Documentation
¶
Index ¶
- func NewEventHandler(queue workqueue.Interface, log logr.Logger) cache.ResourceEventHandler
- type Controller
- type EventHandler
- type Feature
- type Features
- type Item
- type Sink
- func (s *Sink) Delete(ctx context.Context, key string) error
- func (s *Sink) DeleteCh() <-chan interface{}
- func (s *Sink) Error(ctx context.Context, err error) error
- func (s *Sink) ErrorCh() <-chan error
- func (s *Sink) Upsert(ctx context.Context, item *Item) error
- func (s *Sink) UpsertCh() <-chan interface{}
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewEventHandler ¶
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController( informer cache.SharedIndexInformer, log logr.Logger, ) *Controller
func (*Controller) Announce ¶
func (c *Controller) Announce(obj interface{}) error
type EventHandler ¶
type EventHandler struct {
// contains filtered or unexported fields
}
func (*EventHandler) OnAdd ¶
func (e *EventHandler) OnAdd(obj interface{}, _ bool)
func (*EventHandler) OnDelete ¶
func (e *EventHandler) OnDelete(obj interface{})
func (*EventHandler) OnUpdate ¶
func (e *EventHandler) OnUpdate(_, newObj interface{})
type Feature ¶
type Feature func(*Features)
func WithNoDelete ¶
func WithNoDelete() Feature
func WithNoWarumup ¶
func WithNoWarumup() Feature
func WithOnDelete ¶
func WithOnDelete(fn com.ProcessBulk[any]) Feature
func WithOnUpsert ¶
func WithOnUpsert(fn com.ProcessBulk[any]) Feature
type Features ¶
type Features struct {
// contains filtered or unexported fields
}
func NewFeatures ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.