Struct PostgresTopologyProvider 

pub struct PostgresTopologyProvider { /* private fields */ }

PostgreSQL-based topology provider.

Discovers the primary by polling pg_is_in_recovery() on each configured node. Detects primary changes by comparing results across polling intervals.

Implementations

impl PostgresTopologyProvider

pub fn new(nodes: Vec<PostgresNode>) -> Self

Create a new PostgreSQL topology provider.

pub fn with_poll_interval(self, interval: Duration) -> Self

Set polling interval.

pub fn with_tls_mode(self, mode: TlsMode) -> Self

Set the TLS policy used when opening probe connections.

pub async fn start(&self)

Start polling in the background.

Trait Implementations

impl TopologyProvider for PostgresTopologyProvider

Available on crate feature postgres-topology only.

fn subscribe(&self) -> Receiver<TopologyEvent>

Subscribe to topology change events.

fn get_primary(&self) -> Option<TopologyNodeInfo>

Get the current primary node, if one exists.

fn get_node(&self, id: Uuid) -> Option<TopologyNodeInfo>

Look up a node by its UUID.