Versions in this module Expand all Collapse all v1 v1.0.0 Dec 18, 2020 Changes in this version + func New(outboxConfig config.OutboxConfig, kafkaConfig config.KafkaConfig, ...) (manager.Manager, error) + type CommonManager struct + func (m *CommonManager) Await() + func (m *CommonManager) GetEventHandler() event.EventHandler + func (m *CommonManager) GetKafkaConfig() config.KafkaConfig + func (m *CommonManager) GetKafkaProducer() *kafka.Producer + func (m *CommonManager) GetMongoClient() *mongo.Client + func (m *CommonManager) GetOutboxConfig() config.OutboxConfig + func (m *CommonManager) SetEventHandler(e event.EventHandler) + func (m *CommonManager) Start() error
Go to main page