v1

Documentation

Index

• func Notify(events []*models.Event)
• type Config
• type Eventstore
  • func Start(conf Config) (Eventstore, error)
• type Subscription
  • func (s *Subscription) Unsubscribe()

Functions

func Notify

func Notify(events []*models.Event)

Types

type Config

type Config struct {
	Repository  sql.Config
	ServiceName string
	Cache       *config.CacheConfig
}

type Eventstore

type Eventstore interface {
	Health(ctx context.Context) error
	FilterEvents(ctx context.Context, searchQuery *models.SearchQuery) (events []*models.Event, err error)
	LatestSequence(ctx context.Context, searchQuery *models.SearchQueryFactory) (uint64, error)
	Subscribe(aggregates ...models.AggregateType) *Subscription
}

func Start

func Start(conf Config) (Eventstore, error)

type Subscription

type Subscription struct {
	Events chan *models.Event
	// contains filtered or unexported fields
}

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe()