controllers

Jul 8, 2024

Changes in this version

type Config

+ FuncMap gotpl.FuncMap

Feb 2, 2024

Changes in this version

type Config

+ DynamicClient dynamic.Interface

+ ImpersonatingDynamicClient client.DynamicClientImpersonator

+ LocalStages map[internalversion.StageResourceRef][]*internalversion.Stage

+ RESTClient rest.Interface

+ RESTMapper meta.RESTMapper

type NodeController

+ func (c *NodeController) ManageNode(node *corev1.Node)

type NodeControllerConfig

+ OnNodeUnmanagedFunc func(nodeName string)

type NodeLeaseController

+ func (c *NodeLeaseController) ReleaseHold(name string)

type NodeLeaseControllerConfig

+ GetLease func(nodeName string) (*coordinationv1.Lease, bool)

+ type StageController struct

+ func NewStageController(conf StageControllerConfig) (*StageController, error)

+ func (c *StageController) Start(ctx context.Context, events <-chan informer.Event[*unstructured.Unstructured]) error

+ type StageControllerConfig struct

+ Clock clock.Clock

+ DisregardStatusWithAnnotationSelector string

+ DisregardStatusWithLabelSelector string

+ DynamicClient dynamic.Interface

+ FuncMap gotpl.FuncMap

+ GVR schema.GroupVersionResource

+ ImpersonatingDynamicClient client.DynamicClientImpersonator

+ Lifecycle resources.Getter[Lifecycle]

+ PlayStageParallelism uint

+ Recorder record.EventRecorder

+ Schema strategicpatch.LookupPatchMeta

+ type StagesManager struct

+ func NewStagesManager(conf StagesManagerConfig) *StagesManager

+ func (c *StagesManager) Start(ctx context.Context) error

+ type StagesManagerConfig struct

+ StageGetter resources.DynamicGetter[[]*internalversion.Stage]

+ StartFunc func(ctx context.Context, ref internalversion.StageResourceRef, ...) error

Aug 23, 2023

Changes in this version

type Config

+ EnableMetrics bool

+ EnablePodCache bool

+ ManageSingleNode string

+ TypedClient kubernetes.Interface

+ TypedKwokClient versioned.Interface

type Controller

+ func (c *Controller) GetNodeCache() informer.Getter[*corev1.Node]

+ func (c *Controller) GetPodCache() informer.Getter[*corev1.Pod]

+ func (c *Controller) ListNodes() []string

+ func (c *Controller) ListPods(nodeName string) ([]log.ObjectRef, bool)

+ func (c *Controller) StartedContainersTotal(nodeName string) int64

type LifecycleStage

+ func NewLifecycleStage(s *internalversion.Stage) (*LifecycleStage, error)

type NodeController

+ func (c *NodeController) List() []string

type NodeControllerConfig

+ EnableMetrics bool

+ Lifecycle resources.Getter[Lifecycle]

+ NodeCacheGetter informer.Getter[*corev1.Node]

+ TypedClient kubernetes.Interface

type NodeLeaseControllerConfig

+ NodeCacheGetter informer.Getter[*corev1.Node]

+ TypedClient clientset.Interface

type PodController

+ func (c *PodController) Get(namespace, name string) (*PodInfo, bool)

+ func (c *PodController) List(nodeName string) ([]log.ObjectRef, bool)

type PodControllerConfig

+ EnableMetrics bool

+ Lifecycle resources.Getter[Lifecycle]

+ NodeCacheGetter informer.Getter[*corev1.Node]

+ TypedClient kubernetes.Interface

+ type PodInfo struct

Jun 20, 2023

Changes in this version

+ func Identity() (string, error)

type Config

+ Clock clock.Clock

+ ID string

+ Metrics []*internalversion.Metric

+ NodeLeaseDurationSeconds uint

+ NodeLeaseParallelism uint

+ NodePlayStageParallelism uint

+ PodPlayStageParallelism uint

type Controller

+ func (c *Controller) GetNode(nodeName string) (*NodeInfo, bool)

type NodeController

+ func (c *NodeController) Manage(nodeName string)

type NodeControllerConfig

+ Clock clock.Clock

+ OnNodeManagedFunc func(nodeName string)

+ PlayStageParallelism uint

+ ReadOnlyFunc func(nodeName string) bool

type NodeInfo

+ Node *corev1.Node

+ OwnerReferences []metav1.OwnerReference

+ StartedContainer atomic.Int64

+ type NodeLeaseController struct

+ func NewNodeLeaseController(conf NodeLeaseControllerConfig) (*NodeLeaseController, error)

+ func (c *NodeLeaseController) Held(name string) bool

+ func (c *NodeLeaseController) Start(ctx context.Context) error

+ func (c *NodeLeaseController) TryHold(name string)

+ type NodeLeaseControllerConfig struct

+ ClientSet clientset.Interface

+ Clock clock.Clock

+ HolderIdentity string

+ LeaseDurationSeconds uint

+ LeaseNamespace string

+ LeaseParallelism uint

+ MutateLeaseFunc func(*coordinationv1.Lease) error

+ OnNodeManagedFunc func(nodeName string)

+ RenewInterval time.Duration

+ RenewIntervalJitter float64

type PodController

+ func (c *PodController) PlayStagePodsOnNode(nodeName string)

type PodControllerConfig

+ Clock clock.Clock

+ Namespace string

+ NodeHasMetric func(nodeName string) bool

+ PlayStageParallelism uint

+ ReadOnlyFunc func(nodeName string) bool

Apr 20, 2023

Changes in this version

type LifecycleStage

+ func (s *LifecycleStage) ImmediateNextStage() bool

type NodeController

+ func (c *NodeController) Get(nodeName string) (*NodeInfo, bool)

+ type NodeInfo struct

+ HostIPs []string

+ PodCIDRs []string

type PodControllerConfig

+ NodeGetFunc func(nodeName string) (*NodeInfo, bool)

Jan 13, 2023

Changes in this version

+ func NewStagesFromYaml(data []byte) ([]*internalversion.Stage, error)

+ type Config struct

+ CIDR string

+ ClientSet kubernetes.Interface

+ DisregardStatusWithAnnotationSelector string

+ DisregardStatusWithLabelSelector string

+ EnableCNI bool

+ ManageAllNodes bool

+ ManageNodesWithAnnotationSelector string

+ ManageNodesWithLabelSelector string

+ NodeIP string

+ NodeName string

+ NodePort int

+ NodeStages []*internalversion.Stage

+ PodStages []*internalversion.Stage

+ type Controller struct

+ func NewController(conf Config) (*Controller, error)

+ func (c *Controller) Start(ctx context.Context) error

+ type Lifecycle []*LifecycleStage

+ func NewLifecycle(stages []*internalversion.Stage) (Lifecycle, error)

+ func (s Lifecycle) Match(label, annotation labels.Set, data interface{}) (*LifecycleStage, error)

+ type LifecycleStage struct

+ func (s *LifecycleStage) Delay(ctx context.Context, v interface{}, now time.Time) (time.Duration, bool)

+ func (s *LifecycleStage) Name() string

+ func (s *LifecycleStage) Next() *internalversion.StageNext

+ type NodeController struct

+ func NewNodeController(conf NodeControllerConfig) (*NodeController, error)

+ func (c *NodeController) DeleteNode(ctx context.Context, node *corev1.Node) error

+ func (c *NodeController) FinalizersModify(ctx context.Context, node *corev1.Node, ...) error

+ func (c *NodeController) Has(nodeName string) bool

+ func (c *NodeController) ListNodes(ctx context.Context, ch chan<- *corev1.Node, opt metav1.ListOptions) error

+ func (c *NodeController) LockNode(ctx context.Context, node *corev1.Node) error

+ func (c *NodeController) LockNodes(ctx context.Context, nodes <-chan *corev1.Node)

+ func (c *NodeController) Size() int

+ func (c *NodeController) Start(ctx context.Context) error

+ func (c *NodeController) WatchNodes(ctx context.Context, ch chan<- *corev1.Node, opt metav1.ListOptions) error

+ type NodeControllerConfig struct

+ ClientSet kubernetes.Interface

+ DisregardStatusWithAnnotationSelector string

+ DisregardStatusWithLabelSelector string

+ FuncMap template.FuncMap

+ LockNodeParallelism int

+ LockPodsOnNodeFunc func(ctx context.Context, nodeName string) error

+ ManageNodesWithAnnotationSelector string

+ ManageNodesWithLabelSelector string

+ NodeIP string

+ NodeName string

+ NodePort int

+ NodeSelectorFunc func(node *corev1.Node) bool

+ Recorder record.EventRecorder

+ Stages []*internalversion.Stage

+ type PodController struct

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

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

+ func (c *PodController) FinalizersModify(ctx context.Context, pod *corev1.Pod, ...) error

+ func (c *PodController) ListPods(ctx context.Context, ch chan<- *corev1.Pod, opt metav1.ListOptions) error

+ func (c *PodController) LockPod(ctx context.Context, pod *corev1.Pod) error

+ func (c *PodController) LockPods(ctx context.Context, pods <-chan *corev1.Pod)

+ func (c *PodController) LockPodsOnNode(ctx context.Context, nodeName string) error

+ func (c *PodController) Start(ctx context.Context) error

+ func (c *PodController) WatchPods(ctx context.Context, lockChan chan<- *corev1.Pod, opt metav1.ListOptions) error

+ type PodControllerConfig struct

+ CIDR string

+ ClientSet kubernetes.Interface

+ DisregardStatusWithAnnotationSelector string

+ DisregardStatusWithLabelSelector string

+ EnableCNI bool

+ FuncMap template.FuncMap

+ LockPodParallelism int

+ NodeHasFunc func(nodeName string) bool

+ NodeIP string

+ Recorder record.EventRecorder

+ Stages []*internalversion.Stage