kube

Documentation

Index

• func CreateNamespace(ctx context.Context, kubeCli kubernetes.Interface, namespace string) error
• func FetchNonRunningPods(ctx context.Context, workloads []corev1.ObjectReference) ([]corev1.Pod, error)
• func GetK8sVersion() (string, error)
• func WaitForDeploymentConfigReady(ctx context.Context, osCli osversioned.Interface, kubeCli kubernetes.Interface, ...) error
• func WaitForDeploymentReady(ctx context.Context, kubeCli kubernetes.Interface, namespace string, ...) error
• func WaitForPodReady(ctx context.Context, kubeCli kubernetes.Interface, namespace string, ...) error
• func WaitForStatefulSetReady(ctx context.Context, kubeCli kubernetes.Interface, namespace string, ...) error
• type Client
  • func NewClient() (*Client, error)

Functions

func CreateNamespace

func CreateNamespace(ctx context.Context, kubeCli kubernetes.Interface, namespace string) error

CreateNamespace creates namespace

func FetchNonRunningPods

func FetchNonRunningPods(ctx context.Context, workloads []corev1.ObjectReference) ([]corev1.Pod, error)

FetchNonRunningPods returns list of non running Pods owned by the workloads

func GetK8sVersion

func GetK8sVersion() (string, error)

GetK8sVersion returns Kubernetes server version

func WaitForDeploymentConfigReady

func WaitForDeploymentConfigReady(ctx context.Context, osCli osversioned.Interface, kubeCli kubernetes.Interface, namespace string, name string) error

WaitForDeploymentConfigReady waits till the deployment config gets ready

func WaitForDeploymentReady

func WaitForDeploymentReady(ctx context.Context, kubeCli kubernetes.Interface, namespace string, name string) error

WaitForDeploymentReady waits till the deployment gets ready

func WaitForPodReady

func WaitForPodReady(ctx context.Context, kubeCli kubernetes.Interface, namespace string, name string) error

WaitForPodReady waits till the pod gets ready

func WaitForStatefulSetReady

func WaitForStatefulSetReady(ctx context.Context, kubeCli kubernetes.Interface, namespace string, name string) error

WaitForStatefulSetReady waits till the statefulset gets ready

Types

type Client

type Client struct {
	KubeCli      kubernetes.Interface
	OSCli        osversioned.Interface
	DiscoveryCli discovery.DiscoveryInterface
}

Client contains Kubernetes clients to call APIs

func NewClient

func NewClient() (*Client, error)

NewClient initializes and returns client object