Struct Expectation 

pub struct Expectation {
    pub records: Option<Vec<Value>>,
    pub dlq: Option<Vec<Value>>,
    pub records_written: Option<usize>,
    pub dlq_count: Option<usize>,
    pub error: Option<String>,
    pub unordered: bool,
    pub match_mode: MatchMode,
}

Expected outcome of a test case. Every field is optional but at least one must be set; all set fields are asserted together.

Fields

records: Option<Vec<Value>>

The exact records the sink must receive, in order (set unordered: true to compare as a multiset). Compared per match.

dlq: Option<Vec<Value>>

The original record payloads that must land in the DLQ (quality / contract quarantines), in order. Envelope metadata (timestamps, error messages) is not compared — only the quarantined payload itself.

records_written: Option<usize>

Total records the sink must receive (a count-only alternative to records).

dlq_count: Option<usize>

Total DLQ envelopes (a count-only alternative to dlq).

error: Option<String>

The run must FAIL, and the error message must contain this substring (e.g. a quality abort or contract on_breach: fail). Without this field, a failing run fails the case.

unordered: bool

Compare records / dlq as multisets instead of ordered lists.

match_mode: MatchMode

How individual records are compared.

Implementations

impl Expectation

pub fn has_any(&self) -> bool

True when at least one assertion field is set.

Trait Implementations

impl Clone for Expectation

fn clone(&self) -> Expectation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Expectation

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

Formats the value using the given formatter.

impl Default for Expectation

fn default() -> Expectation

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Expectation

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for Expectation

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl Serialize for Expectation

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.