Struct PipelineMeta 

pub struct PipelineMeta {
    pub direction: Direction,
    pub source: String,
    pub sink: String,
    pub peer: Option<String>,
}

Static description of the path a pipeline instance sits on.

Fields

direction: Direction

source: String

sink: String

peer: Option<String>

Implementations

impl PipelineMeta

pub fn new( direction: Direction, source: impl Into<String>, sink: impl Into<String>, ) -> Self

pub fn with_peer(self, peer: Option<impl Into<String>>) -> Self

pub fn upstream(&self) -> &str

The endpoint bytes are read from on this path.

pub fn downstream(&self) -> &str

The endpoint bytes are written to on this path.

pub fn label(&self) -> String

"source -> sink", oriented for this path.

Trait Implementations

impl Clone for PipelineMeta

fn clone(&self) -> PipelineMeta

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineMeta

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

Formats the value using the given formatter.

impl Eq for PipelineMeta

impl PartialEq for PipelineMeta

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PipelineMeta