Struct hadoop_common::proto::hadoop::common::RpcTraceInfoProto

pub struct RpcTraceInfoProto {
    pub trace_id: Option<i64>,
    pub parent_id: Option<i64>,
    pub span_context: Option<Vec<u8>>,
}

Used to pass through the information necessary to continue a trace after an RPC is made. All we need is the traceid (so we know the overarching trace this message is a part of), and the id of the current span when this message was sent, so we know what span caused the new span we will create when this message is received.

Fields

trace_id: Option<i64>

parentIdHigh

parent_id: Option<i64>

parentIdLow

span_context: Option<Vec<u8>>

Trace SpanContext

Implementations

impl RpcTraceInfoProto

pub fn trace_id(&self) -> i64

Returns the value of trace_id, or the default value if trace_id is unset.

pub fn parent_id(&self) -> i64

Returns the value of parent_id, or the default value if parent_id is unset.

pub fn span_context(&self) -> &[u8]

Returns the value of span_context, or the default value if span_context is unset.

Trait Implementations

impl Clone for RpcTraceInfoProto

fn clone(&self) -> RpcTraceInfoProto

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RpcTraceInfoProto

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

Formats the value using the given formatter.

impl Default for RpcTraceInfoProto

fn default() -> Self

Returns the “default value” for a type.

impl Message for RpcTraceInfoProto

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where B: BufMut, Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8, Global>where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where B: BufMut, Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8, Global>where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError>where B: Buf, Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where B: Buf, Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where B: Buf, Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where B: Buf, Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<RpcTraceInfoProto> for RpcTraceInfoProto

fn eq(&self, other: &RpcTraceInfoProto) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RpcTraceInfoProto