Struct GrpcPcsAdapter 

pub struct GrpcPcsAdapter { /* private fields */ }

Production PcsExternalPort adapter wrapping an ExternalChannel.

Cheap-cloneable (the inner ExternalChannel holds an Arc<Channel> and the API key is Arc<str>); intended to live in shared application state.

Implementations

impl GrpcPcsAdapter

pub async fn connect( endpoint: &str, api_key: impl Into<String>, ) -> Result<Self, Error>

Build an adapter from explicit endpoint + API key.

Validates that api_key parses as an HTTP header value (no CR/LF/NUL) at construction; calls onto the resulting adapter then never re-validate.

Errors

Returns Error::InvalidApiKey if api_key contains characters that cannot be sent as an HTTP Authorization value, plus the transport-construction errors of connect.

pub async fn from_env() -> Result<Self, Error>

Default constructor reading PCS_EXTERNAL_ENDPOINT and PCS_API_KEY from the environment.

Covers the 80% configuration path documented in the workspace CLAUDE.md Quick Start. Use Self::connect to override.

Errors

Returns Error::External when either env var is unset, plus the construction errors of Self::connect.

pub fn from_parts( channel: ExternalChannel, api_key: impl Into<String>, ) -> Result<Self, Error>

Construct from a pre-built ExternalChannel (advanced — useful when the caller has already configured the channel via connect and wants to share it across adapters).

Errors

Returns Error::InvalidApiKey for invalid header characters.

Trait Implementations

impl Clone for GrpcPcsAdapter

fn clone(&self) -> GrpcPcsAdapter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GrpcPcsAdapter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PcsExternalPort for GrpcPcsAdapter

async fn send_alert( &self, template: &TemplateId, recipients: &RecipientList, poll: Option<&PollConfig>, ) -> Result<SendOutcome, PcsFailure>

Hot path: send a batch of templated messages.

async fn get_send_status( &self, id: &SendRequestId, ) -> Result<SendStatus, PcsFailure>

Hot path: poll aggregate delivery status for a previously-issued send request.

fn raw_channel(&self) -> RawPcsChannel<'_>

Escape hatch for templates / admin / polls / observability — RPCs outside the hot path.