Documentation ¶
Index ¶
- func New() repository.Kafka
- type Impl
- func (r *Impl) IsKafka() bool
- func (r *Impl) Receive(incomingEvent repository.UpdateEvent)
- func (r *Impl) Reset()
- func (r *Impl) Send(_ context.Context, event repository.UpdateEvent) error
- func (r *Impl) Setup() error
- func (r *Impl) StartReceiveLoop(ctx context.Context) error
- func (r *Impl) SubscribeIncoming(_ context.Context, callback repository.ReceiverCallback) error
- func (r *Impl) Teardown()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New() repository.Kafka
Types ¶
type Impl ¶
type Impl struct { Callback repository.ReceiverCallback Recording []repository.UpdateEvent }
func (*Impl) Receive ¶
func (r *Impl) Receive(incomingEvent repository.UpdateEvent)
func (*Impl) Send ¶
func (r *Impl) Send(_ context.Context, event repository.UpdateEvent) error
func (*Impl) SubscribeIncoming ¶
func (r *Impl) SubscribeIncoming(_ context.Context, callback repository.ReceiverCallback) error
Click to show internal directories.
Click to hide internal directories.