kubectl

Documentation

Overview

Package kubectl provides kubectl CLI wrapper.

Index

• type KubeCtl
  • func NewKubeCtl(ctx context.Context, kubeconfig string) (*KubeCtl, error)
  • func (k *KubeCtl) Apply(ctx context.Context, res meta.Object) error
  • func (k *KubeCtl) Cleanup() error
  • func (k *KubeCtl) Delete(ctx context.Context, res meta.Object) error
  • func (k *KubeCtl) Get(ctx context.Context, kind string, name string, res interface{}) error
  • func (k *KubeCtl) Run(ctx context.Context, args []string, stdin interface{}) ([]byte, error)

Types

type KubeCtl

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

KubeCtl wraps kubectl CLI with version selection and kubeconfig handling.

func NewKubeCtl

func NewKubeCtl(ctx context.Context, kubeconfig string) (*KubeCtl, error)

NewKubeCtl creates a new KubeCtl object with a given logger.

func (*KubeCtl) Apply

func (k *KubeCtl) Apply(ctx context.Context, res meta.Object) error

Apply executes `kubectl apply` with given resource.

func (*KubeCtl) Cleanup

func (k *KubeCtl) Cleanup() error

Cleanup removes temporary files created by that object.

func (*KubeCtl) Delete

func (k *KubeCtl) Delete(ctx context.Context, res meta.Object) error

Delete executes `kubectl delete` with given resource.

func (*KubeCtl) Get

func (k *KubeCtl) Get(ctx context.Context, kind string, name string, res interface{}) error

Get executes `kubectl get` with given object kind and optional name, and decodes resource into `res`.

func (*KubeCtl) Run

func (k *KubeCtl) Run(ctx context.Context, args []string, stdin interface{}) ([]byte, error)

Run wraps func run.