bus

Jul 29, 2024

Changes in this version

+ func ExecOneOffWatchSelectCb[T directive.ComparableValue](b Bus, dir directive.Directive, ...) (directive.Instance, directive.Reference, error)

Jun 3, 2024

Changes in this version

+ func ExecOneOffWatchLatestCb[T directive.ComparableValue](ctx context.Context, b Bus, dir directive.Directive, ...) error

Apr 4, 2024

Changes in this version

+ func ExecOneOffWithXfrm(ctx context.Context, bus Bus, dir directive.Directive, idleCb ExecIdleCallback, ...) (directive.Value, directive.AttachedValue, directive.Instance, ...)

+ func ExecOneOffWithXfrmTyped[T, R directive.ComparableValue](ctx context.Context, bus Bus, dir directive.Directive, idleCb ExecIdleCallback, ...) (R, directive.TypedAttachedValue[T], directive.Instance, directive.Reference, ...)

Mar 5, 2024

Changes in this version

+ func ExecOneOffWatchTransformEffect[T, E directive.ComparableValue](ctx context.Context, ...) (directive.Instance, directive.Reference, error)

+ func ExecWatchTransformEffect[T, E directive.ComparableValue](ctx context.Context, ...) (directive.Instance, directive.Reference, error)

Mar 4, 2024

Changes in this version

+ func ExecOneOffWatchEffect[T directive.ComparableValue](cb func(val directive.TypedAttachedValue[T]) func(), b Bus, ...) (directive.Instance, directive.Reference, error)

Feb 29, 2024

Changes in this version

+ func ExecOneOffTyped[T comparable](ctx context.Context, bus Bus, dir directive.Directive, idleCb ExecIdleCallback, ...) (directive.TypedAttachedValue[T], directive.Instance, directive.Reference, ...)

+ func ExecOneOffWithFilterTyped[T comparable](ctx context.Context, bus Bus, dir directive.Directive, idleCb ExecIdleCallback, ...) (directive.TypedAttachedValue[T], directive.Instance, directive.Reference, ...)

+ func NewOneOffRefCountResolver[T comparable](bus Bus, dir directive.Directive, idleCb ExecIdleCallback, ...) refcount.RefCountResolver[T]

+ func NewOneOffRefCount[T comparable](ctx context.Context, bus Bus, dir directive.Directive, idleCb ExecIdleCallback, ...) *refcount.RefCount[T]

Feb 27, 2024

Changes in this version

+ func ExecWatchEffect[T directive.ComparableValue](cb func(val directive.TypedAttachedValue[T]) func(), b Bus, ...) (directive.Instance, directive.Reference, error)

Feb 8, 2024

Changes in this version

+ func ExecOneOffWatchCb[T directive.ComparableValue](cb func(val directive.TypedAttachedValue[T]) bool, b Bus, ...) (directive.Instance, directive.Reference, error)

Aug 17, 2023

Changes in this version

+ func NewTransformHandler(passthru directive.ResolverHandler, ...) directive.ReferenceHandler

+ type TransformHandler struct

+ func (h *TransformHandler) HandleInstanceDisposed(di directive.Instance)

+ func (h *TransformHandler) HandleValueAdded(_ directive.Instance, v directive.AttachedValue)

+ func (h *TransformHandler) HandleValueRemoved(_ directive.Instance, v directive.AttachedValue)

May 31, 2023

Changes in this version

+ func ExecOneOffWatchCtr(ctr *ccontainer.CContainer[*directive.AttachedValue], b Bus, ...) (directive.Instance, directive.Reference, error)

May 13, 2023

Changes in this version

type ExecIdleCallback

+ func ReturnIfIdle(returnIfIdle bool) ExecIdleCallback

May 12, 2023

Changes in this version

+ type ExecIdleCallback func(errs []error) (bool, error)

+ func ReturnWhenIdle() ExecIdleCallback

+ func WaitWhenIdle(ignoreErrors bool) ExecIdleCallback

Jan 29, 2023

Changes in this version

type BusFactory

+ func NewBusFactory(b Bus, configID string, version semver.Version, newConfig func() T, ...) *BusFactory[T, C]

Jan 29, 2023

Changes in this version

+ func ExecOneOffWatchRoutine(b Bus, dir directive.Directive, cb func(ctx context.Context, value T) error) (*routine.RoutineContainer, directive.Reference, error)

Jan 4, 2023

Changes in this version

+ var ErrDirectiveDisposed = errors.New("directive disposed unexpectedly")

+ func ExecOneOffWatch(b Bus, dir directive.Directive) (*ccontainer.CContainer[*directive.AttachedValue], directive.Reference, error)

Dec 29, 2022

Changes in this version

+ func ExecOneOffWithFilter(ctx context.Context, bus Bus, dir directive.Directive, returnIfIdle bool, ...) (directive.AttachedValue, directive.Reference, error)

Oct 12, 2022

Changes in this version

type Bus

+ AddController func(ctx context.Context, ctrl controller.Controller, cb func(exitErr error)) (func(), error)

Oct 7, 2022

Changes in this version

+ type BusController struct

+ func NewBusController(le *logrus.Entry, b Bus, conf T, controllerID string, ...) *BusController[T]

+ func (c *BusController[T]) Close() error

+ func (c *BusController[T]) Execute(ctx context.Context) error

+ func (c *BusController[T]) GetBus() Bus

+ func (c *BusController[T]) GetConfig() T

+ func (c *BusController[T]) GetControllerInfo() *controller.Info

+ func (c *BusController[T]) GetLogger() *logrus.Entry

+ func (c *BusController[T]) HandleDirective(ctx context.Context, di directive.Instance) (directive.Resolver, error)

type BusFactory

+ func NewBusControllerFactory(b Bus, configID string, controllerID string, version semver.Version, ...) *BusFactory[T, C]

Oct 6, 2022

Changes in this version

+ func ExecWaitValue(ctx context.Context, b Bus, dir directive.Directive, ...) (T, directive.Reference, error)

+ type BusFactory struct

+ func NewFactory(b Bus, configID string, version semver.Version, newConfig func() T, ...) *BusFactory[T, C]

+ func (f *BusFactory[T, C]) Construct(cc config.Config, opts controller.ConstructOpts) (controller.Controller, error)

+ func (f *BusFactory[T, C]) ConstructConfig() config.Config

+ func (f *BusFactory[T, C]) GetConfigID() string

+ func (f *BusFactory[T, C]) GetVersion() semver.Version

Feb 22, 2022

Changes in this version

+ func ExecOneOffWatchCh(b Bus, dir directive.Directive) (<-chan directive.AttachedValue, directive.Reference, error)

Jun 4, 2021

Changes in this version

+ func ExecCollectValues(ctx context.Context, bus Bus, dir directive.Directive, ...) ([]directive.Value, directive.Reference, error)

+ func ExecOneOff(ctx context.Context, bus Bus, dir directive.Directive, ...) (directive.AttachedValue, directive.Reference, error)

+ func NewCallbackHandler(valCb func(directive.AttachedValue), removedCb func(directive.AttachedValue), ...) directive.ReferenceHandler

+ func NewPassThruHandler(passthru directive.ResolverHandler, disposeCb func()) directive.ReferenceHandler

+ type Bus interface

+ ExecuteController func(context.Context, controller.Controller) error

+ GetControllers func() []controller.Controller

+ RemoveController func(context.Context, controller.Controller) error

+ type CallbackHandler struct

+ func (h *CallbackHandler) HandleInstanceDisposed(directive.Instance)

+ func (h *CallbackHandler) HandleValueAdded(_ directive.Instance, v directive.AttachedValue)

+ func (h *CallbackHandler) HandleValueRemoved(_ directive.Instance, v directive.AttachedValue)

+ type PassThruHandler struct

+ func (h *PassThruHandler) HandleInstanceDisposed(di directive.Instance)

+ func (h *PassThruHandler) HandleValueAdded(_ directive.Instance, v directive.AttachedValue)

+ func (h *PassThruHandler) HandleValueRemoved(_ directive.Instance, v directive.AttachedValue)