Struct Topic

pub struct Topic {
    pub name: String,
    pub partitions: Vec<Partition>,
    pub subscribers: Vec<Subscriber>,
}

Fields

name: String

partitions: Vec<Partition>

subscribers: Vec<Subscriber>

Implementations

impl Topic

pub fn new(name: &str, num_partitions: usize, replication_factor: usize) -> Self

Creates a new topic.

Arguments

• name - The name of the topic.
• num_partitions - The number of partitions for the topic.
• replication_factor - The replication factor for the topic.

Examples

use pilgrimage::broker::topic::Topic;

let topic = Topic::new("test_topic", 3, 2);
assert_eq!(topic.name, "test_topic");
assert_eq!(topic.partitions.len(), 3);
assert_eq!(topic.partitions[0].replicas.len(), 2);

pub fn add_subscriber(&mut self, subscriber: Subscriber)

Adds a subscriber to the topic.

Arguments

• subscriber - The subscriber to add.

Examples

use pilgrimage::broker::topic::Topic;
use pilgrimage::subscriber::types::Subscriber;

let mut topic = Topic::new("test_topic", 3, 2);
let subscriber = Subscriber::new("sub1", Box::new(|msg: String| {
    println!("Received message: {}", msg);
}));
topic.add_subscriber(subscriber);
assert_eq!(topic.subscribers.len(), 1);

pub fn remove_subscriber(&mut self, _subscriber_id: &str)

pub fn publish( &mut self, message: String, partition_key: Option<&str>, ) -> Result<usize, BrokerError>

Publishes a message to the topic.

Arguments

• message - The message to publish.
• partition_key - An optional key for partitioning.

Examples

use pilgrimage::broker::topic::Topic;
use pilgrimage::broker::error::BrokerError;

let mut topic = Topic::new("test_topic", 3, 2);
let result = topic.publish("test_message".to_string(), None);
assert!(result.is_ok());

Trait Implementations

impl Clone for Topic

fn clone(&self) -> Topic

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Topic

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

Formats the value using the given formatter.