manager

Documentation

Index

• func New(outboxConfig config.OutboxConfig, kafkaConfig config.KafkaConfig, ...) (manager.Manager, error)
• type CommonManager
  • 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

Functions

func New

func New(outboxConfig config.OutboxConfig, kafkaConfig config.KafkaConfig, client *mongo.Client) (manager.Manager, error)

Types

type CommonManager

type CommonManager struct {
	// contains filtered or unexported fields
}

func (*CommonManager) Await

func (m *CommonManager) Await()

func (*CommonManager) GetEventHandler

func (m *CommonManager) GetEventHandler() event.EventHandler

func (*CommonManager) GetKafkaConfig

func (m *CommonManager) GetKafkaConfig() config.KafkaConfig

func (*CommonManager) GetKafkaProducer

func (m *CommonManager) GetKafkaProducer() *kafka.Producer

func (*CommonManager) GetMongoClient

func (m *CommonManager) GetMongoClient() *mongo.Client

func (*CommonManager) GetOutboxConfig

func (m *CommonManager) GetOutboxConfig() config.OutboxConfig

func (*CommonManager) SetEventHandler

func (m *CommonManager) SetEventHandler(e event.EventHandler)

func (*CommonManager) Start

func (m *CommonManager) Start() error