Enum Transport 

pub enum Transport {
    Mtls {
        endpoint: String,
        ca_cert: String,
        client_cert: String,
        client_key: String,
        auth_token: Option<String>,
        expected_worker_identity: String,
    },
    Sidecar {
        endpoint: String,
        auth_token: Option<String>,
    },
}

Runtime transport configuration (derived from the manifest).

Variants

Mtls

Mutual TLS with server-identity verification.

Fields

endpoint: String

ca_cert: String

client_cert: String

client_key: String

auth_token: Option<String>

expected_worker_identity: String

Expected server identity (bound to the TLS domain_name).

Sidecar

Plain TCP to a localhost sidecar.

Fields

endpoint: String

auth_token: Option<String>

Implementations

impl Transport

pub async fn connect( &self, connect_timeout: Duration, ) -> Result<Channel, TransportError>

Create a gRPC channel for this transport, failing fast at startup.

connect_timeout bounds the initial connection/handshake.

Errors

Returns a TransportError if certificates cannot be read, the endpoint or TLS configuration is malformed, the server identity does not match, or the connection fails.

pub fn auth_token(&self) -> Option<&str>

The configured auth token, if any.

pub fn worker_identity(&self) -> Option<&str>

The expected worker identity for mTLS transports (for audit logging).

Trait Implementations

impl Clone for Transport

fn clone(&self) -> Transport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Transport

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

Formats the value using the given formatter.