k8s

package
v1.6.2-rc Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 24, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Service

type Service interface {
	// ListLocalPods list local pod from api server
	ListLocalPods(ctx context.Context) ([]*corev1.Pod, error)

	// GetPod get pod from api server
	GetPod(ctx context.Context, namespace, name string) (*corev1.Pod, error)

	// ListCachedPods list local pod from local cached(informer)
	ListCachedPods() ([]*corev1.Pod, error)

	// ListCachedPodsWithLabelSelector list local pod with selector from local cached(informer)
	ListCachedPodsWithLabelSelector(selector labels.Selector) ([]*corev1.Pod, error)

	// GetCachedPod get local pod from local cached(informer)
	GetCachedPod(namespace, name string) (*corev1.Pod, error)

	// GetLocalNode get the node itself from api server
	GetLocalNode(ctx context.Context) (*corev1.Node, error)

	// GetConfigMap get configmap from api server
	GetConfigMap(ctx context.Context, namespace, name string) (*corev1.ConfigMap, error)

	// GetNodeDynamicConfigName get namespace and name of dynamic configmap that separated by '.'
	GetNodeDynamicConfigName() string

	// RecordNodeEvent record events of node
	RecordNodeEvent(eventType, reason, message string)

	// RecordPodEvent record events of pod
	RecordPodEvent(podName, podNamespace, eventType, reason, message string) error

	// EvictPod evict the specific pod
	EvictPod(ctx context.Context, podName, namespace string) error

	// AddConfigMapEventHandler add handler which called while configmap cello-config changed
	AddConfigMapEventHandler(handler cache.ResourceEventHandlerFuncs)

	// PatchTrunkInfo patch trunk info to node annotation
	PatchTrunkInfo(info *types.TrunkInfo) error

	// PatchPodAnnotation patch annotation to pod
	PatchPodAnnotation(ctx context.Context, namespace, name string, anno map[string]string) error
}

func NewK8sService

func NewK8sService(nodeName string, clientSet kubernetes.Interface) (Service, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL