consumer

Documentation

Index

• type Dispatcher
• type EventbusConsumer
  • func NewEventbusConsumer(q string, servicer types.QueueEventBuilder) *EventbusConsumer
  • func (cq *EventbusConsumer) Write(ctx context.Context, p []byte) error
• type StoreConsumer
  • func NewStoreConsumer(q string, s types.QueueServicer) *StoreConsumer
  • func (cq *StoreConsumer) GetStore() types.QueueStorer
  • func (cq *StoreConsumer) SetStore(s types.QueueStorer)
  • func (cq *StoreConsumer) Write(ctx context.Context, p []byte) error

Types

type Dispatcher

type Dispatcher interface {
	Dispatch(ctx context.Context, ev eventbus.Event)
	WaitFor(ctx context.Context, ev eventbus.Event) (err error)
}

type EventbusConsumer

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

func NewEventbusConsumer

func NewEventbusConsumer(q string, servicer types.QueueEventBuilder) *EventbusConsumer

func (*EventbusConsumer) Write

func (cq *EventbusConsumer) Write(ctx context.Context, p []byte) error

type StoreConsumer

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

func NewStoreConsumer

func NewStoreConsumer(q string, s types.QueueServicer) *StoreConsumer

func (*StoreConsumer) GetStore

func (cq *StoreConsumer) GetStore() types.QueueStorer

func (*StoreConsumer) SetStore

func (cq *StoreConsumer) SetStore(s types.QueueStorer)

func (*StoreConsumer) Write

func (cq *StoreConsumer) Write(ctx context.Context, p []byte) error