Untitled :: Tecnisys Docs

patroni.dcs.exhibitor module

class _patroni.dcs.exhibitor.Exhibitor(_config: Dict[ str, Any], mpp: AbstractMPP) View on GitHub 

Bases: ZooKeeper +

__init\\__(config: Dict[ str, Any], mpp: AbstractMPP) → None View on GitHub 

Prepare DCS paths, MPP object, initial values for state information and processing dependencies. +

Variables: config – dict, reference to config section of selected DCS. i.e.: zookeeper for zookeeper, etcd for etcd, etc… +

abc_impl = <_abc._abc_data object>_

load_cluster(_path: str, loader: Callable[[ str], Cluster | Dict[ int, Cluster]]) → Cluster | Dict[ int, Cluster] View on GitHub 

Main abstract method that implements the loading of Cluster instance. + Note

Internally this method should call the _loader_ method that will build `+Cluster+` object which represents current state and topology of the cluster in DCS. This method supposed to be called only by the `+get_cluster()+` method.
+
Parameters:::
Raise:::
  `+DCSError+` in case of communication problems with DCS. If the current node was running as a primary and exception raised, instance would be demoted.

class _patroni.dcs.exhibitor.ExhibitorEnsembleProvider(_hosts: List[ str], port: int, uri_path: str = '/exhibitor/v1/cluster/list', poll_interval: int = 300) View on GitHub 

Bases: object +

TIMEOUT_ = 3.1_: +
__init\\__(hosts: List[ str], port: int, uri_path: str = '/exhibitor/v1/cluster/list', poll_interval: int = 300) → None View on GitHub : +
query_exhibitors(_exhibitors: List[ str]) → Dict[ str, Any] | Any View on GitHub : +
poll() → bool View on GitHub : +
property _zookeeper_hosts: str_: Previous Next

Built with Sphinx using a theme provided by Read the Docs.

Read the Docs v: latest

bugfix-readthedocs

Project Home

+ Builds