eventstore

Documentation

Index

• type EventStore
  • func Init() (es EventStore, err error)
  • func (es EventStore) Store(streamName string, ctx context.Context, events ...store.Event) (transactionId 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
}

func Init

func Init() (es EventStore, err error)

func (EventStore) Store

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

func (EventStore) Stream

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