node

Jul 31, 2024

Changes in this version

+ const DefaultLeaseDuration

+ const DefaultPingInterval

+ const DefaultRenewIntervalFraction

+ const DefaultStatusUpdateInterval

+ var DefaultRetryFunc = queue.DefaultRetryFunc

+ var ErrConflictingLeaseControllerConfiguration = pkgerrors.New("Multiple, conflicting lease configurations have been put into place")

+ var MaxRetries = queue.MaxRetries

+ type ErrorHandler func(context.Context, error) error

+ type NaiveNodeProvider struct

+ func (NaiveNodeProvider) Ping(ctx context.Context) error

+ func (n NaiveNodeProvider) NotifyNodeStatus(_ context.Context, _ func(*corev1.Node))

+ type NaiveNodeProviderV2 struct

+ func NewNaiveNodeProvider() *NaiveNodeProviderV2

+ func (*NaiveNodeProviderV2) Ping(ctx context.Context) error

+ func (n *NaiveNodeProviderV2) NotifyNodeStatus(_ context.Context, f func(*corev1.Node))

+ func (n *NaiveNodeProviderV2) UpdateStatus(ctx context.Context, node *corev1.Node) error

+ type NodeController struct

+ func NewNodeController(p NodeProvider, node *corev1.Node, nodes v1.NodeInterface, ...) (*NodeController, error)

+ func (n *NodeController) Done() <-chan struct{}

+ func (n *NodeController) Err() error

+ func (n *NodeController) Ready() <-chan struct{}

+ func (n *NodeController) Run(ctx context.Context) (retErr error)

+ type NodeControllerOpt func(*NodeController) error

+ func WithNodeEnableLeaseV1(client coordclientset.LeaseInterface, leaseDurationSeconds int32) NodeControllerOpt

+ func WithNodeEnableLeaseV1WithRenewInterval(client coordclientset.LeaseInterface, leaseDurationSeconds int32, ...) NodeControllerOpt

+ func WithNodePingInterval(d time.Duration) NodeControllerOpt

+ func WithNodePingTimeout(timeout time.Duration) NodeControllerOpt

+ func WithNodeStatusUpdateErrorHandler(h ErrorHandler) NodeControllerOpt

+ func WithNodeStatusUpdateInterval(d time.Duration) NodeControllerOpt

+ type NodeProvider interface

+ NotifyNodeStatus func(ctx context.Context, cb func(*corev1.Node))

+ Ping func(context.Context) error

+ type PodController struct

+ func NewPodController(cfg PodControllerConfig) (*PodController, error)

+ func (pc *PodController) DeletePodsFromKubernetesQueueItemsBeingProcessedLen() int

+ func (pc *PodController) DeletePodsFromKubernetesQueueLen() int

+ func (pc *PodController) DeletePodsFromKubernetesQueueUnprocessedLen() int

+ func (pc *PodController) Done() <-chan struct{}

+ func (pc *PodController) Err() error

+ func (pc *PodController) Ready() <-chan struct{}

+ func (pc *PodController) Run(ctx context.Context, podSyncWorkers int) (retErr error)

+ func (pc *PodController) SyncPodStatusFromProviderQueueItemsBeingProcessedLen() int

+ func (pc *PodController) SyncPodStatusFromProviderQueueLen() int

+ func (pc *PodController) SyncPodStatusFromProviderQueueUnprocessedLen() int

+ func (pc *PodController) SyncPodsFromKubernetesQueueItemsBeingProcessedLen() int

+ func (pc *PodController) SyncPodsFromKubernetesQueueLen() int

+ func (pc *PodController) SyncPodsFromKubernetesQueueUnprocessedLen() int

+ type PodControllerConfig struct

+ ConfigMapInformer corev1informers.ConfigMapInformer

+ DeletePodsFromKubernetesRateLimiter workqueue.RateLimiter

+ DeletePodsFromKubernetesShouldRetryFunc ShouldRetryFunc

+ EventRecorder record.EventRecorder

+ PodClient corev1client.PodsGetter

+ PodEventFilterFunc PodEventFilterFunc

+ PodInformer corev1informers.PodInformer

+ Provider PodLifecycleHandler

+ SecretInformer corev1informers.SecretInformer

+ ServiceInformer corev1informers.ServiceInformer

+ SyncPodStatusFromProviderRateLimiter workqueue.RateLimiter

+ SyncPodStatusFromProviderShouldRetryFunc ShouldRetryFunc

+ SyncPodsFromKubernetesRateLimiter workqueue.RateLimiter

+ SyncPodsFromKubernetesShouldRetryFunc ShouldRetryFunc

+ type PodEventFilterFunc func(context.Context, *corev1.Pod) bool

+ type PodLifecycleHandler interface

+ CreatePod func(ctx context.Context, pod *corev1.Pod) error

+ DeletePod func(ctx context.Context, pod *corev1.Pod) error

+ GetPod func(ctx context.Context, namespace, name string) (*corev1.Pod, error)

+ GetPodStatus func(ctx context.Context, namespace, name string) (*corev1.PodStatus, error)

+ GetPods func(context.Context) ([]*corev1.Pod, error)

+ UpdatePod func(ctx context.Context, pod *corev1.Pod) error

+ type PodNotifier interface

+ NotifyPods func(context.Context, func(*corev1.Pod))

+ type ShouldRetryFunc = queue.ShouldRetryFunc