kube

Documentation

Index

• func EnableEvenPodsSpread(ver *version.Info) (bool, error)
• type ClientSet
  • func NewClientSet(config *rest.Config) (ClientSet, error)
• type ConfigMap
  • func NewConfigMap(kubecli client.Client) ConfigMap
• type Endpoint
  • func NewEndpointClient(cli client.Client) Endpoint
• type FakeNebulaCluster
  • func (f *FakeNebulaCluster) GetNebulaCluster(namespace, name string) (*v1alpha1.NebulaCluster, error)
  • func (f *FakeNebulaCluster) UpdateNebulaClusterStatus(nc *v1alpha1.NebulaCluster) error
• type NebulaCluster
  • func NewFakeNebulaCluster(cli client.Client) NebulaCluster
  • func NewNebulaCluster(cli client.Client) NebulaCluster
• type PersistentVolume
  • func NewPV(kubecli client.Client) PersistentVolume
• type PersistentVolumeClaim
  • func NewPVC(kubecli client.Client) PersistentVolumeClaim
• type Pod
  • func NewPod(kubecli client.Client) Pod
• type Service
  • func NewService(kubecli client.Client) Service
• type Workload
  • func NewWorkload(kubecli client.Client) Workload

Functions

func EnableEvenPodsSpread

func EnableEvenPodsSpread(ver *version.Info) (bool, error)

Types

type ClientSet

type ClientSet interface {
	ConfigMap() ConfigMap
	PV() PersistentVolume
	PVC() PersistentVolumeClaim
	Pod() Pod
	Endpoint() Endpoint
	Service() Service
	Workload() Workload
	NebulaCluster() NebulaCluster
}

func NewClientSet

func NewClientSet(config *rest.Config) (ClientSet, error)

type ConfigMap

type ConfigMap interface {
	CreateOrUpdateConfigMap(cm *corev1.ConfigMap) error
}

func NewConfigMap

func NewConfigMap(kubecli client.Client) ConfigMap

type Endpoint

type Endpoint interface {
	GetEndpoints(namespace string, name string) (*corev1.Endpoints, error)
}

func NewEndpointClient

func NewEndpointClient(cli client.Client) Endpoint

type FakeNebulaCluster

type FakeNebulaCluster struct {
	// contains filtered or unexported fields
}

func (*FakeNebulaCluster) GetNebulaCluster

func (f *FakeNebulaCluster) GetNebulaCluster(namespace, name string) (*v1alpha1.NebulaCluster, error)

func (*FakeNebulaCluster) UpdateNebulaClusterStatus

func (f *FakeNebulaCluster) UpdateNebulaClusterStatus(nc *v1alpha1.NebulaCluster) error

type NebulaCluster

type NebulaCluster interface {
	GetNebulaCluster(namespace, name string) (*v1alpha1.NebulaCluster, error)
	UpdateNebulaClusterStatus(nc *v1alpha1.NebulaCluster) error
}

func NewFakeNebulaCluster

func NewFakeNebulaCluster(cli client.Client) NebulaCluster

func NewNebulaCluster

func NewNebulaCluster(cli client.Client) NebulaCluster

type PersistentVolume

type PersistentVolume interface {
	CreatePersistentVolume(pv *corev1.PersistentVolume) error
	GetPersistentVolume(name string) (*corev1.PersistentVolume, error)
	PatchPVReclaimPolicy(pv *corev1.PersistentVolume, policy corev1.PersistentVolumeReclaimPolicy) error
	UpdateMetaInfo(obj runtime.Object, pv *corev1.PersistentVolume) error
	UpdatePersistentVolume(pv *corev1.PersistentVolume) error
}

func NewPV

func NewPV(kubecli client.Client) PersistentVolume

type PersistentVolumeClaim

type PersistentVolumeClaim interface {
	CreatePVC(pvc *corev1.PersistentVolumeClaim) error
	GetPVC(namespace, name string) (*corev1.PersistentVolumeClaim, error)
	UpdateMetaInfo(pvc *corev1.PersistentVolumeClaim, pod *corev1.Pod) error
	UpdatePVC(pvc *corev1.PersistentVolumeClaim) error
	DeletePVC(namespace string, name string) error
	ListPVCs(namespace string, selector labels.Selector) ([]corev1.PersistentVolumeClaim, error)
}

func NewPVC

func NewPVC(kubecli client.Client) PersistentVolumeClaim

type Pod

type Pod interface {
	GetPod(namespace string, name string) (*corev1.Pod, error)
	UpdatePod(pod *corev1.Pod) error
	DeletePod(namespace string, name string) error
	ListPods(namespace string, selector labels.Selector) ([]corev1.Pod, error)
}

func NewPod

func NewPod(kubecli client.Client) Pod

type Service

type Service interface {
	CreateService(service *corev1.Service) error
	GetService(namespace string, name string) (*corev1.Service, error)
	UpdateService(service *corev1.Service) error
	DeleteService(namespace string, name string) error
}

func NewService

func NewService(kubecli client.Client) Service

type Workload

type Workload interface {
	GetWorkload(namespace string, name string, gvk schema.GroupVersionKind) (*unstructured.Unstructured, error)
	CreateWorkload(obj *unstructured.Unstructured) error
	UpdateWorkload(obj *unstructured.Unstructured) error
}

func NewWorkload

func NewWorkload(kubecli client.Client) Workload