store

Documentation

Index

• type EventStore
  • func NewEventStore(client *redis.Client, queueName string, logger log.Logger) *EventStore
  • func (rs *EventStore) Listen(evtType string, listener interface{})
  • func (rs *EventStore) Publish(evt event.Event) error
  • func (rs *EventStore) Register(typ interface{})
  • func (rs *EventStore) SetManager(manager event.Manager)
  • func (rs *EventStore) Start(ctx context.Context) <-chan interface{}

Types

type EventStore

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

func NewEventStore

func NewEventStore(client *redis.Client, queueName string, logger log.Logger) *EventStore

func (*EventStore) Listen

func (rs *EventStore) Listen(evtType string, listener interface{})

func (*EventStore) Publish

func (rs *EventStore) Publish(evt event.Event) error

func (*EventStore) Register

func (rs *EventStore) Register(typ interface{})

func (*EventStore) SetManager

func (rs *EventStore) SetManager(manager event.Manager)

func (*EventStore) Start

func (rs *EventStore) Start(ctx context.Context) <-chan interface{}