Enum FaultKind 

pub enum FaultKind {
    DiskPressure {
        watermark: Ratio,
    },
    SlowFollower {
        slowdown: Slowdown,
    },
    Pause {
        intends_failover: bool,
    },
    Restart {
        graceful: bool,
    },
    Roll {
        to: Side,
    },
    CertificateRotation,
    Reassignment {
        path: String,
    },
}

What a fault does.

Variants

DiskPressure

Fill the target’s data volume to watermark of host.disk_capacity.

Fields

watermark: Ratio

SlowFollower

Slow the target’s replication.

Fields

slowdown: Slowdown

Pause

SIGSTOP the target for the fault’s duration, then SIGCONT it.

Fields

intends_failover: bool

Whether the pause is meant to outlast the check-quorum window and move leadership. A pause that is not must stay below the window.

Restart

Stop the target and start it again after the fault’s duration.

Fields

graceful: bool

SIGTERM and a controlled shutdown when true, SIGKILL when false.

Roll

A lifecycle transition: stop the target with a controlled shutdown, and after the fault’s duration start it again, on the same data, from the image of the to release.

Fields

to: Side

CertificateRotation

A lifecycle transition: give the target’s TLS listener a certificate from a new CA, with the same DN and SANs, and a truststore that holds both CAs. The files are rewritten in place and the listener’s keystore and truststore are altered to them, which the broker reloads without a restart.

Reassignment

A lifecycle transition: drain the target of path. Every replica of the path that the target holds moves, with AlterPartitionReassignments, to a broker that holds no replica of that partition, so the cluster needs more brokers than the replication factor.

Fields

path: String

Implementations

impl FaultKind

pub fn name(&self) -> &'static str

The snake-case name the YAML spells this kind with.

pub fn moves_leadership(&self) -> bool

Whether the fault takes its target out of the quorum long enough to move leadership, and so a controller failover when the target is the active controller.

pub fn checks(&self, target: Target) -> Vec<RecoveryCheck>

The recoveries the harness measures after a fault of this kind on target.

Trait Implementations

impl Clone for FaultKind

fn clone(&self) -> FaultKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FaultKind

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FaultKind

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for FaultKind

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for FaultKind

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FaultKind