eventstore

Documentation

Index

• type EventStore
  • func Init() (es EventStore, err error)
  • func (es EventStore) Store(streamName string, ctx context.Context, events ...store.Event) (position uint64, err error)
  • func (es EventStore) Stream(streamName string, from store.StreamPosition, ctx context.Context) (out <-chan store.Event, err error)

Types

type EventStore

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

EventStore Adding an arbitrary 1 all revisions so revision 0 is reserved for the null condition.

func Init

func Init() (es EventStore, err error)

func (EventStore) Store

func (es EventStore) Store(streamName string, ctx context.Context, events ...store.Event) (position uint64, err error)

func (EventStore) Stream

func (es EventStore) Stream(streamName string, from store.StreamPosition, ctx context.Context) (out <-chan store.Event, err error)