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 Deployment
  • func NewDeployment(kubecli client.Client) Deployment
• type Endpoint
  • func NewEndpointClient(cli client.Client) Endpoint
• type FakeNebulaCluster
  • func (f *FakeNebulaCluster) CreateNebulaCluster(_ *v1alpha1.NebulaCluster) error
  • func (f *FakeNebulaCluster) DeleteNebulaCluster(_, _ string) error
  • func (f *FakeNebulaCluster) GetNebulaCluster(_, _ string) (*v1alpha1.NebulaCluster, error)
  • func (f *FakeNebulaCluster) UpdateNebulaCluster(_ *v1alpha1.NebulaCluster) error
  • func (f *FakeNebulaCluster) UpdateNebulaClusterStatus(_ *v1alpha1.NebulaCluster) error
• type Ingress
  • func NewIngress(kubecli client.Client) Ingress
• type NebulaCluster
  • func NewFakeNebulaCluster(client client.Client) NebulaCluster
  • func NewNebulaCluster(client client.Client) NebulaCluster
• type NebulaRestore
  • func NewNebulaRestore(cli client.Client) NebulaRestore
• 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 RestoreUpdateStatus
• type Secret
  • func NewSecret(kubecli client.Client) Secret
• 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 {
	Secret() Secret
	ConfigMap() ConfigMap
	PV() PersistentVolume
	PVC() PersistentVolumeClaim
	Pod() Pod
	Endpoint() Endpoint
	Service() Service
	Ingress() Ingress
	Workload() Workload
	Deployment() Deployment
	NebulaCluster() NebulaCluster
	NebulaRestore() NebulaRestore
}

func NewClientSet

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

type ConfigMap

type ConfigMap interface {
	CreateOrUpdateConfigMap(cm *corev1.ConfigMap) error
	GetConfigMap(namespace, cmName string) (*corev1.ConfigMap, error)
	DeleteConfigMap(namespace, cmName string) error
}

func NewConfigMap

func NewConfigMap(kubecli client.Client) ConfigMap

type Deployment

type Deployment interface {
	CreateDeployment(deploy *appsv1.Deployment) error
	GetDeployment(namespace string, name string) (*appsv1.Deployment, error)
	UpdateDeployment(*appsv1.Deployment) error
}

func NewDeployment

func NewDeployment(kubecli client.Client) Deployment

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) CreateNebulaCluster

func (f *FakeNebulaCluster) CreateNebulaCluster(_ *v1alpha1.NebulaCluster) error

func (*FakeNebulaCluster) DeleteNebulaCluster

func (f *FakeNebulaCluster) DeleteNebulaCluster(_, _ string) error

func (*FakeNebulaCluster) GetNebulaCluster

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

func (*FakeNebulaCluster) UpdateNebulaCluster

func (f *FakeNebulaCluster) UpdateNebulaCluster(_ *v1alpha1.NebulaCluster) error

func (*FakeNebulaCluster) UpdateNebulaClusterStatus

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

type Ingress

type Ingress interface {
	CreateOrUpdateIngress(ingress *networkingv1.Ingress) error
	GetIngress(namespace, ingressName string) (*networkingv1.Ingress, error)
	DeleteIngress(namespace, ingressName string) error
}

func NewIngress

func NewIngress(kubecli client.Client) Ingress

type NebulaCluster

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

func NewFakeNebulaCluster

func NewFakeNebulaCluster(client client.Client) NebulaCluster

func NewNebulaCluster

func NewNebulaCluster(client client.Client) NebulaCluster

type NebulaRestore

type NebulaRestore interface {
	GetNebulaRestore(namespace, name string) (*v1alpha1.NebulaRestore, error)
	UpdateNebulaRestoreStatus(restore *v1alpha1.NebulaRestore, condition *v1alpha1.RestoreCondition, newStatus *RestoreUpdateStatus) error
}

func NewNebulaRestore

func NewNebulaRestore(cli client.Client) NebulaRestore

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, isReclaimEnabled bool) 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 RestoreUpdateStatus

type RestoreUpdateStatus struct {
	TimeStarted   *metav1.Time
	TimeCompleted *metav1.Time
	ClusterName   *string
	ConditionType v1alpha1.RestoreConditionType
	Partitions    map[string][]*nebula.HostAddr
	Checkpoints   map[string]map[string]string
}

type Secret

type Secret interface {
	GetSecret(namespace, secretName string) (*corev1.Secret, error)
}

func NewSecret

func NewSecret(kubecli client.Client) Secret

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