Versions in this module Expand all Collapse all v0 v0.0.2 Sep 16, 2023 v0.0.1 Sep 7, 2023 Changes in this version + type Consumer interface + Close func() error + Consume func() (<-chan Message, error) + type Message struct + Payload []byte + type MockConsumer struct + func NewMockMessageConsumer(t mockConstructorTestingTNewMockMessageConsumer) *MockConsumer + func (_m *MockConsumer) Close() error + func (_m *MockConsumer) Consume() (<-chan Message, error) + type Processor struct + func NewProcessor(messageConsumer Consumer, eventsDeserializer events.Deserializer[Visitor], ...) *Processor[Visitor] + func (p *Processor[Visitor]) Start() error
Go to main page