eventstore

Documentation

Index

• type TestAggregateStore
  • func NewTestAggregateStore() *TestAggregateStore
  • func (as *TestAggregateStore) Exists(ctx context.Context, aggregateID string) error
  • func (as *TestAggregateStore) GetEventMap() map[string][]eventstore.Event
  • func (as *TestAggregateStore) Load(ctx context.Context, aggregate eventstore.Aggregate) error
  • func (as *TestAggregateStore) LoadVersion(ctx context.Context, aggregate eventstore.Aggregate) error
  • func (as *TestAggregateStore) Save(ctx context.Context, aggregate eventstore.Aggregate) error
  • func (as *TestAggregateStore) UpdateStreamMetadata(ctx context.Context, streamID string, streamMetadata esdb.StreamMetadata) error

Types

type TestAggregateStore

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

func NewTestAggregateStore

func NewTestAggregateStore() *TestAggregateStore

func (*TestAggregateStore) Exists

func (as *TestAggregateStore) Exists(ctx context.Context, aggregateID string) error

func (*TestAggregateStore) GetEventMap

func (as *TestAggregateStore) GetEventMap() map[string][]eventstore.Event

func (*TestAggregateStore) Load

func (as *TestAggregateStore) Load(ctx context.Context, aggregate eventstore.Aggregate) error

func (*TestAggregateStore) LoadVersion

func (as *TestAggregateStore) LoadVersion(ctx context.Context, aggregate eventstore.Aggregate) error

func (*TestAggregateStore) Save

func (as *TestAggregateStore) Save(ctx context.Context, aggregate eventstore.Aggregate) error

func (*TestAggregateStore) UpdateStreamMetadata

func (as *TestAggregateStore) UpdateStreamMetadata(ctx context.Context, streamID string, streamMetadata esdb.StreamMetadata) error