nodevalidator

Documentation

Index

• func NewNodeReadinessChecker(client kubernetes.Interface, timeout time.Duration, logger *zap.Logger) *nodeReadinessChecker
• func NewNodeRegistrationChecker(client kubernetes.Interface, timeout time.Duration, logger *zap.Logger) *nodeRegistrationChecker
• func WithNodeReadiness(validate bool) func(*ActiveNodeValidator)
• func WithNodeRegistration(validate bool) func(*ActiveNodeValidator)
• func WithTimeout(timeout time.Duration) func(*ActiveNodeValidator)
• type ActiveNodeValidator
  • func NewActiveNodeValidator(opts ...func(*ActiveNodeValidator)) ActiveNodeValidator
  • func (v ActiveNodeValidator) Run(ctx context.Context, informer validation.Informer, nodeConfig *api.NodeConfig) error

Functions

func NewNodeReadinessChecker

func NewNodeReadinessChecker(client kubernetes.Interface, timeout time.Duration, logger *zap.Logger) *nodeReadinessChecker

func NewNodeRegistrationChecker

func NewNodeRegistrationChecker(client kubernetes.Interface, timeout time.Duration, logger *zap.Logger) *nodeRegistrationChecker

NewNodeRegistrationChecker creates a new NodeRegistrationChecker

func WithNodeReadiness

func WithNodeReadiness(validate bool) func(*ActiveNodeValidator)

func WithNodeRegistration

func WithNodeRegistration(validate bool) func(*ActiveNodeValidator)

func WithTimeout

func WithTimeout(timeout time.Duration) func(*ActiveNodeValidator)

configures the timeout for validations

Types

type ActiveNodeValidator

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

func NewActiveNodeValidator

func NewActiveNodeValidator(opts ...func(*ActiveNodeValidator)) ActiveNodeValidator

func (ActiveNodeValidator) Run

func (v ActiveNodeValidator) Run(ctx context.Context, informer validation.Informer, nodeConfig *api.NodeConfig) error