orievent

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 11, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL