instance

type Instance ¶

type Instance struct {
	// contains filtered or unexported fields
}

Instance is the per-named-component loop handler.

func New(opts Options) *Instance

func (i *Instance) Handle(ctx context.Context, e loops.EventInstance) error

func (i *Instance) Loop() loop.Interface[loops.EventInstance]

type Manager ¶

type Manager interface {
	Init(ctx context.Context, comp compapi.Component) error
	Close(comp compapi.Component) error
}

Manager performs Init/Close on a single named component. Per-category sub-processors (binding, pubsub, state, secret, ...) satisfy this interface.

type Options ¶

type Options struct {
	Manager   Manager
	CompStore *compstore.ComponentStore
	Reporter  registry.Reporter
	Security  security.Handler
	// AlsoStartInput is set when Init for this category should also start the
	// input pipe (bindings: true when readingBindings is set when Init runs).
	AlsoStartInput bool
}

type PostInit ¶

type PostInit interface {
	StartInput(ctx context.Context, comp compapi.Component) error
	StopInput(comp compapi.Component)
}

PostInit is an optional capability for managers that need to run additional per-instance work after Init succeeds (e.g. bindings starting their input pipe when the category is reading). The Instance dispatches StartInput / StopInput events to managers implementing this interface.