Crate eventcore
Source - require
- Validates a business rule condition and returns early with
CommandError::BusinessRuleViolation when the condition is false.
- AttemptNumber
- Attempt number for retry operations (1-based).
- BackoffMultiplier
- Backoff multiplier for exponential retry delays.
- BatchSize
- Batch size domain type for limiting query results.
- DelayMilliseconds
- Delay in milliseconds for retry or backoff operations.
- EventFilter
- Filter criteria for selecting which events to read from the event store.
- EventPage
- Pagination parameters for reading events.
- EventRetryConfig
- Configuration for event retry behavior (application level).
- EventStreamReader
- Event stream reader generic over event payload type.
- EventStreamSlice
- Placeholder for event stream slice type.
- ExecutionResponse
- Represents the successful outcome of command execution.
- FailureContext
- Context provided to error handler when event processing fails.
- MaxConsecutiveFailures
- Maximum number of consecutive poll failures before stopping.
- MaxRetries
- Maximum number of retry attempts.
- MaxRetryAttempts
- Maximum number of retry attempts for event processing.
- NewEvents
- Collection of new events produced by a command.
- NoCheckpointStore
- A no-op checkpoint store that never saves or loads checkpoints.
- PollConfig
- Configuration for projection polling behavior.
- ProjectionRunner
- Orchestrates projector execution with event polling.
- RetryContext
- Context information passed to metrics hooks during retry lifecycle.
- RetryCount
- Count of retry attempts that have been made (0-based).
- RetryPolicy
- Configuration for automatic retry behavior on concurrency conflicts.
- StreamDeclarations
- StreamId
- Stream identifier domain type.
- StreamPosition
- Global stream position representing a location in the ordered event log.
- StreamPrefix
- Stream prefix domain type for filtering events by stream ID prefix.
- StreamVersion
- Stream version domain type.
- StreamWriteEntry
- StreamWrites
- Placeholder for collection of events to write, organized by stream.
- BackoffStrategy
- Defines the delay strategy between retry attempts.
- CommandError
- Error type for command execution failures.
- EventStoreError
- Error type returned by event store operations.
- FailureStrategy
- Strategy for handling event processing failures.
- Operation
- Identifies the event store operation that failed.
- PollMode
- Polling mode for projection runners.
- ProjectionError
- Error type for projection operations.
- StreamDeclarationsError
- CheckpointStore
- Trait for persisting and retrieving projection checkpoints.
- CommandLogic
- Trait defining the business logic of a command.
- CommandStreams
- Infrastructure trait describing the streams required to execute a command.
- Event
- Event trait for domain-first event sourcing.
- EventReader
- Trait for reading events globally for projections.
- EventStore
- Trait defining the contract for event store implementations.
- MetricsHook
- Callback trait for integrating with metrics systems during retry lifecycle.
- Projector
- Trait for transforming events into read model updates.
- StreamResolver
- Trait for runtime stream discovery when static declarations are insufficient.
- execute
- Execute a command against the event store with a custom retry policy.
- run_projection
- Runs a projector against a backend that provides events, checkpoints, and coordination.
- Command
- Macro entry point that generates
CommandStreams implementations for
structs whose StreamId fields are annotated with #[stream].