eventsource

Documentation

Index

• type EventSource
  • func New[T any](f InformerFactory, h Handlers[T]) *EventSource[T]
  • func (ig *EventSource[T]) OnAdd(obj interface{})
  • func (ig *EventSource[T]) OnDelete(obj interface{})
  • func (ig *EventSource[T]) OnUpdate(oldObj, newObj interface{})
• type Handlers
• type InformerFactory

Types

type EventSource

type EventSource[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](f InformerFactory, h Handlers[T]) *EventSource[T]

func (*EventSource[T]) OnAdd

func (ig *EventSource[T]) OnAdd(obj interface{})

func (*EventSource[T]) OnDelete

func (ig *EventSource[T]) OnDelete(obj interface{})

func (*EventSource[T]) OnUpdate

func (ig *EventSource[T]) OnUpdate(oldObj, newObj interface{})

type Handlers

type Handlers[T any] struct {
	AddFunc    func(obj *T)
	UpdateFunc func(oldObj, newObj *T)
	DeleteFunc func(obj *T)
}

type InformerFactory

type InformerFactory interface {
	Informer() cache.SharedIndexInformer
}