Struct NotificationDialer 

pub struct NotificationDialer { /* private fields */ }

Reusable handle for the control plane’s NotificationService — the pending-notification projection an edge drains to deliver operator DMs.

Shares the AgentService endpoint (one internal Connect port), so it is built from the same address an edge already holds.

Implementations

impl NotificationDialer

pub fn new(addr: &str) -> Result<Self, DialError>

Build a dialer pointed at addr (expects http://host:port).

Errors

Returns DialError::InvalidAddress if addr isn’t a valid URI, or DialError::Tls if an https endpoint’s TLS setup fails.

pub fn with_bearer(addr: &str, bearer: &str) -> Result<Self, DialError>

Build a dialer pointed at addr, authenticated with bearer.

Every call this dialer makes carries an Authorization: Bearer <bearer> header. NotificationService doesn’t send AgentStart, so no signed AssertedAttribution envelope rides these calls — bearer-only.

Errors

Returns DialError::InvalidAddress if addr isn’t a valid URI, or DialError::InvalidBearer if bearer can’t be encoded as an HTTP header value.

pub async fn poll_pending( &self, provider: &str, ) -> Result<Vec<PendingNotice>, DialError>

Drain undelivered operator notifications for provider ("slack" | "telegram"). Read-only and idempotent — the durable mailbox is unchanged until Self::ack.

Errors

Returns DialError::Connect for any transport/encoding error.

pub async fn ack( &self, provider: &str, action_id: &str, target: &str, ) -> Result<bool, DialError>

Mark an (action_id, target) delivered after the DM is sent. Persists an ops_action_delivered marker server-side so the projection survives restart and never double-delivers. Idempotent: a redundant ack is harmless.

Errors

Returns DialError::Connect for any transport/encoding error.

pub async fn subscribe( &self, provider: &str, ) -> Result<impl Stream<Item = Result<PendingNotice, DialError>>, DialError>

Server-streaming replacement for Self::poll_pending (#803): opens a long-lived Subscribe stream that pushes undelivered notifications for provider as they’re durably recorded, instead of a fixed polling interval. The initial connect ALSO catches a freshly (re)started edge up on whatever is already undelivered — the same coverage a first poll_pending call would give, just pushed rather than pulled.

Errors

The outer Result carries DialError::Connect if opening the stream fails. Each item is a Result so a later transport/decode error surfaces inline without tearing down the whole stream.

Trait Implementations

impl Clone for NotificationDialer

fn clone(&self) -> NotificationDialer

Returns a duplicate of the value.

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

Performs copy-assignment from source.