v1

Documentation

Index

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

Functions

func Notify

func Notify(events []*models.Event)

Types

type Eventstore

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

func Start

func Start(db *sql.DB) (Eventstore, error)

type Subscription

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

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe()