k8s

Documentation

Index

• func NewClientset(isInCluster bool) (kubernetes.Interface, error)
• type K8S
  • func New(logger *zap.Logger, clientset kubernetes.Interface) (K8S, error)

Functions

func NewClientset

func NewClientset(isInCluster bool) (kubernetes.Interface, error)

NewClientset create kubernetes clientset

Types

type K8S

type K8S interface {
	GetPod(name string, namespace string) (*v1.Pod, error)
	GetCurrentNamespace() string
	CreatePod(job *job.SchedulerJob, namespace string) (string, error)
	CreateNamespace(name string) error
	DeletePod(name string, namespace string) error
	WatchPod(name string, namespace string) error
}

K8S service interface, that should abstract all k8s sdk details away

func New

func New(logger *zap.Logger, clientset kubernetes.Interface) (K8S, error)

New instance of K8S concrete implementation