kubernetes

Documentation

Index

• func Namespace() string
• type Kubernetes
  • func NewKubernetes(cfg config.StaticConfig) (d *Kubernetes, err error)
  • func (k *Kubernetes) DeployWorkers(ctx context.Context, info worker.Info) error
  • func (k *Kubernetes) RemoveWorkers(ctx context.Context, info worker.Info) error

Functions

func Namespace

func Namespace() string

https://stackoverflow.com/questions/53283347/how-to-get-current-namespace-of-an-in-cluster-go-kubernetes-client

Types

type Kubernetes

type Kubernetes struct {
	Client *kubernetes.Clientset
	// Namespace in which worker nodes are to be deployed.
	Namespace string
	Config    config.StaticConfig
}

func NewKubernetes

func NewKubernetes(cfg config.StaticConfig) (d *Kubernetes, err error)

func (*Kubernetes) DeployWorkers

func (k *Kubernetes) DeployWorkers(ctx context.Context, info worker.Info) error

func (*Kubernetes) RemoveWorkers

func (k *Kubernetes) RemoveWorkers(ctx context.Context, info worker.Info) error