Documentation ¶
Overview ¶
Package container provides primitives for configuration and starting all primitives in the module
Index ¶
- Variables
- type Configuration
- type Container
- func (c *Container) Close() (err error)
- func (c *Container) Config() *Configuration
- func (c *Container) Connection() connection.Handler
- func (c *Container) ConnectionHandler() consumer.ConnectionHandler
- func (c *Container) Connector() connector.Handler
- func (c *Container) Consumer() consumer.Handler
- func (c *Container) Init(configFile string) (err error)
- func (c *Container) Worker() worker.Handler
- type Handler
Constants ¶
This section is empty.
Variables ¶
View Source
var WireSet = wire.NewSet(NewContainer, NewConfiguration, wire.Bind(new(Handler), new(*Container)), worker.WireSet, consumer.WireSet, connector.WireSet, connection.WireSet)
Functions ¶
This section is empty.
Types ¶
type Configuration ¶
type Configuration struct { ConnectionConfig *connection.Configuration WorkerConfig *worker.Configuration ConsumerConfig *consumer.Configuration ConnectorConfig *connector.Configuration ConfigFile string `json:"-"` // contains filtered or unexported fields }
func NewConfiguration ¶
func NewConfiguration(workerConfig *worker.Configuration, consumerConfig *consumer.Configuration, connectorConfig *connector.Configuration, connectionConfig *connection.Configuration) *Configuration
func (*Configuration) OnConfigModified ¶
func (c *Configuration) OnConfigModified()
type Container ¶
type Container struct { *Configuration // contains filtered or unexported fields }
func NewContainer ¶
func NewContainer(config *Configuration, connectionHandler connection.Handler, connectorHandler connector.Handler, workerHandler worker.Handler, consumerHandler consumer.Handler) *Container
func (*Container) Config ¶
func (c *Container) Config() *Configuration
func (*Container) Connection ¶
func (c *Container) Connection() connection.Handler
func (*Container) ConnectionHandler ¶
func (c *Container) ConnectionHandler() consumer.ConnectionHandler
Click to show internal directories.
Click to hide internal directories.