Enum FramingContract 

#[non_exhaustive]
pub enum FramingContract {
    PerRecord,
    WholePayload,
}

What one payload emitted by a source represents, so the framework can pair a source with a deserializer without the two being coordinated by hand.

• PerRecord: the source already framed one record per payload — it ran a RecordFramer over its byte stream (e.g. an spate-s3 backfill framing each object with the format’s framer). The deserializer must decode a single unit; a deserializer configured to also frame the payload is a double-framing error.
• WholePayload: the source emits whole payloads and the deserializer owns framing (e.g. a Kafka message, which may carry one record or many). This is the default for sources that do not frame.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

PerRecord

One record per payload — the deserializer decodes a single unit.

WholePayload

Whole payloads — the deserializer frames them.

Trait Implementations

impl Clone for FramingContract

fn clone(&self) -> FramingContract

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for FramingContract

impl Debug for FramingContract

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

Formats the value using the given formatter.

impl Eq for FramingContract

impl PartialEq for FramingContract

fn eq(&self, other: &FramingContract) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for FramingContract