context

Jan 27, 2023

Changes in this version

type ClusterContext

+ DeletePodWithCondition func(pod *v1.Pod, condition func(pod *v1.Pod) bool, pessimistic bool) error

+ GetEndpointSlices func(namespace string, labelName string, labelValue string) ([]*discovery.EndpointSlice, error)

type KubernetesClusterContext

+ func (c *KubernetesClusterContext) DeletePodWithCondition(pod *v1.Pod, condition func(pod *v1.Pod) bool, pessimistic bool) error

+ func (c *KubernetesClusterContext) GetEndpointSlices(namespace string, labelName string, labelValue string) ([]*discovery.EndpointSlice, error)

Jan 23, 2023

Changes in this version

+ type ClusterContext interface

+ AddAnnotation func(pod *v1.Pod, annotations map[string]string) error

+ AddClusterEventAnnotation func(event *v1.Event, annotations map[string]string) error

+ AddClusterEventEventHandler func(handler cache.ResourceEventHandlerFuncs)

+ AddPodEventHandler func(handler cache.ResourceEventHandlerFuncs)

+ DeleteIngress func(ingress *networking.Ingress) error

+ DeletePods func(pods []*v1.Pod)

+ DeleteService func(service *v1.Service) error

+ GetActiveBatchPods func() ([]*v1.Pod, error)

+ GetAllPods func() ([]*v1.Pod, error)

+ GetBatchPods func() ([]*v1.Pod, error)

+ GetIngresses func(pod *v1.Pod) ([]*networking.Ingress, error)

+ GetNode func(nodeName string) (*v1.Node, error)

+ GetNodeStatsSummary func(context.Context, *v1.Node) (*v1alpha1.Summary, error)

+ GetNodes func() ([]*v1.Node, error)

+ GetPodEvents func(pod *v1.Pod) ([]*v1.Event, error)

+ GetServices func(pod *v1.Pod) ([]*v1.Service, error)

+ Stop func()

+ SubmitIngress func(ingress *networking.Ingress) (*networking.Ingress, error)

+ SubmitPod func(pod *v1.Pod, owner string, ownerGroups []string) (*v1.Pod, error)

+ SubmitService func(service *v1.Service) (*v1.Service, error)

+ type ClusterIdentity interface

+ GetClusterId func() string

+ GetClusterPool func() string

+ type KubernetesClusterContext struct

+ func NewClusterContext(configuration configuration.ApplicationConfiguration, ...) *KubernetesClusterContext

+ func (c *KubernetesClusterContext) AddAnnotation(pod *v1.Pod, annotations map[string]string) error

+ func (c *KubernetesClusterContext) AddClusterEventAnnotation(event *v1.Event, annotations map[string]string) error

+ func (c *KubernetesClusterContext) AddClusterEventEventHandler(handler cache.ResourceEventHandlerFuncs)

+ func (c *KubernetesClusterContext) AddPodEventHandler(handler cache.ResourceEventHandlerFuncs)

+ func (c *KubernetesClusterContext) DeleteIngress(ingress *networking.Ingress) error

+ func (c *KubernetesClusterContext) DeletePods(pods []*v1.Pod)

+ func (c *KubernetesClusterContext) DeleteService(service *v1.Service) error

+ func (c *KubernetesClusterContext) GetActiveBatchPods() ([]*v1.Pod, error)

+ func (c *KubernetesClusterContext) GetAllPods() ([]*v1.Pod, error)

+ func (c *KubernetesClusterContext) GetBatchPods() ([]*v1.Pod, error)

+ func (c *KubernetesClusterContext) GetClusterId() string

+ func (c *KubernetesClusterContext) GetClusterPool() string

+ func (c *KubernetesClusterContext) GetIngresses(pod *v1.Pod) ([]*networking.Ingress, error)

+ func (c *KubernetesClusterContext) GetNode(nodeName string) (*v1.Node, error)

+ func (c *KubernetesClusterContext) GetNodeStatsSummary(ctx context.Context, node *v1.Node) (*v1alpha1.Summary, error)

+ func (c *KubernetesClusterContext) GetNodes() ([]*v1.Node, error)

+ func (c *KubernetesClusterContext) GetPodEvents(pod *v1.Pod) ([]*v1.Event, error)

+ func (c *KubernetesClusterContext) GetServices(pod *v1.Pod) ([]*v1.Service, error)

+ func (c *KubernetesClusterContext) ProcessPodsToDelete()

+ func (c *KubernetesClusterContext) Stop()

+ func (c *KubernetesClusterContext) SubmitIngress(ingress *networking.Ingress) (*networking.Ingress, error)

+ func (c *KubernetesClusterContext) SubmitPod(pod *v1.Pod, owner string, ownerGroups []string) (*v1.Pod, error)

+ func (c *KubernetesClusterContext) SubmitService(service *v1.Service) (*v1.Service, error)