core

Documentation

Index

• func NewCoreBus(ctx context.Context, le *logrus.Entry, opts ...Option) (bus.Bus, *static.Resolver, error)
• type CoreBusConfig
• type FactoryResolverCtor
• type Option
  • func WithControllerFactories(factories ...controller.Factory) Option
  • func WithFactoryResolverCtor(ctor FactoryResolverCtor) Option

Functions

func NewCoreBus

func NewCoreBus(
	ctx context.Context,
	le *logrus.Entry,
	opts ...Option,
) (bus.Bus, *static.Resolver, error)

NewCoreBus constructs a standard in-memory bus stack.

Types

type CoreBusConfig

type CoreBusConfig struct {
	// FactoryResolver overrides the static resolver.
	FactoryResolverCtor FactoryResolverCtor
	// BuiltInFactories is the list of built in controller factories.
	BuiltInFactories []controller.Factory
}

CoreBusConfig configures NewCoreBus.

type FactoryResolverCtor

type FactoryResolverCtor func(b bus.Bus, sr *static.Resolver) (controller.FactoryResolver, error)

FactoryResolverCtor constructs a Factory resolver.

type Option

type Option func(c *CoreBusConfig) error

Option is a core config option.

func WithControllerFactories

func WithControllerFactories(factories ...controller.Factory) Option

WithControllerFactories adds built-in factories.

func WithFactoryResolverCtor

func WithFactoryResolverCtor(ctor FactoryResolverCtor) Option

WithFactoryResolverCtor sets the Factory resolver constructor.