nodemaintenance

Documentation

Overview

Package nodemaintenance is a generated GoMock package.

Index

• Variables
• func Add(mgr manager.Manager) error
• func AddOrRemoveTaint(clientset kubernetes.Interface, node *corev1.Node, add bool) error
• func ContainsString(slice []string, s string) bool
• func GetPodNameList(pods []corev1.Pod) (result []string)
• func RemoveString(slice []string, s string) (result []string)
• type MockReconcileHandler
  • func NewMockReconcileHandler(ctrl *gomock.Controller) *MockReconcileHandler
  • func (m *MockReconcileHandler) EXPECT() *MockReconcileHandlerMockRecorder
  • func (m *MockReconcileHandler) StartPodInformer(node *v1.Node, stop <-chan struct{}) error
• type MockReconcileHandlerMockRecorder
  • func (mr *MockReconcileHandlerMockRecorder) StartPodInformer(node, stop interface{}) *gomock.Call
• type ReconcileHandler
• type ReconcileNodeMaintenance
  • func (r *ReconcileNodeMaintenance) Reconcile(request reconcile.Request) (reconcile.Result, error)
  • func (r *ReconcileNodeMaintenance) StartPodInformer(node *corev1.Node, stop <-chan struct{}) error

Variables

var KubevirtDrainTaint = &corev1.Taint{
	Key:    "kubevirt.io/drain",
	Effect: corev1.TaintEffectNoSchedule,
}

var MaintenanceTaints = []corev1.Taint{*NodeUnschedulableTaint, *KubevirtDrainTaint}

var NodeUnschedulableTaint = &corev1.Taint{
	Key:    "node.kubernetes.io/unschedulable",
	Effect: corev1.TaintEffectNoSchedule,
}

Functions

func Add

func Add(mgr manager.Manager) error

Add creates a new NodeMaintenance Controller and adds it to the Manager. The Manager will set fields on the Controller and Start it when the Manager is Started.

func AddOrRemoveTaint

func AddOrRemoveTaint(clientset kubernetes.Interface, node *corev1.Node, add bool) error

func ContainsString

func ContainsString(slice []string, s string) bool

ContainsString checks if the string array contains the given string.

func GetPodNameList

func GetPodNameList(pods []corev1.Pod) (result []string)

GetPodNameList returns a list of pod names from a pod list

func RemoveString

func RemoveString(slice []string, s string) (result []string)

RemoveString removes the given string from the string array if exists.

Types

type MockReconcileHandler

type MockReconcileHandler struct {
	// contains filtered or unexported fields
}

MockReconcileHandler is a mock of ReconcileHandler interface

func NewMockReconcileHandler

func NewMockReconcileHandler(ctrl *gomock.Controller) *MockReconcileHandler

NewMockReconcileHandler creates a new mock instance

func (*MockReconcileHandler) EXPECT

func (m *MockReconcileHandler) EXPECT() *MockReconcileHandlerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockReconcileHandler) StartPodInformer

func (m *MockReconcileHandler) StartPodInformer(node *v1.Node, stop <-chan struct{}) error

StartPodInformer mocks base method

type MockReconcileHandlerMockRecorder

type MockReconcileHandlerMockRecorder struct {
	// contains filtered or unexported fields
}

MockReconcileHandlerMockRecorder is the mock recorder for MockReconcileHandler

func (*MockReconcileHandlerMockRecorder) StartPodInformer

func (mr *MockReconcileHandlerMockRecorder) StartPodInformer(node, stop interface{}) *gomock.Call

StartPodInformer indicates an expected call of StartPodInformer

type ReconcileHandler

type ReconcileHandler interface {
	StartPodInformer(node *corev1.Node, stop <-chan struct{}) error
}

var Handler ReconcileHandler

type ReconcileNodeMaintenance

type ReconcileNodeMaintenance struct {
	// contains filtered or unexported fields
}

ReconcileNodeMaintenance reconciles a NodeMaintenance object

func (*ReconcileNodeMaintenance) Reconcile

func (r *ReconcileNodeMaintenance) Reconcile(request reconcile.Request) (reconcile.Result, error)

Reconcile reads that state of the cluster for a NodeMaintenance object and makes changes based on the state read and what is in the NodeMaintenance.Spec Note: The Controller will requeue the Request to be processed again if the returned error is non-nil or Result.Requeue is true, otherwise upon completion it will remove the work from the queue.

func (*ReconcileNodeMaintenance) StartPodInformer

func (r *ReconcileNodeMaintenance) StartPodInformer(node *corev1.Node, stop <-chan struct{}) error