inmemory

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)
• type Stream

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)

type Stream

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

Stream Need to add a way to not store multiple events with the same id in the same stream.