store

Documentation

Index

• type EventStore
  • func NewEventStore(db *ledis.DB) EventStore
• type Provider
  • func (s Provider) Boot(app infra.Resolver)
  • func (s Provider) Register(app infra.Binder)

Types

type EventStore

type EventStore interface {
	Enqueue(msg *protocol.MessageRequest) error
	Dequeue() (*protocol.MessageRequest, error)
}

func NewEventStore

func NewEventStore(db *ledis.DB) EventStore

NewEventStore create a new eventStore

type Provider

type Provider struct{}

func (Provider) Boot

func (s Provider) Boot(app infra.Resolver)

func (Provider) Register

func (s Provider) Register(app infra.Binder)