stores

Documentation

Index

• func NewEvent(e dom.Event) gocqrs.Event
• type EventoStore
  • func NewEventoStore(url string, proxy bool) *EventoStore
  • func (es EventoStore) Range(streamid string) (chan gocqrs.Eventer, uint64)
  • func (es EventoStore) Scan(streamid string, from, to uint64) chan gocqrs.Event
  • func (estore EventoStore) Store(e gocqrs.Eventer, opt gocqrs.StoreOptions) (uint64, error)
  • func (es EventoStore) Version(streamid string) (uint64, error)

Functions

func NewEvent

func NewEvent(e dom.Event) gocqrs.Event

Types

type EventoStore

type EventoStore struct {
	URL   string `json:"url"`
	Proxy bool   `json:"proxy"`
	// contains filtered or unexported fields
}

func NewEventoStore

func NewEventoStore(url string, proxy bool) *EventoStore

func (EventoStore) Range

func (es EventoStore) Range(streamid string) (chan gocqrs.Eventer, uint64)

func (EventoStore) Scan

func (es EventoStore) Scan(streamid string, from, to uint64) chan gocqrs.Event

func (EventoStore) Store

func (estore EventoStore) Store(e gocqrs.Eventer, opt gocqrs.StoreOptions) (uint64, error)

func (EventoStore) Version

func (es EventoStore) Version(streamid string) (uint64, error)