store

Documentation

Index

• type EventStore
  • func NewEventStore(db *ledis.DB) EventStore
• type ServiceProvider
  • func (s ServiceProvider) Boot(app infra.Glacier)
  • func (s ServiceProvider) Register(app container.Container)

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 ServiceProvider

type ServiceProvider struct{}

func (ServiceProvider) Boot

func (s ServiceProvider) Boot(app infra.Glacier)

func (ServiceProvider) Register

func (s ServiceProvider) Register(app container.Container)