engine

Nov 27, 2020

Changes in this version

type OperationOption

+ func EnableHandler(name string, enabled bool) OperationOption

Nov 15, 2020

Changes in this version

type Option

+ func EnableProjectionCompactionDuringHandling(enabled bool) Option

Nov 4, 2020

Changes in this version

type Engine

+ func MustNew(app dogma.Application, options ...Option) *Engine

Nov 2, 2020

Changes in this version

+ type CommandExecutor struct

+ Engine *Engine

+ Options []OperationOption

+ func (e CommandExecutor) ExecuteCommand(ctx context.Context, m dogma.Message) error

+ type EventRecorder struct

+ Engine *Engine

+ Options []OperationOption

+ func (r EventRecorder) RecordEvent(ctx context.Context, m dogma.Message) error

Jun 11, 2020

Changes in this version

+ const DefaultTickInterval

+ func Run(ctx context.Context, e *Engine, d time.Duration, opts ...OperationOption) error

+ func RunTimeScaled(ctx context.Context, e *Engine, d time.Duration, f float64, t time.Time, ...) error

Aug 1, 2019

Changes in this version

+ type Engine struct

+ func New(app dogma.Application, options ...Option) (*Engine, error)

+ func (e *Engine) Dispatch(ctx context.Context, m dogma.Message, options ...OperationOption) error

+ func (e *Engine) ExecuteCommand(ctx context.Context, m dogma.Message) error

+ func (e *Engine) RecordEvent(ctx context.Context, m dogma.Message) error

+ func (e *Engine) Reset()

+ func (e *Engine) Tick(ctx context.Context, options ...OperationOption) error

+ type OperationOption func(*operationOptions)

+ func EnableAggregates(enabled bool) OperationOption

+ func EnableIntegrations(enabled bool) OperationOption

+ func EnableProcesses(enabled bool) OperationOption

+ func EnableProjections(enabled bool) OperationOption

+ func WithCurrentTime(t time.Time) OperationOption

+ func WithObserver(o fact.Observer) OperationOption

+ type Option func(*engineOptions)

+ func WithResetter(fn func()) Option