Struct StreamId

pub struct StreamId {
    pub node_id: NodeId,
    pub stream_nr: StreamNr,
}

The unique identifier of a single event stream emitted by an Actyx node

The emitting node — identified by its NodeId — may emit multiple streams with different IDs. The emitting node’s ID can be extracted from this stream ID without further information.

The default serialization of this type is the string representation of the NodeId followed by a dot and a base64url multibase-encoded multiformats-varint (see also varint).

Fields

node_id: NodeId

stream_nr: StreamNr

Implementations

impl StreamId

pub fn min() -> Self

pub fn node_id(&self) -> NodeId

pub fn stream_nr(&self) -> StreamNr

Trait Implementations

impl Abomonation for StreamId

unsafe fn entomb<W: Write>(&self, _write: &mut W) -> Result<()>

Write any additional information about &self beyond its binary representation.

fn extent(&self) -> usize

Reports the number of further bytes required to entomb self.

unsafe fn exhume<'a, 'b>( &'a mut self, bytes: &'b mut [u8], ) -> Option<&'b mut [u8]>

Recover any information for &mut self not evident from its binary representation.

impl Clone for StreamId

fn clone(&self) -> StreamId

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamId

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

Formats the value using the given formatter.

impl Decode<DagCborCodec> for StreamId

fn decode<R: Read + Seek>(c: DagCborCodec, r: &mut R) -> Result<Self>

Decode from an impl Read.

impl Default for StreamId

fn default() -> StreamId

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamId

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for StreamId

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

Formats the value using the given formatter.

impl Encode<DagCborCodec> for StreamId

fn encode<W: Write>(&self, c: DagCborCodec, w: &mut W) -> Result<()>

Encodes into a impl Write.

impl From<&SourceId> for StreamId

fn from(src: &SourceId) -> Self

Converts to this type from the input type.

impl From<SourceId> for StreamId

fn from(src: SourceId) -> Self

Converts to this type from the input type.

impl From<StreamId> for String

fn from(sid: StreamId) -> String

Converts to this type from the input type.

impl FromStr for StreamId

type Err = Error

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, Self::Err>

Parses a string s to return a value of this type.

impl Hash for StreamId

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Ord for StreamId

fn cmp(&self, other: &StreamId) -> Ordering

This method returns an Ordering between self and other.

fn max(self, other: Self) -> Self

where Self: Sized,

Compares and returns the maximum of two values.

fn min(self, other: Self) -> Self

where Self: Sized,

Compares and returns the minimum of two values.

fn clamp(self, min: Self, max: Self) -> Self

where Self: Sized,

Restrict a value to a certain interval.

impl PartialEq for StreamId

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl PartialOrd for StreamId

fn partial_cmp(&self, other: &StreamId) -> Option<Ordering>

This method returns an ordering between self and other values if one exists.

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

Tests less than (for self and other) and is used by the < operator.

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

Tests less than or equal to (for self and other) and is used by the <= operator.

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

Tests greater than (for self and other) and is used by the > operator.

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

Tests greater than or equal to (for self and other) and is used by the >= operator.

impl Serialize for StreamId

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<String> for StreamId

type Error = Error

The type returned in the event of a conversion error.

fn try_from(value: String) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for StreamId

impl Eq for StreamId

impl StructuralPartialEq for StreamId