Documentation
¶
Index ¶
- func GetPodsOnNode(ctx context.Context, nodeName string, clientset kubernetes.Interface) ([]corev1.Pod, error)
- func IsDrained(ctx context.Context) (bool, error)
- func IsInitialized(ctx context.Context) error
- func IsUnscheduled(ctx context.Context) error
- func NewNodeProvider(configSource string, skipPhases []string, logger *zap.Logger) (nodeprovider.NodeProvider, error)
- type 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 Kubelet
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPodsOnNode ¶ added in v1.0.4
func GetPodsOnNode(ctx context.Context, nodeName string, clientset kubernetes.Interface) ([]corev1.Pod, error)
GetPodsOnNode makes 5 attempts by default to list pods before erroring unless it times out.
func IsInitialized ¶
func IsUnscheduled ¶
func NewNodeProvider ¶
func NewNodeProvider(configSource string, skipPhases []string, logger *zap.Logger) (nodeprovider.NodeProvider, error)
Types ¶
type APIServerValidator ¶
type APIServerValidator struct {
// contains filtered or unexported fields
}
func NewAPIServerValidator ¶
func NewAPIServerValidator(kubelet Kubelet) 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 Kubelet ¶ added in v1.0.4
type Kubelet interface {
// BuildClient creates a new Kubernetes client
BuildClient() (kubernetes.Interface, error)
// KubeconfigPath returns the path to the kubeconfig file
KubeconfigPath() string
// Version returns the current kubelet version
Version() (string, error)
}
Kubelet is the kubernetes node agent.
Click to show internal directories.
Click to hide internal directories.