projection

type Compactor struct {
	// DB is the database connection used to coordinate compaction.
	DB *sql.DB

	// Handler is the projection to compact.
	Handler dogma.ProjectionMessageHandler

	// Identity is the identity of the handler.
	Identity *identitypb.Identity

	// Interval is the minimum time between successful compactions.
	Interval time.Duration

	// Timeout is the maximum time the handler is given to compact the
	// projection in a single attempt.
	Timeout time.Duration

	// Logger is the target for log messages produced by the compactor and by
	// the handler during compaction.
	Logger *slog.Logger
}

type Consumer struct {
	// Node is this engine's node in the cluster. Its membership determines
	// which streams this node consumes.
	Node *cluster.Node

	// EventStreams is the catalog of event streams to consume.
	EventStreams *eventstream.Catalog

	// Handler is the projection message handler to which events are
	// dispatched.
	Handler dogma.ProjectionMessageHandler

	// Identity is the identity of the handler.
	Identity *identitypb.Identity

	// Concurrency is the handler's concurrency preference.
	Concurrency dogma.ConcurrencyPreference

	// EventTypeIDs is the set of IDs of the event types that the handler
	// consumes. It must not be empty.
	EventTypeIDs *uuidcollection.Set

	// Logger is the target for log messages produced by the consumer and its
	// stream consumers.
	Logger *slog.Logger
	// contains filtered or unexported fields
}