Struct MultiConnectorRunner 

pub struct MultiConnectorRunner { /* private fields */ }

Runs N independently-approvable connectors over a shared transport.

See module-level docs for transport semantics. From the Matrix server’s point of view, each registration is a normal Connect RPC.

Implementations

impl MultiConnectorRunner

pub fn new( opts: MultiTransportOptions, registrations: Vec<ConnectorRegistration>, ) -> Self

Create a new runner. Construction does not open any connections — transport is established lazily by MultiConnectorRunner::run.

Duplicate registrations (same tenant.type.instance) are rejected by MultiConnectorRunner::add; duplicates passed in here are reduced to the first occurrence and logged.

pub async fn add(&self, registration: ConnectorRegistration) -> Result<()>

Append a registration. Only valid before MultiConnectorRunner::run is called; returns an error if run() has already started or if the registration’s tenant.type.instance collides with an existing one.

running is checked inside the same write-lock critical section that run() uses to snapshot the registration list, so a concurrent add either lands before the snapshot (and is driven) or returns ConnectorError::AlreadyRunning. There is no window where the registration is silently dropped.

pub fn shutdown_handle(&self) -> ShutdownHandle

Get a ShutdownHandle that signals every registration to exit.

pub async fn registrations(&self) -> Vec<RegistrationKey>

Snapshot of the registered keys (in insertion order).

pub async fn metrics_snapshot( &self, ) -> HashMap<RegistrationKey, ConnectorMetrics>

Per-registration metrics snapshot.

Each registration owns its own ConnectorMetrics (no global singleton), so values are independent across registrations sharing the same transport.

pub async fn run(&self) -> Result<()>

Run all registrations to completion or until shutdown.

Returns once every registration has exited. Individual registration failures are logged but do not abort the runner unless MultiTransportOptions::reconnect_enabled is false.