k8sclient

Oct 21, 2024

Changes in this version

type K8sClient

+ func (k *K8sClient) GetEvents(ctx context.Context, pod *corev1.Pod) ([]corev1.Event, error)

Sep 30, 2024

Changes in this version

type K8sClient

+ func NewClientWithConfig(config *rest.Config) (*K8sClient, error)

+ func (k *K8sClient) CreateEvent(ctx context.Context, pod corev1.Pod, evtType, reason, message string) error

+ func (k *K8sClient) GetConfigMap(ctx context.Context, cmName, namespace string) (*corev1.ConfigMap, error)

Apr 16, 2024

Changes in this version

type K8sClient

+ func (k *K8sClient) ListPersistentVolumesByVolumeHandle(ctx context.Context, volumeHandle string) ([]corev1.PersistentVolume, error)

Nov 15, 2023

Changes in this version

type K8sClient

+ func (k *K8sClient) ListNode(ctx context.Context, labelSelector *metav1.LabelSelector) ([]corev1.Node, error)

+ func (k *K8sClient) ListStorageClasses(ctx context.Context) ([]storagev1.StorageClass, error)

Sep 7, 2023

Changes in this version

type K8sClient

+ func (k *K8sClient) PatchSecret(ctx context.Context, secret *corev1.Secret, data []byte, pt types.PatchType) error

Jul 13, 2023

Changes in this version

+ type KubeletClient struct

+ func NewKubeletClient(host string, port int) (*KubeletClient, error)

+ func (kc *KubeletClient) GetNodeRunningPods() (*corev1.PodList, error)

+ type KubeletClientConfig struct

+ Address string

+ BearerToken string

+ HTTPTimeout time.Duration

+ Port int

Jun 12, 2023

Changes in this version

type K8sClient

+ func (k *K8sClient) GetReplicaSet(ctx context.Context, rsName, namespace string) (*appsv1.ReplicaSet, error)

+ func (k *K8sClient) GetStatefulSet(ctx context.Context, stsName, namespace string) (*appsv1.StatefulSet, error)

Apr 7, 2023

Changes in this version

type K8sClient

+ func (k *K8sClient) GetDaemonSet(ctx context.Context, dsName, namespace string) (*appsv1.DaemonSet, error)

Feb 13, 2023

Changes in this version

type K8sClient

+ func (k *K8sClient) ExecuteInContainer(podName, namespace, containerName string, cmd []string) (stdout string, stderr string, err error)

+ func (k *K8sClient) GetPersistentVolumeClaim(ctx context.Context, pvcName, namespace string) (*corev1.PersistentVolumeClaim, error)

+ func (k *K8sClient) GetStorageClass(ctx context.Context, scName string) (*storagev1.StorageClass, error)

+ func (k *K8sClient) ListPersistentVolumes(ctx context.Context, labelSelector *metav1.LabelSelector, ...) ([]corev1.PersistentVolume, error)

Dec 23, 2022

Changes in this version

+ type PatchDelValue struct

+ Op string

+ Path string

+ type PatchStringValue struct

+ Op string

+ Path string

+ Value string

Nov 15, 2022

Changes in this version

+ type K8sClient struct

+ func NewClient() (*K8sClient, error)

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

+ func (k *K8sClient) CreatePod(ctx context.Context, pod *corev1.Pod) (*corev1.Pod, error)

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

+ func (k *K8sClient) DeleteJob(ctx context.Context, jobName string, namespace string) error

+ func (k *K8sClient) DeletePod(ctx context.Context, pod *corev1.Pod) error

+ func (k *K8sClient) DeleteSecret(ctx context.Context, secretName string, namespace string) error

+ func (k *K8sClient) GetJob(ctx context.Context, jobName, namespace string) (*batchv1.Job, error)

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

+ func (k *K8sClient) GetPod(ctx context.Context, podName, namespace string) (*corev1.Pod, error)

+ func (k *K8sClient) GetPodLog(ctx context.Context, podName, namespace, containerName string) (string, error)

+ func (k *K8sClient) GetSecret(ctx context.Context, secretName, namespace string) (*corev1.Secret, error)

+ func (k *K8sClient) ListPod(ctx context.Context, namespace string, labelSelector *metav1.LabelSelector, ...) ([]corev1.Pod, error)

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

+ func (k *K8sClient) UpdateJob(ctx context.Context, job *batchv1.Job) error

+ func (k *K8sClient) UpdatePod(ctx context.Context, pod *corev1.Pod) error

+ func (k *K8sClient) UpdateSecret(ctx context.Context, secret *corev1.Secret) error

+ type PatchListValue struct

+ Op string

+ Path string

+ Value []string

+ type PatchMapValue struct

+ Op string

+ Path string

+ Value map[string]string