component

type Component interface {
	service.LifeCycle

	Route(msg message.Message) (interface{}, error)
}

type Describe struct {
	Name         string
	RegisterFunc string
	Component    Component
	Started      bool
}

type Handler func(message.Message) (interface{}, error)

type Manager interface {
	RegisterComponentFunc(service *service.Service, fn NewComponentFunc) error
	RegisterComponent(s *service.Service, cpt Component) error
	ListComponents() []Describe
	NewComponent(s *service.Service, opts ...Option) (Component, error)
	GetComponent(*service.Service) (Component, error)
}

type Middleware func(Handler) Handler

type NewComponentFunc func(opts ...Option) (Component, error)

type Option func(*Options)

type Options struct {
	Logger logger.Logger
	Config config.Config
	Caller message.Caller
}