k8sclient

Apr 25, 2022

Changes in this version

type K8sClient

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

Apr 1, 2022

Changes in this version

+ type PatchListValue struct

+ Op string

+ Path string

+ Value []string

+ type PatchMapValue struct

+ Op string

+ Path string

+ Value map[string]string

Feb 16, 2022

Changes in this version

type K8sClient

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

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

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

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

+ func (k *K8sClient) GetJob(jobName, namespace string) (*batchv1.Job, 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) UpdateJob(job *batchv1.Job) error

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

Aug 24, 2021

Changes in this version

+ var FakeClient = &FakeK8sClient

+ type FakeK8sClient struct

+ PodMap map[string]*corev1.Pod

+ func (f *FakeK8sClient) CreatePod(pod *corev1.Pod) (*corev1.Pod, error)

+ func (f *FakeK8sClient) DeletePod(pod *corev1.Pod) error

+ func (f *FakeK8sClient) Flush()

+ func (f *FakeK8sClient) GetPod(podName, namespace string) (*corev1.Pod, error)

+ func (f *FakeK8sClient) PatchPod(pod *corev1.Pod, data []byte) error

+ func (f *FakeK8sClient) UpdatePod(pod *corev1.Pod) error

+ type K8sClient interface

+ CreatePod func(pod *corev1.Pod) (*corev1.Pod, error)

+ DeletePod func(pod *corev1.Pod) error

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

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

+ UpdatePod func(pod *corev1.Pod) error

+ func NewClient() (K8sClient, error)