Struct PulsarTopic 

pub struct PulsarTopic { /* private fields */ }

A validated Pulsar topic name.

Examples

use ruststream_pulsar::PulsarTopic;

let topic = PulsarTopic::persistent("acme", "orders", "created");
assert_eq!(topic.as_str(), "persistent://acme/orders/created");

let parsed = PulsarTopic::parse("persistent://acme/orders/created")?;
assert_eq!(parsed, topic);

Implementations

impl PulsarTopic

pub fn persistent(tenant: &str, namespace: &str, topic: &str) -> Self

A persistent topic: persistent://tenant/namespace/topic.

Panics

Panics when a component is empty or carries characters Pulsar rejects; use parse for fallible construction from untrusted input.

pub fn non_persistent(tenant: &str, namespace: &str, topic: &str) -> Self

A non-persistent topic: non-persistent://tenant/namespace/topic.

Panics

Panics when a component is empty or carries characters Pulsar rejects; use parse for fallible construction from untrusted input.

pub fn parse(name: &str) -> Result<Self, PulsarError>

Parses a fully qualified name (persistent://t/ns/topic), a tenant/namespace/topic triple (defaulting to persistent), or a bare topic name (defaulting to persistent://public/default/).

Errors

Returns PulsarError::Invalid when the shape or a component is invalid.

pub fn as_str(&self) -> &str

The fully qualified name sent to the broker.

Trait Implementations

impl Clone for PulsarTopic

fn clone(&self) -> PulsarTopic

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PulsarTopic

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

Formats the value using the given formatter.

impl Display for PulsarTopic

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

Formats the value using the given formatter.

impl Eq for PulsarTopic

impl Hash for PulsarTopic

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

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for PulsarTopic