messages

Documentation

Index

• type Consumer
• type Message
• type MockConsumer
  • func NewMockMessageConsumer(t mockConstructorTestingTNewMockMessageConsumer) *MockConsumer
  • func (_m *MockConsumer) Close() error
  • func (_m *MockConsumer) Consume() (<-chan Message, error)
• type Processor
  • func NewProcessor[Visitor any](messageConsumer Consumer, eventsDeserializer events.Deserializer[Visitor], ...) *Processor[Visitor]
  • func (p *Processor[Visitor]) Start() error

Types

type Consumer

type Consumer interface {
	Consume() (<-chan Message, error)
	Close() error
}

type Message

type Message struct {
	Payload []byte
}

type MockConsumer

type MockConsumer struct {
	mock.Mock
}

MockConsumer is an autogenerated mock type for the Consumer type

func NewMockMessageConsumer

func NewMockMessageConsumer(t mockConstructorTestingTNewMockMessageConsumer) *MockConsumer

NewMockMessageConsumer creates a new instance of MockConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockConsumer) Close

func (_m *MockConsumer) Close() error

Close provides a mock function with given fields:

func (*MockConsumer) Consume

func (_m *MockConsumer) Consume() (<-chan Message, error)

Consume provides a mock function with given fields:

type Processor

type Processor[Visitor any] struct {
	// contains filtered or unexported fields
}

func NewProcessor

func NewProcessor[Visitor any](
	messageConsumer Consumer,
	eventsDeserializer events.Deserializer[Visitor],
	eventsVisitor Visitor,
) *Processor[Visitor]

func (*Processor[Visitor]) Start

func (p *Processor[Visitor]) Start() error