kafkamock

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()

Functions

func New

func New() repository.Kafka

Types

type Impl

type Impl struct {
	Callback repository.ReceiverCallback

	Recording []repository.UpdateEvent
}

func (*Impl) IsKafka

func (r *Impl) IsKafka() bool

func (*Impl) Receive

func (r *Impl) Receive(incomingEvent repository.UpdateEvent)

func (*Impl) Reset

func (r *Impl) Reset()

func (*Impl) Send

func (r *Impl) Send(_ context.Context, event repository.UpdateEvent) error

func (*Impl) Setup

func (r *Impl) Setup() error

func (*Impl) StartReceiveLoop

func (r *Impl) StartReceiveLoop(ctx context.Context) error

func (*Impl) SubscribeIncoming

func (r *Impl) SubscribeIncoming(_ context.Context, callback repository.ReceiverCallback) error

func (*Impl) Teardown

func (r *Impl) Teardown()