Struct ProtocolRegistry 

pub struct ProtocolRegistry { /* private fields */ }

Registry of built-in protocol decoders.

Implementations

impl ProtocolRegistry

pub fn with_builtins() -> Self

Built-in registry with http, grpc, kafka, amqp, and mqtt registered.

pub fn http(&self) -> &HttpProtocol

HTTP protocol implementation.

pub fn grpc(&self) -> &GrpcProtocol

gRPC protocol implementation.

pub fn kafka(&self) -> &KafkaProtocol

Kafka protocol implementation.

pub fn amqp(&self) -> &AmqpProtocol

AMQP protocol implementation.

pub fn mqtt(&self) -> &MqttProtocol

MQTT protocol implementation.

pub fn decode_attachment( &self, attachment: &ProtocolAttachment, ) -> Result<DecodedAttachment>

Decode a protocol attachment envelope.

Built-in ids deserialize to the matching DecodedAttachment variant; other ids return DecodedAttachment::Opaque with bytes unchanged.

pub fn http_operation_from_attachments( &self, protocols: &[ProtocolAttachment], ) -> Option<HttpOperationMeta>

Find the first HTTP operation meta on an operation body’s attachments.

pub fn grpc_operation_from_attachments( &self, protocols: &[ProtocolAttachment], ) -> Option<GrpcOperationMeta>

Find the first gRPC operation meta on an operation body’s attachments.

Trait Implementations

impl Clone for ProtocolRegistry

fn clone(&self) -> ProtocolRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProtocolRegistry

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

Formats the value using the given formatter.

impl Default for ProtocolRegistry

fn default() -> ProtocolRegistry

Returns the “default value” for a type.