Enum CorpusEvent 

pub enum CorpusEvent {
    Created {
        corpus_id: CorpusId,
        codec_config: CodecConfig,
        compression_policy: CompressionPolicy,
        timestamp: Timestamp,
    },
    VectorsInserted {
        corpus_id: CorpusId,
        vector_ids: Arc<[VectorId]>,
        count: u32,
        timestamp: Timestamp,
    },
    Decompressed {
        corpus_id: CorpusId,
        vector_count: u32,
        timestamp: Timestamp,
    },
    PolicyViolationDetected {
        corpus_id: CorpusId,
        kind: ViolationKind,
        detail: Arc<str>,
        timestamp: Timestamp,
    },
}

A domain event emitted by the Corpus aggregate.

Events are buffered in pending_events and drained atomically by Corpus::drain_events.

Variants

Created

Emitted once when a new Corpus is successfully constructed.

Python parity: CorpusCreated.

Fields

corpus_id: CorpusId

The id of the newly created corpus.

codec_config: CodecConfig

The codec configuration active at construction time.

compression_policy: CompressionPolicy

The compression policy set at construction time.

timestamp: Timestamp

Nanosecond Unix timestamp of construction.

VectorsInserted

Emitted after one or more vectors are successfully inserted.

A single VectorsInserted event covers the entire batch on insert_batch success; insert emits exactly one event per call.

Python parity: VectorsInserted.

Fields

corpus_id: CorpusId

The id of the corpus that received the vectors.

vector_ids: Arc<[VectorId]>

Ids of the vectors that were inserted, in insertion order.

count: u32

Number of vectors inserted (equals vector_ids.len()).

timestamp: Timestamp

Nanosecond Unix timestamp of the insertion.

Decompressed

Emitted after decompress_all succeeds.

Single-vector decompress does not emit an event (Python parity).

Python parity: CorpusDecompressed.

Fields

corpus_id: CorpusId

The id of the corpus whose vectors were decompressed.

vector_count: u32

Total number of vectors decompressed.

timestamp: Timestamp

Nanosecond Unix timestamp of the operation.

PolicyViolationDetected

Emitted when a policy or dimension violation is detected but the operation is not immediately fatal (e.g., logging path).

Python parity: CompressionPolicyViolationDetected.

Fields

corpus_id: CorpusId

The id of the corpus where the violation was detected.

kind: ViolationKind

The category of the violation.

detail: Arc<str>

Human-readable detail string, suitable for logging.

timestamp: Timestamp

Nanosecond Unix timestamp of detection.

Trait Implementations

impl Clone for CorpusEvent

fn clone(&self) -> CorpusEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CorpusEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.