ked

README

ked

👉 https://vizee.org/2022/05/03/kubernetes-go-client-ssa/

Documentation

Index

• Constants
• type AppTemplate
• type Event
• type Operator
  • func NewOperator(prefix string, kc *kube.Client) *Operator
  • func (op *Operator) DeployApp(ctx context.Context, app AppTemplate, replace bool, watcher *Watcher) error
  • func (op *Operator) RedeployAll(ctx context.Context, ns string, should func(*unstructured.Unstructured) bool, ...) error
  • func (op *Operator) RedeployApp(ctx context.Context, app AppTemplate, watcher *Watcher) error
• type Watcher
  • func NewWatcher(deployTimeout time.Duration, checkInterval time.Duration, recvEvent int) *Watcher
  • func (w *Watcher) Events() <-chan Event

Constants

const (
	StatePending = iota
	StateDeploying
	StateReplicasUpdated
	StateReplicasReady
	StateInterrupted
)

Types

type AppTemplate

type AppTemplate interface {
	GetNs() string
	GetDeploymentName() string
	GenerateObjects() ([]*unstructured.Unstructured, error)
}

type Event

type Event struct {
	State int
	Ns    string
	Name  string
	Err   error
	Done  bool
}

type Operator

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

func NewOperator

func NewOperator(prefix string, kc *kube.Client) *Operator

func (*Operator) DeployApp

func (op *Operator) DeployApp(ctx context.Context, app AppTemplate, replace bool, watcher *Watcher) error

func (*Operator) RedeployAll

func (op *Operator) RedeployAll(ctx context.Context, ns string, should func(*unstructured.Unstructured) bool, watcher *Watcher) error

func (*Operator) RedeployApp

func (op *Operator) RedeployApp(ctx context.Context, app AppTemplate, watcher *Watcher) error

type Watcher

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

func NewWatcher

func NewWatcher(deployTimeout time.Duration, checkInterval time.Duration, recvEvent int) *Watcher

func (*Watcher) Events

func (w *Watcher) Events() <-chan Event