k8s

Documentation

Index

• func Status(ctx context.Context, storage storage.IStep, dynamicClient dynamic.Interface, ...) error
• type IResource
  • func ResourceFor(ctx context.Context, storage storage.IStep, client *kubernetes.Clientset, ...) IResource
• type SKubectl
  • func New(storage storage.IStep, command, workspace string) (*SKubectl, error)
  • func (k *SKubectl) Clear() error
  • func (k *SKubectl) Run(ctx context.Context) (exit int64, err error)

Functions

func Status

func Status(ctx context.Context, storage storage.IStep, dynamicClient dynamic.Interface, resource *types.SResource) error

Status StatusViewerFor returns a StatusViewer for the resource specified by kind. https://github.com/kubernetes/kubectl/blob/master/pkg/polymorphichelpers/rollout_status.go

Types

type IResource

type IResource interface {
	Scale(replicas int32) error
	Update() error
	Println() error
	Restart() error
}

func ResourceFor

func ResourceFor(ctx context.Context, storage storage.IStep, client *kubernetes.Clientset, resource *types.SResource) IResource

type SKubectl

type SKubectl struct {
	Config              string             `json:"kube_config"`
	Namespace           string             `json:"namespace"`
	ImageTag            string             `json:"image_tag"`
	IgnoreInitContainer *bool              `json:"ignoreInitContainer"`
	Resources           []*types.SResource `json:"resources"`
	// contains filtered or unexported fields
}

func New

func New(storage storage.IStep, command, workspace string) (*SKubectl, error)

func (*SKubectl) Clear

func (k *SKubectl) Clear() error

func (*SKubectl) Run

func (k *SKubectl) Run(ctx context.Context) (exit int64, err error)