nodematch

package

v0.0.0-...-c7dd6ca Latest Latest Go to latest Published: Mar 6, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func ValidateMatch(match *flipopv1alpha1.Match) error

ValidateMatch returns an error if the provided match spec is invalid.

type Controller struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Controller watches Kubernetes nodes and pods and enables or disables them with the provided action based upon the provided criteria.

func NewController(log logrus.FieldLogger, kubeCS kubernetes.Interface, action NodeEnableDisabler) *Controller

NewController builds a new node match Controller.

func (m *Controller) IsCriteriaEqual(match *flipopv1alpha1.Match) bool

IsCriteriaEqual returns true if the specified criteria match the current criteria.

func (m *Controller) OnAdd(obj interface{}, _ bool)

OnAdd implements the shared informer ResourceEventHandler for corev1.Pod & corev1.Node.

func (m *Controller) OnDelete(obj interface{})

OnDelete implements the shared informer ResourceEventHandler for corev1.Pod & corev1.Node.

func (m *Controller) OnUpdate(_, newObj interface{})

OnUpdate implements the shared informer ResourceEventHandler for corev1.Pod & corev1.Node.

func (m *Controller) SetCriteria(match *flipopv1alpha1.Match)

SetCriteria sets the match criteria based on the match spec.

func (m *Controller) Start(ctx context.Context)

Start begins asynchronous execution of the node match controller.

func (m *Controller) Stop()

Stop terminates execution of the node match controller and waits for it to finish.

type NodeEnableDisabler interface {
	EnableNodes(...*corev1.Node)
	DisableNodes(...*corev1.Node)
}

NodeEnableDisabler describes a controller which can enable or disable sets of nodes, based upon decisions reached by the node match controller.