fraudtwin.KafkaChaosOutage#

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

Bases: BaseModel

A source-time interval with a deterministic delivery behavior.

Parameters:

  • from_time (datetime)

  • to_time (datetime)

  • behavior (Literal['DROP', 'BUFFER_AND_FLUSH', 'DELAY', 'PARTIAL_REJECT'])

  • reject_probability (float)

  • delay_seconds (int)

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

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