projection

Documentation

Index

• Variables
• type ContextKey
• type Projector
• type Registerer
• type Schedules
• type Worker
  • func New(bus event.Bus, store event.Store, reg *codec.Registry, opts ...WorkerOption) *Worker
  • func (svc *Worker) Start(ctx context.Context, opts ...projection.SubscribeOption) (<-chan error, error)
• type WorkerOption
  • func WithErrorFunc(fn func(projection.Job, error)) WorkerOption
  • func WithLogger(logger *zap.SugaredLogger) WorkerOption
  • func WithProjector(projector Projector) WorkerOption
  • func WithSchedules(schedules Schedules) WorkerOption

Variables

var (
	ContextKeyJobName = ContextKey("name")
	ContextKeyId      = ContextKey("id")
	ContextKeyRunId   = ContextKey("run-id")
)

Types

type ContextKey

type ContextKey string

type Projector

type Projector interface {
	WithSchedules(bus event.Bus, store event.Store) Schedules
	HandleJob(projection.Job) error
}

type Registerer

type Registerer interface {
	// RegisterEventHandler registers an event handler for the given event name.
	RegisterEventHandler(eventName string, handler func(event.Event) error)
}

type Schedules

type Schedules = map[string]projection.Schedule

type Worker

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

func New

func New(bus event.Bus, store event.Store, reg *codec.Registry, opts ...WorkerOption) *Worker

func (*Worker) Start

func (svc *Worker) Start(ctx context.Context, opts ...projection.SubscribeOption) (<-chan error, error)

type WorkerOption

type WorkerOption func(*Worker)

func WithErrorFunc

func WithErrorFunc(fn func(projection.Job, error)) WorkerOption

func WithLogger

func WithLogger(logger *zap.SugaredLogger) WorkerOption

func WithProjector

func WithProjector(projector Projector) WorkerOption

func WithSchedules

func WithSchedules(schedules Schedules) WorkerOption