pulsar.AutoClusterFailover

class documentation

class AutoClusterFailover: (source)

Constructor: AutoClusterFailover(primary, secondary, check_interval_ms, failover_threshold, switch_back_threshold)

View In Hierarchy

Cluster-level automatic failover configuration for Client.

Method __init__ Create an automatic failover configuration.
Method __repr__ Undocumented
Instance Variable check_interval_ms Undocumented
Instance Variable failover_threshold Undocumented
Instance Variable primary Undocumented
Instance Variable secondary Undocumented
Instance Variable switch_back_threshold Undocumented
def __init__(self, primary: ServiceInfo, secondary: list[ServiceInfo], check_interval_ms: int = 5000, failover_threshold: int = 1, switch_back_threshold: int = 1): (source)

Create an automatic failover configuration.

Parameters
primary:ServiceInfoThe preferred cluster to use.
secondary:list[ServiceInfo]Ordered fallback clusters to probe when the primary becomes unavailable.
check_interval_ms:int, default 5000Probe interval in milliseconds.
failover_threshold:int, default 1Number of consecutive probe failures required before failover.
switch_back_threshold:int, default 1Number of consecutive successful primary probes required before switching back.
def __repr__(self) -> str: (source)

Undocumented

check_interval_ms = (source)

Undocumented

failover_threshold = (source)

Undocumented

primary = (source)

Undocumented

secondary = (source)

Undocumented

switch_back_threshold = (source)

Undocumented