repos

Documentation

Index

• type AggregateRepo
  • func NewAggregate(pool *pgxpool.Pool, s ev.Serializer) AggregateRepo
• type EventRepo
  • func NewEvent(pool *pgxpool.Pool, s ev.Serializer) EventRepo
• type Repos
  • func New(pool *pgxpool.Pool, s ev.Serializer) Repos

Types

type AggregateRepo

type AggregateRepo interface {
	CreateIfNotExist(ctx context.Context, id, typ string) error
	CheckAndUpdateVersion(ctx context.Context, agg ev.Aggregate) bool
	CreateSnapshot(ctx context.Context, agg ev.Aggregate) error
	ReadSnapshot(ctx context.Context, aggregateID string, version int, agg ev.Aggregate) bool
}

func NewAggregate

func NewAggregate(pool *pgxpool.Pool, s ev.Serializer) AggregateRepo

type EventRepo

type EventRepo interface {
	Get(ctx context.Context, aggregateID string, fromVer, toVer int, root *ev.AggregateRoot) ([]ev.Event, error)
	Append(context.Context, ev.Event) error
}

func NewEvent

func NewEvent(pool *pgxpool.Pool, s ev.Serializer) EventRepo

type Repos

type Repos interface {
	Event() EventRepo
	Aggregate() AggregateRepo
}

func New

func New(pool *pgxpool.Pool, s ev.Serializer) Repos