Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClientSet ¶
type ClientSet interface { ConfigMap() ConfigMap PV() PersistentVolume PVC() PersistentVolumeClaim Pod() Pod Endpoint() Endpoint Service() Service Ingress() Ingress Workload() Workload NebulaCluster() NebulaCluster }
type ConfigMap ¶
type ConfigMap interface { CreateOrUpdateConfigMap(cm *corev1.ConfigMap) error GetConfigMap(namespace, cmName string) (*corev1.ConfigMap, error) DeleteConfigMap(namespace, cmName string) error }
func NewConfigMap ¶
type Endpoint ¶
func NewEndpointClient ¶
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) UpdateNebulaCluster ¶ added in v0.9.0
func (f *FakeNebulaCluster) UpdateNebulaCluster(nc *v1alpha1.NebulaCluster) error
func (*FakeNebulaCluster) UpdateNebulaClusterStatus ¶
func (f *FakeNebulaCluster) UpdateNebulaClusterStatus(nc *v1alpha1.NebulaCluster) error
type Ingress ¶ added in v0.9.0
type Ingress interface { CreateOrUpdateIngress(ingress *networkingv1.Ingress) error GetIngress(namespace, ingressName string) (*networkingv1.Ingress, error) DeleteIngress(namespace, ingressName string) error }
func NewIngress ¶ added in v0.9.0
type NebulaCluster ¶
type NebulaCluster interface { GetNebulaCluster(namespace, name string) (*v1alpha1.NebulaCluster, error) UpdateNebulaCluster(nc *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, 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 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 ¶
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 ¶
Click to show internal directories.
Click to hide internal directories.