example

Dec 28, 2020

Changes in this version

+ const BarEventName

+ const DatabaseURL

+ const FooEventName

+ const FooReadmodelTable

+ const FooStream

+ var ErrFooNotFound = errors.New("Foo not found")

+ func CreateAggregate(ctx context.Context, pool *pgxpool.Pool)

+ func CreateProjection(ctx context.Context, pool *pgxpool.Pool)

+ func CreateQuery(ctx context.Context, pool *pgxpool.Pool)

+ func CreateReadModelProjection(ctx context.Context, pool *pgxpool.Pool)

+ func Logger(_ context.Context, event eventstore.DomainEvent) (eventstore.DomainEvent, error)

+ func Transform(_ context.Context, event eventstore.DomainEvent) (eventstore.DomainEvent, error)

+ type BarEvent struct

+ Bar string

+ type FooAggregate struct

+ Foo string

+ func NewFooAggregate() *FooAggregate

+ func NewFooAggregateFromHistory(events eventstore.DomainEventIterator) *FooAggregate

+ func (f *FooAggregate) WhenFooEvent(e FooEvent)

+ type FooEvent struct

+ Foo string

+ type FooReadModel struct

+ func NewFooReadModel(client *pg.Client) *FooReadModel

+ func (f *FooReadModel) Delete(ctx context.Context) error

+ func (f *FooReadModel) Init(ctx context.Context) error

+ func (f *FooReadModel) IsInitialized(ctx context.Context) (bool, error)

+ func (f *FooReadModel) Persist(ctx context.Context) error

+ func (f *FooReadModel) Reset(ctx context.Context) error

+ func (f *FooReadModel) Stack(method string, args ...map[string]interface{})

+ type FooRepository struct

+ func NewFooRepository(streamName string, eventStore *eventstore.EventStore) *FooRepository

+ func (r FooRepository) Get(ctx context.Context, fooID uuid.UUID) (*FooAggregate, error)

+ func (r FooRepository) Save(ctx context.Context, foo *FooAggregate) error