client

Documentation

Index

• type K8sClient
  • func NewK8sClient() (*K8sClient, error)
  • func (c *K8sClient) Kube() kubernetes.Interface
  • func (w *K8sClient) ListPods(namespace, selector string) (*v1.PodList, error)
  • func (w *K8sClient) OcApplyWorkspace(filePath string) (err error)
  • func (w *K8sClient) WaitForMutatingWebhooksConfigurations(name string) (deployed bool, err error)
  • func (w *K8sClient) WaitForPodRunningByLabel(label string) (deployed bool, err error)
  • func (w *K8sClient) WaitForRunningPodBySelector(namespace, selector string, timeout time.Duration) error

Types

type K8sClient

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

func NewK8sClient

func NewK8sClient() (*K8sClient, error)

NewK8sClient creates kubernetes client wrapper with helper functions and direct access to k8s go client

func (*K8sClient) Kube

func (c *K8sClient) Kube() kubernetes.Interface

Kube returns the clientset for Kubernetes upstream.

func (*K8sClient) ListPods

func (w *K8sClient) ListPods(namespace, selector string) (*v1.PodList, error)

Returns the list of currently scheduled or running pods in `namespace` with the given selector

func (*K8sClient) OcApplyWorkspace

func (w *K8sClient) OcApplyWorkspace(filePath string) (err error)

func (*K8sClient) WaitForMutatingWebhooksConfigurations

func (w *K8sClient) WaitForMutatingWebhooksConfigurations(name string) (deployed bool, err error)

func (*K8sClient) WaitForPodRunningByLabel

func (w *K8sClient) WaitForPodRunningByLabel(label string) (deployed bool, err error)

func (*K8sClient) WaitForRunningPodBySelector

func (w *K8sClient) WaitForRunningPodBySelector(namespace, selector string, timeout time.Duration) error

Wait up to timeout seconds for all pods in 'namespace' with given 'selector' to enter running state. Returns an error if no pods are found or not all discovered pods enter running state.