Struct FlowHeader 

pub struct FlowHeader {
    pub endpoint: String,
    pub flow: u64,
    pub content_type: Option<String>,
    pub traceparent: Option<String>,
    pub tracestate: Option<String>,
    pub topic: Option<String>,
}

FLOW header (kind 7).

The registration of a datagram flow: the stream it opens is the flow’s lifetime, and the flow id prefixes every datagram the flow carries (decisions/0034 §4.2). The optional keys reuse DATA’s meaning and caps.

Fields

endpoint: String

Endpoint path the flow is addressed to (key 0, required).

flow: u64

Flow id, chosen by the sender and unique per connection and direction (key 1, required).

content_type: Option<String>

Opaque media type label (key 2).

traceparent: Option<String>

W3C Trace Context traceparent (key 3).

tracestate: Option<String>

W3C Trace Context tracestate (key 4).

topic: Option<String>

Topic the flow carries (key 5).

Implementations

impl FlowHeader

pub fn new(endpoint: impl Into<String>, flow: u64) -> FlowHeader

A header for flow flow addressed to endpoint, with no optional key.

pub fn encode(&self) -> Vec<u8>

Encodes the header.

pub fn encode_into(&self, out: &mut Vec<u8>)

Appends the encoded header to out. The canonical form has one implementation and this is it; Self::encode is a wrapper.

pub fn decode(bytes: &[u8]) -> Result<FlowHeader, HeaderError>

Decodes the header.

Trait Implementations

impl Clone for FlowHeader

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FlowHeader

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

Formats the value using the given formatter.

impl Eq for FlowHeader

impl PartialEq for FlowHeader

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for FlowHeader