Struct StreamerUri

pub struct StreamerUri { /* private fields */ }

URI of Streaming Server. If this is a cluster, there can be multiple nodes.

Examples:

stdio://
redis://localhost
kafka://node-a:1234,node-b:1234
file://./path/to/stream

Implementations

impl StreamerUri

pub fn zero() -> StreamerUri

pub fn one(url: Url) -> StreamerUri

pub fn many(urls: impl Iterator<Item = Url>) -> StreamerUri

pub fn protocol(&self) -> Option<&str>

pub fn nodes(&self) -> &[Url]

pub fn into_nodes(self) -> impl Iterator<Item = Url>

Trait Implementations

impl Clone for StreamerUri

fn clone(&self) -> StreamerUri

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamerUri

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

Formats the value using the given formatter.

impl Display for StreamerUri

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

Formats the value using the given formatter.

impl From<Url> for StreamerUri

fn from(value: Url) -> StreamerUri

Converts to this type from the input type.

impl FromIterator<Url> for StreamerUri

fn from_iter<T>(iter: T) -> StreamerUri

where T: IntoIterator<Item = Url>,

Creates a value from an iterator.

impl FromStr for StreamerUri

type Err = StreamUrlErr

The associated error which can be returned from parsing.

fn from_str(urls: &str) -> Result<StreamerUri, <StreamerUri as FromStr>::Err>

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

impl Hash for StreamerUri

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

where __H: Hasher,

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 PartialEq for StreamerUri

fn eq(&self, other: &StreamerUri) -> 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 Eq for StreamerUri

impl StructuralPartialEq for StreamerUri