workload

Documentation

Index

• Constants
• func FromAny(obj any) (k8sapi.Workload, bool)
• func RpcKind(s k8sapi.Kind) manager.WorkloadInfo_Kind
• func StartDeployments(ctx context.Context, ns string) cache.SharedIndexInformer
• func StartReplicaSets(ctx context.Context, ns string) cache.SharedIndexInformer
• func StartRollouts(ctx context.Context, ns string) cache.SharedIndexInformer
• func StartStatefulSets(ctx context.Context, ns string) cache.SharedIndexInformer
• type Event
• type EventType
  • func (e EventType) String() string
• type State
  • func GetWorkloadState(wl k8sapi.Workload) State
  • func StateFromRPC(s manager.WorkloadInfo_State) State
  • func (ws State) String() string
• type Watcher
  • func NewWatcher(ctx context.Context, ns string, enabledWorkloadKinds k8sapi.Kinds) (Watcher, error)

Constants

const (
	EventTypeAdd = iota
	EventTypeUpdate
	EventTypeDelete
)

Functions

func FromAny

func FromAny(obj any) (k8sapi.Workload, bool)

func RpcKind

func RpcKind(s k8sapi.Kind) manager.WorkloadInfo_Kind

func StartDeployments

func StartDeployments(ctx context.Context, ns string) cache.SharedIndexInformer

func StartReplicaSets

func StartReplicaSets(ctx context.Context, ns string) cache.SharedIndexInformer

func StartRollouts

func StartRollouts(ctx context.Context, ns string) cache.SharedIndexInformer

func StartStatefulSets

func StartStatefulSets(ctx context.Context, ns string) cache.SharedIndexInformer

Types

type Event

type Event struct {
	Type     EventType
	Workload k8sapi.Workload
}

type EventType

type EventType int

func (EventType) String

func (e EventType) String() string

type State

type State int

const (
	StateUnknown State = iota
	StateProgressing
	StateAvailable
	StateFailure
)

func GetWorkloadState

func GetWorkloadState(wl k8sapi.Workload) State

func StateFromRPC

func StateFromRPC(s manager.WorkloadInfo_State) State

func (State) String

func (ws State) String() string

type Watcher

type Watcher interface {
	Subscribe(ctx context.Context) <-chan []Event
}

func NewWatcher

func NewWatcher(ctx context.Context, ns string, enabledWorkloadKinds k8sapi.Kinds) (Watcher, error)