kubernetes

Documentation

Index

• type K8S
  • func Create() (*K8S, error)
  • func (k *K8S) CreatePod(namespace string, name string, image string, labels map[string]string) (*v1.Pod, error)
  • func (k *K8S) CreateService(namespace string, name string, typ string, ports []int32, ...) (*v1.Service, error)
  • func (k *K8S) DeletePod(namespace string, name string) error
  • func (k *K8S) DeleteService(namespace string, name string) error
  • func (k *K8S) Deploy(ctx context.Context, workdir string, name string, ports []int32) error
  • func (k *K8S) Destroy(ctx context.Context, name string) error
  • func (k *K8S) GetPod(namespace string, name string) (*v1.Pod, error)
  • func (k *K8S) GetStatus(ctx context.Context, name string) error
  • func (k *K8S) ListPods() (*v1.PodList, error)
  • func (k *K8S) Update(ctx context.Context, name string) error

Types

type K8S

type K8S struct {
	*kubernetes.Clientset
}

K8S client

func Create

func Create() (*K8S, error)

Create a k8s cluster client

func (*K8S) CreatePod

func (k *K8S) CreatePod(
	namespace string,
	name string,
	image string,
	labels map[string]string,
) (*v1.Pod, error)

CreatePod create a pod

func (*K8S) CreateService

func (k *K8S) CreateService(
	namespace string,
	name string,
	typ string,
	ports []int32,
	podsLabels map[string]string,
) (*v1.Service, error)

CreateService create a service

func (*K8S) DeletePod

func (k *K8S) DeletePod(namespace string, name string) error

DeletePod delete a pod

func (*K8S) DeleteService

func (k *K8S) DeleteService(namespace string, name string) error

DeleteService a service

func (*K8S) Deploy

func (k *K8S) Deploy(
	ctx context.Context,
	workdir string,
	name string,
	ports []int32,
) error

Deploy a image to be a service

func (*K8S) Destroy

func (k *K8S) Destroy(ctx context.Context, name string) error

Destroy a service

func (*K8S) GetPod

func (k *K8S) GetPod(namespace string, name string) (*v1.Pod, error)

GetPod get a pod

func (*K8S) GetStatus

func (k *K8S) GetStatus(ctx context.Context, name string) error

GetStatus get status of a service

func (*K8S) ListPods

func (k *K8S) ListPods() (*v1.PodList, error)

ListPods list pods

func (*K8S) Update

func (k *K8S) Update(ctx context.Context, name string) error

Update a service