eventstore

README

eventstore-lib

Documentation

Index

• type Config
• type Eventstore
  • func Start(conf Config) Eventstore
• type Service
  • func (es *Service) Filter(ctx context.Context, events models.Events, query models.SearchQuery) (err error)
  • func (es *Service) Health(ctx context.Context) error
  • func (es *Service) PushEvents(ctx context.Context, aggregates ...models.Aggregate) (err error)

Types

type Config

type Config struct {
	Repository repository.Repository
}

type Eventstore

type Eventstore interface {
	Health(ctx context.Context) error

	PushEvents(ctx context.Context, events ...models.Aggregate) error
	Filter(ctx context.Context, events models.Events, query models.SearchQuery) error
}

func Start

func Start(conf Config) Eventstore

type Service

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

func (*Service) Filter

func (es *Service) Filter(ctx context.Context, events models.Events, query models.SearchQuery) (err error)

func (*Service) Health

func (es *Service) Health(ctx context.Context) error

func (*Service) PushEvents

func (es *Service) PushEvents(ctx context.Context, aggregates ...models.Aggregate) (err error)