k8sclient

Documentation

Index

• type K8sClient
  • func NewClient() (*K8sClient, error)
  • func (k *K8sClient) CreateJob(job *batchv1.Job) (*batchv1.Job, error)
  • func (k *K8sClient) CreatePod(pod *corev1.Pod) (*corev1.Pod, error)
  • func (k *K8sClient) CreateSecret(secret *corev1.Secret) (*corev1.Secret, error)
  • func (k *K8sClient) DeleteJob(jobName string, namespace string) error
  • func (k *K8sClient) DeletePod(pod *corev1.Pod) error
  • func (k *K8sClient) DeleteSecret(secretName string, namespace string) error
  • func (k *K8sClient) GetJob(jobName, namespace string) (*batchv1.Job, error)
  • func (k *K8sClient) GetPersistentVolume(pvName string) (*corev1.PersistentVolume, error)
  • func (k *K8sClient) GetPod(podName, namespace string) (*corev1.Pod, error)
  • func (k *K8sClient) GetPodLog(podName, namespace, containerName string) (string, error)
  • func (k *K8sClient) GetSecret(secretName, namespace string) (*corev1.Secret, error)
  • func (k *K8sClient) ListPod(namespace string, labelSelector *metav1.LabelSelector, ...) ([]corev1.Pod, error)
  • func (k *K8sClient) PatchPod(pod *corev1.Pod, data []byte) error
  • func (k *K8sClient) UpdateJob(job *batchv1.Job) error
  • func (k *K8sClient) UpdatePod(pod *corev1.Pod) error
  • func (k *K8sClient) UpdateSecret(secret *corev1.Secret) error
• type PatchListValue
• type PatchMapValue

Types

type K8sClient

type K8sClient struct {
	kubernetes.Interface
}

func NewClient

func NewClient() (*K8sClient, error)

func (*K8sClient) CreateJob

func (k *K8sClient) CreateJob(job *batchv1.Job) (*batchv1.Job, error)

func (*K8sClient) CreatePod

func (k *K8sClient) CreatePod(pod *corev1.Pod) (*corev1.Pod, error)

func (*K8sClient) CreateSecret

func (k *K8sClient) CreateSecret(secret *corev1.Secret) (*corev1.Secret, error)

func (*K8sClient) DeleteJob

func (k *K8sClient) DeleteJob(jobName string, namespace string) error

func (*K8sClient) DeletePod

func (k *K8sClient) DeletePod(pod *corev1.Pod) error

func (*K8sClient) DeleteSecret

func (k *K8sClient) DeleteSecret(secretName string, namespace string) error

func (*K8sClient) GetJob

func (k *K8sClient) GetJob(jobName, namespace string) (*batchv1.Job, error)

func (*K8sClient) GetPersistentVolume

func (k *K8sClient) GetPersistentVolume(pvName string) (*corev1.PersistentVolume, error)

func (*K8sClient) GetPod

func (k *K8sClient) GetPod(podName, namespace string) (*corev1.Pod, error)

func (*K8sClient) GetPodLog

func (k *K8sClient) GetPodLog(podName, namespace, containerName string) (string, error)

func (*K8sClient) GetSecret

func (k *K8sClient) GetSecret(secretName, namespace string) (*corev1.Secret, error)

func (*K8sClient) ListPod

func (k *K8sClient) ListPod(namespace string, labelSelector *metav1.LabelSelector, filedSelector *fields.Set) ([]corev1.Pod, error)

func (*K8sClient) PatchPod

func (k *K8sClient) PatchPod(pod *corev1.Pod, data []byte) error

func (*K8sClient) UpdateJob

func (k *K8sClient) UpdateJob(job *batchv1.Job) error

func (*K8sClient) UpdatePod

func (k *K8sClient) UpdatePod(pod *corev1.Pod) error

func (*K8sClient) UpdateSecret

func (k *K8sClient) UpdateSecret(secret *corev1.Secret) error

type PatchListValue

type PatchListValue struct {
	Op    string   `json:"op"`
	Path  string   `json:"path"`
	Value []string `json:"value"`
}

type PatchMapValue

type PatchMapValue struct {
	Op    string            `json:"op"`
	Path  string            `json:"path"`
	Value map[string]string `json:"value"`
}