controller_k8s

Documentation

Index

• type ControllerK8s
  • func NewControllerK8s(ctx context.Context, kcs *kubernetes.Clientset, dc dynamic.Interface) (*ControllerK8s, error)
  • func (r *ControllerK8s) ApplyService(namespace string, service *v1.ServiceApplyConfiguration) (*corev1.Service, error)
  • func (r *ControllerK8s) ApplyYaml(bt []byte) error
  • func (r *ControllerK8s) CreateDeployment(namespace string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)
  • func (r *ControllerK8s) CreateObject(res schema.GroupVersionResource, namespace string, ...) (*unstructured.Unstructured, error)
  • func (r *ControllerK8s) DeleteDeployment(namespace, deploymentName string) error
  • func (r *ControllerK8s) DeleteObject(res schema.GroupVersionResource, name, namespace string, ...) error
  • func (r *ControllerK8s) DeleteService(serviceName, namespace string) error
  • func (r *ControllerK8s) DeleteYaml(bt []byte) error
  • func (r *ControllerK8s) GetDeployment(namespace, deploymentName string) (*appsv1.Deployment, error)
  • func (r *ControllerK8s) GetPod(namespace, pod string) (*corev1.Pod, error)
  • func (r *ControllerK8s) GetPods(namespace string) (*corev1.PodList, error)
  • func (r *ControllerK8s) GetService(namespace, serviceName string) (*corev1.Service, error)
  • func (r *ControllerK8s) UpdateDeployment(namespace string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)
  • func (r *ControllerK8s) UpdateObject(res schema.GroupVersionResource, namespace string, ...) (*unstructured.Unstructured, error)

Types

type ControllerK8s

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

func NewControllerK8s

func NewControllerK8s(ctx context.Context, kcs *kubernetes.Clientset, dc dynamic.Interface) (*ControllerK8s, error)

func (*ControllerK8s) ApplyService

func (r *ControllerK8s) ApplyService(namespace string, service *v1.ServiceApplyConfiguration) (*corev1.Service, error)

func (*ControllerK8s) ApplyYaml

func (r *ControllerK8s) ApplyYaml(bt []byte) error

Yaml

func (*ControllerK8s) CreateDeployment

func (r *ControllerK8s) CreateDeployment(namespace string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

func (*ControllerK8s) CreateObject

func (r *ControllerK8s) CreateObject(res schema.GroupVersionResource, namespace string, obj *unstructured.Unstructured) (*unstructured.Unstructured, error)

Object

func (*ControllerK8s) DeleteDeployment

func (r *ControllerK8s) DeleteDeployment(namespace, deploymentName string) error

func (*ControllerK8s) DeleteObject

func (r *ControllerK8s) DeleteObject(res schema.GroupVersionResource, name, namespace string, obj *unstructured.Unstructured) error

func (*ControllerK8s) DeleteService

func (r *ControllerK8s) DeleteService(serviceName, namespace string) error

func (*ControllerK8s) DeleteYaml

func (r *ControllerK8s) DeleteYaml(bt []byte) error

func (*ControllerK8s) GetDeployment

func (r *ControllerK8s) GetDeployment(namespace, deploymentName string) (*appsv1.Deployment, error)

Deployment

func (*ControllerK8s) GetPod

func (r *ControllerK8s) GetPod(namespace, pod string) (*corev1.Pod, error)

func (*ControllerK8s) GetPods

func (r *ControllerK8s) GetPods(namespace string) (*corev1.PodList, error)

Pod

func (*ControllerK8s) GetService

func (r *ControllerK8s) GetService(namespace, serviceName string) (*corev1.Service, error)

Service

func (*ControllerK8s) UpdateDeployment

func (r *ControllerK8s) UpdateDeployment(namespace string, deployment *appsv1.Deployment) (*appsv1.Deployment, error)

func (*ControllerK8s) UpdateObject

func (r *ControllerK8s) UpdateObject(res schema.GroupVersionResource, namespace string, obj *unstructured.Unstructured) (*unstructured.Unstructured, error)