runtimeevent

Documentation

Index

• type Generator
  • func NewGenerator(getResources func(ctx context.Context) (*iri.RuntimeResources, error), ...) Generator
• type GeneratorOptions
• type Handler
• type HandlerFuncs
  • func (f HandlerFuncs) UpdateResources(event *UpdateResourcesEvent)
• type HandlerRegistration
• type Source
• type UpdateResourcesEvent

Types

type Generator

type Generator interface {
	Source
	healthz.HealthChecker
	manager.Runnable
}

func NewGenerator

func NewGenerator(getResources func(ctx context.Context) (*iri.RuntimeResources, error), opts GeneratorOptions) Generator

type GeneratorOptions

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

type Handler

type Handler interface {
	UpdateResources(event *UpdateResourcesEvent)
}

type HandlerFuncs

type HandlerFuncs struct {
	UpdateResourcesFunc func(event *UpdateResourcesEvent)
}

func (HandlerFuncs) UpdateResources

func (f HandlerFuncs) UpdateResources(event *UpdateResourcesEvent)

type HandlerRegistration

type HandlerRegistration interface {
	Remove() error
}

type Source

type Source interface {
	AddHandler(handler Handler) (HandlerRegistration, error)
}

type UpdateResourcesEvent

type UpdateResourcesEvent struct {
	ResourcesOld *iri.RuntimeResources
	ResourcesNew *iri.RuntimeResources
}