watcher

Documentation

Index

• Variables
• type Watcher
  • func New[T client.Object](client client.WithWatch) *Watcher[T]
  • func (w *Watcher[T]) ByName(ctx context.Context, namespace, name string, cb func(obj T) (bool, error)) (def T, _ error)
  • func (w *Watcher[T]) ByObject(ctx context.Context, obj T, cb func(obj T) (bool, error)) (def T, _ error)
  • func (w *Watcher[T]) BySelector(ctx context.Context, namespace string, selector labels.Selector, ...) (def T, _ error)

Variables

var (
	WatchTimeoutSeconds int64 = 120
)

Types

type Watcher

type Watcher[T client.Object] struct {
	// contains filtered or unexported fields
}

func New

func New[T client.Object](client client.WithWatch) *Watcher[T]

func (*Watcher[T]) ByName

func (w *Watcher[T]) ByName(ctx context.Context, namespace, name string, cb func(obj T) (bool, error)) (def T, _ error)

func (*Watcher[T]) ByObject

func (w *Watcher[T]) ByObject(ctx context.Context, obj T, cb func(obj T) (bool, error)) (def T, _ error)

func (*Watcher[T]) BySelector

func (w *Watcher[T]) BySelector(ctx context.Context, namespace string, selector labels.Selector, cb func(obj T) (bool, error)) (def T, _ error)