Versions in this module Expand all Collapse all v0 v0.2.1 Apr 29, 2021 Changes in this version + const DefaultPingInterval + const DefaultStatusUpdateInterval + const ReasonFailedToReadMandatoryConfigMap + const ReasonFailedToReadMandatorySecret + const ReasonFailedToReadOptionalConfigMap + const ReasonFailedToReadOptionalSecret + const ReasonInvalidEnvironmentVariableNames + const ReasonMandatoryConfigMapKeyNotFound + const ReasonMandatoryConfigMapNotFound + const ReasonMandatorySecretKeyNotFound + const ReasonMandatorySecretNotFound + const ReasonOptionalConfigMapKeyNotFound + const ReasonOptionalConfigMapNotFound + const ReasonOptionalSecretKeyNotFound + const ReasonOptionalSecretNotFound + type ErrorHandler func(context.Context, error) error + type NaiveNodeProvider struct + func (NaiveNodeProvider) NotifyNodeStatus(ctx context.Context, f func(*corev1.Node)) + func (NaiveNodeProvider) Ping(ctx context.Context) error + type NodeController struct + func NewNodeController(p NodeProvider, node *corev1.Node, nodes v1.NodeInterface, ...) (*NodeController, error) + func (n *NodeController) Ready() <-chan struct{} + func (n *NodeController) Run(ctx context.Context) error + func (n *NodeController) UpdateNodeFromOutside(skipErrorCb bool, no *corev1.Node) error + type NodeControllerOpt func(*NodeController) error + func WithNodeEnableLeaseV1Beta1(client v1beta1.LeaseInterface, baseLease *coord.Lease) NodeControllerOpt + func WithNodePingInterval(d 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) 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) + type PodControllerConfig struct + ConfigMapInformer corev1informers.ConfigMapInformer + EventRecorder record.EventRecorder + PodClient corev1client.PodsGetter + PodInformer corev1informers.PodInformer + Provider PodLifecycleHandler + SecretInformer corev1informers.SecretInformer + ServiceInformer corev1informers.ServiceInformer + 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(interface{}))
Go to main page