progress

Documentation

Index

• type Config
• type State
• type Tracker
  • func NewProgressTracker(client kubernetes.Interface, logger *zap.SugaredLogger, config Config) (*Tracker, error)
  • func (pt *Tracker) AddResource(kind WatchableResource, namespace, name string)
  • func (pt *Tracker) AddResourceWithInfo(kind WatchableResource, namespace, name string, info *resource.Info)
  • func (pt *Tracker) Watch(ctx context.Context, targetState State) error
• type WatchableResource
  • func NewWatchableResource(kind string) (WatchableResource, error)

Types

type Config

type Config struct {
	Interval time.Duration
	Timeout  time.Duration
}

type State

type State string

const (
	ReadyState      State = "ready"
	TerminatedState State = "terminated"
)

type Tracker

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

func NewProgressTracker

func NewProgressTracker(client kubernetes.Interface, logger *zap.SugaredLogger, config Config) (*Tracker, error)

func (*Tracker) AddResource

func (pt *Tracker) AddResource(kind WatchableResource, namespace, name string)

func (*Tracker) AddResourceWithInfo

func (pt *Tracker) AddResourceWithInfo(kind WatchableResource, namespace, name string, info *resource.Info)

func (*Tracker) Watch

func (pt *Tracker) Watch(ctx context.Context, targetState State) error

type WatchableResource

type WatchableResource string

const (
	Deployment               WatchableResource = "Deployment"
	Pod                      WatchableResource = "Pod"
	DaemonSet                WatchableResource = "DaemonSet"
	StatefulSet              WatchableResource = "StatefulSet"
	Job                      WatchableResource = "Job"
	CustomResourceDefinition WatchableResource = "CustomResourceDefinition"
)

func NewWatchableResource

func NewWatchableResource(kind string) (WatchableResource, error)