k8sclient

Documentation

Index

• type K8sClient
  • 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) ExecuteInContainer(podName, namespace, containerName string, cmd []string) (stdout string, stderr string, err error)
  • func (k *K8sClient) GetDaemonSet(ctx context.Context, dsName, namespace string) (*appsv1.DaemonSet, 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) GetPersistentVolumeClaim(ctx context.Context, pvcName, namespace string) (*corev1.PersistentVolumeClaim, 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) GetReplicaSet(ctx context.Context, rsName, namespace string) (*appsv1.ReplicaSet, error)
  • func (k *K8sClient) GetSecret(ctx context.Context, secretName, namespace string) (*corev1.Secret, error)
  • func (k *K8sClient) GetStatefulSet(ctx context.Context, stsName, namespace string) (*appsv1.StatefulSet, 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)
  • 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, pt types.PatchType) error
  • func (k *K8sClient) PatchSecret(ctx context.Context, secret *corev1.Secret, data []byte, pt types.PatchType) 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 KubeletClient
  • func NewKubeletClient(host string, port int) (*KubeletClient, error)
  • func (kc *KubeletClient) GetNodeRunningPods() (*corev1.PodList, error)
• type KubeletClientConfig
• type PatchDelValue
• type PatchListValue
• type PatchMapValue
• type PatchStringValue

Types

type K8sClient

type K8sClient struct {
	kubernetes.Interface
	// contains filtered or unexported fields
}

func NewClient

func NewClient() (*K8sClient, error)

func (*K8sClient) CreateJob

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

func (*K8sClient) CreatePod

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

func (*K8sClient) CreateSecret

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

func (*K8sClient) DeleteJob

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

func (*K8sClient) DeletePod

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

func (*K8sClient) DeleteSecret

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

func (*K8sClient) ExecuteInContainer

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

func (*K8sClient) GetDaemonSet

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

func (*K8sClient) GetJob

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

func (*K8sClient) GetPersistentVolume

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

func (*K8sClient) GetPersistentVolumeClaim

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

func (*K8sClient) GetPod

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

func (*K8sClient) GetPodLog

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

func (*K8sClient) GetReplicaSet

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

func (*K8sClient) GetSecret

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

func (*K8sClient) GetStatefulSet

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

func (*K8sClient) GetStorageClass

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

func (*K8sClient) ListPersistentVolumes

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

func (*K8sClient) ListPod

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

func (*K8sClient) PatchPod

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

func (*K8sClient) PatchSecret

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

func (*K8sClient) UpdateJob

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

func (*K8sClient) UpdatePod

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

func (*K8sClient) UpdateSecret

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

type KubeletClient

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

func NewKubeletClient

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

func (*KubeletClient) GetNodeRunningPods

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

type KubeletClientConfig

type KubeletClientConfig struct {
	// Address specifies the kubelet address
	Address string

	// Port specifies the default port - used if no information about Kubelet port can be found in Node.NodeStatus.DaemonEndpoints.
	Port int

	// TLSClientConfig contains settings to enable transport layer security
	restclient.TLSClientConfig

	// Server requires Bearer authentication
	BearerToken string

	// HTTPTimeout is used by the client to timeout http requests to Kubelet.
	HTTPTimeout time.Duration
}

KubeletClientConfig defines config parameters for the kubelet client

type PatchDelValue

type PatchDelValue struct {
	Op   string `json:"op"`
	Path string `json:"path"`
}

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"`
}

type PatchStringValue

type PatchStringValue struct {
	Op    string `json:"op"`
	Path  string `json:"path"`
	Value string `json:"value"`
}