engine

Documentation

Overview

Package engine wires the store's transactional ingest to the live bus.

Index

• type Engine
  • func New(st *store.Store, b *bus.Bus) *Engine
  • func (e *Engine) Ingest(ev core.Event) (store.IngestResult, error)

Types

type Engine

type Engine struct {
	Store *store.Store
	Bus   *bus.Bus
	// Notify, when set, is called after any ingest that produced
	// continuations — the dispatcher's wake signal.
	Notify func()
}

func New

func New(st *store.Store, b *bus.Bus) *Engine

func (*Engine) Ingest

func (e *Engine) Ingest(ev core.Event) (store.IngestResult, error)

Ingest normalizes the event, runs the outbox transaction, and only then notifies live subscribers (durable first, notify second).