Struct GrpcIngress 

pub struct GrpcIngress { /* private fields */ }

Minimal blocking gRPC ingress adapter.

This adapter exposes a unary Publish(bytes) service and surfaces each request payload as one ingress message.

Implementations

impl GrpcIngress

pub fn bind( name: impl Into<String>, bind: &str, max_message_bytes: usize, ) -> Result<Self, AdapterError>

Bind a blocking gRPC ingress adapter.

pub fn local_addr(&self) -> SocketAddr

Return the bound socket address.

pub fn endpoint(&self) -> String

Return a client endpoint URL for the adapter.

Trait Implementations

impl Adapter for GrpcIngress

fn name(&self) -> &str

Stable adapter name for logs/obs.

fn transport_kind(&self) -> &str

Adapter transport family label.

fn connection_state(&self) -> &str

Best-effort connection/runtime state for operator visibility.

fn lag(&self) -> Option<u64>

Best-effort queue/stream lag, when the adapter can observe it.

fn status_fields(&self) -> Map<String, Value>

Transport-specific runtime fields that can be attached to operator snapshots.

impl Drop for GrpcIngress

fn drop(&mut self)

Executes the destructor for this type.

impl IngressAdapter for GrpcIngress

fn read_next(&mut self, out: &mut [u8]) -> Result<Option<usize>, AdapterError>

Read the next message.