controller

Documentation

Index

• func IndexChan[T any, PT types.Object[T]](watcher types.WatchInterface[T, PT], indexer Indexer[PT]) chan string
• type Controller
  • func NewController[T any, PT types.Object[T]](root types.ObjectAPI[T, PT]) (*Controller[T, PT], error)
  • func NewEmptyController[T any, PT types.Object[T]](root types.ObjectAPI[T, PT]) *Controller[T, PT]
  • func (c *Controller[T, PT]) Run(action RunAction[T])
  • func (c *Controller[T, PT]) Watches(r chan string) *Controller[T, PT]
• type Indexer
  • func KeyFromLabel[T any, PT types.Object[T]](label string) Indexer[PT]
• type RunAction

Functions

func IndexChan

func IndexChan[T any, PT types.Object[T]](watcher types.WatchInterface[T, PT], indexer Indexer[PT]) chan string

Types

type Controller

type Controller[T any, PT types.Object[T]] struct {
	// contains filtered or unexported fields
}

func NewController

func NewController[T any, PT types.Object[T]](root types.ObjectAPI[T, PT]) (*Controller[T, PT], error)

func NewEmptyController

func NewEmptyController[T any, PT types.Object[T]](root types.ObjectAPI[T, PT]) *Controller[T, PT]

func (*Controller[T, PT]) Run

func (c *Controller[T, PT]) Run(action RunAction[T])

func (*Controller[T, PT]) Watches

func (c *Controller[T, PT]) Watches(r chan string) *Controller[T, PT]

type Indexer

type Indexer[T any] func(T) string

func KeyFromLabel

func KeyFromLabel[T any, PT types.Object[T]](label string) Indexer[PT]

type RunAction

type RunAction[T any] func(T) error