fraudtwin.KafkaChaosResult#

class fraudtwin.KafkaChaosResult(**data)[source][source]#

Bases: BaseModel

Auditable output of one seeded logical-message chaos run.

Parameters:

  • manifest_version (str)

  • seed (int)

  • boundary (Literal['producer', 'consumer'])

  • input_count (int)

  • emitted_count (int)

  • dropped_count (int)

  • retried_count (int)

  • duplicated_count (int)

  • late_count (int)

  • out_of_order_count (int)

  • deduplicated_count (int)

  • partition_counts (dict[str, int])

  • input_fingerprint (str)

  • output_fingerprint (str)

  • envelopes (tuple[ChaosEnvelope, ...])

  • audit (tuple[dict[str, Any], ...])

model_config: ClassVar[ConfigDict] = {'extra': 'forbid', 'frozen': True}#

Configuration for the model, should be a dictionary conforming to [ConfigDict][pydantic.config.ConfigDict].

property manifest: dict[str, Any]#

Return JSON-ready counts, fingerprints, and audit metadata.