orievent

Documentation

Index

• type CreateEvent
• type DeleteEvent
• type Generator
  • func NewGenerator[O orimeta.Object](list func(ctx context.Context) ([]O, error), opts GeneratorOptions) Generator[O]
• type GeneratorOptions
• type GenericEvent
• type Handler
• type HandlerFuncs
  • func (e HandlerFuncs[O]) Create(event CreateEvent[O])
  • func (e HandlerFuncs[O]) Delete(event DeleteEvent[O])
  • func (e HandlerFuncs[O]) Generic(event GenericEvent[O])
  • func (e HandlerFuncs[O]) Update(event UpdateEvent[O])
• type HandlerRegistration
• type Source
• type UpdateEvent

Types

type CreateEvent

type CreateEvent[O orimeta.Object] struct {
	Object O
}

type DeleteEvent

type DeleteEvent[O orimeta.Object] struct {
	Object O
}

type Generator

type Generator[O orimeta.Object] interface {
	Source[O]
	healthz.HealthChecker
	manager.Runnable
}

func NewGenerator

func NewGenerator[O orimeta.Object](list func(ctx context.Context) ([]O, error), opts GeneratorOptions) Generator[O]

type GeneratorOptions

type GeneratorOptions struct {
	ChannelCapacity int
	RelistPeriod    time.Duration
	RelistThreshold time.Duration
}

type GenericEvent

type GenericEvent[O orimeta.Object] struct {
	Object O
}

type Handler

type Handler[O orimeta.Object] interface {
	Create(event CreateEvent[O])
	Update(event UpdateEvent[O])
	Delete(event DeleteEvent[O])
	Generic(event GenericEvent[O])
}

type HandlerFuncs

type HandlerFuncs[O orimeta.Object] struct {
	CreateFunc  func(event CreateEvent[O])
	UpdateFunc  func(event UpdateEvent[O])
	DeleteFunc  func(event DeleteEvent[O])
	GenericFunc func(event GenericEvent[O])
}

func (HandlerFuncs[O]) Create

func (e HandlerFuncs[O]) Create(event CreateEvent[O])

func (HandlerFuncs[O]) Delete

func (e HandlerFuncs[O]) Delete(event DeleteEvent[O])

func (HandlerFuncs[O]) Generic

func (e HandlerFuncs[O]) Generic(event GenericEvent[O])

func (HandlerFuncs[O]) Update

func (e HandlerFuncs[O]) Update(event UpdateEvent[O])

type HandlerRegistration

type HandlerRegistration interface {
	Remove() error
}

type Source

type Source[O orimeta.Object] interface {
	AddHandler(handler Handler[O]) (HandlerRegistration, error)
}

type UpdateEvent

type UpdateEvent[O orimeta.Object] struct {
	ObjectOld O
	ObjectNew O
}