node

Documentation

Index

• func IsDrained(ctx context.Context) error
• func IsInitialized(ctx context.Context) error
• func IsUnscheduled(ctx context.Context) error
• func NewNodeProvider(configSource string, logger *zap.Logger) (nodeprovider.NodeProvider, error)
• type APIServerValidator
  • func NewAPIServerValidator(opts ...APIServerValidatorOption) APIServerValidator
  • func (a APIServerValidator) CheckIdentity(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
  • func (a APIServerValidator) CheckVPCEndpointAccess(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
  • func (a APIServerValidator) MakeAuthenticatedRequest(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error
• type APIServerValidatorOption
  • func WithClientBuilder(buildClient func() (kubernetes.Interface, error)) APIServerValidatorOption

Functions

func IsDrained

func IsDrained(ctx context.Context) error

func IsInitialized

func IsInitialized(ctx context.Context) error

func IsUnscheduled

func IsUnscheduled(ctx context.Context) error

func NewNodeProvider

func NewNodeProvider(configSource string, logger *zap.Logger) (nodeprovider.NodeProvider, error)

Types

type APIServerValidator

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

func NewAPIServerValidator

func NewAPIServerValidator(opts ...APIServerValidatorOption) APIServerValidator

func (APIServerValidator) CheckIdentity

func (a APIServerValidator) CheckIdentity(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error

func (APIServerValidator) CheckVPCEndpointAccess

func (a APIServerValidator) CheckVPCEndpointAccess(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error

func (APIServerValidator) MakeAuthenticatedRequest

func (a APIServerValidator) MakeAuthenticatedRequest(ctx context.Context, informer validation.Informer, node *api.NodeConfig) error

type APIServerValidatorOption

type APIServerValidatorOption func(*APIServerValidator)

func WithClientBuilder

func WithClientBuilder(buildClient func() (kubernetes.Interface, error)) APIServerValidatorOption