Struct pulsar::Pulsar

pub struct Pulsar { /* fields omitted */ }

Methods

impl Pulsar

pub fn new<E: PulsarExecutor>(
    addr: SocketAddr,
    auth: Option<Authentication>,
    executor: E
) -> impl Future<Item = Self, Error = Error>

pub fn lookup_topic<S: Into<String>>(
    &self,
    topic: S
) -> impl Future<Item = BrokerAddress, Error = Error>

pub fn lookup_partitioned_topic_number<S: Into<String>>(
    &self,
    topic: S
) -> impl Future<Item = u32, Error = Error>

get the number of partitions for a partitioned topic

pub fn lookup_partitioned_topic<S: Into<String>>(
    &self,
    topic: S
) -> impl Future<Item = Vec<(String, BrokerAddress)>, Error = Error>

pub fn get_topics_of_namespace(
    &self,
    namespace: String,
    mode: Mode
) -> impl Future<Item = Vec<String>, Error = Error>

pub fn consumer(&self) -> ConsumerBuilder<Unset, Unset, Unset>

pub fn create_multi_topic_consumer<T, S1, S2>(
    &self,
    topic_regex: Regex,
    subscription: S1,
    namespace: S2,
    sub_type: SubType,
    topic_refresh: Duration,
    unacked_message_resend_delay: Option<Duration>,
    options: ConsumerOptions
) -> MultiTopicConsumer<T> where
    T: DeserializeMessage,
    S1: Into<String>,
    S2: Into<String>, 

pub fn create_consumer<T, S1, S2>(
    &self,
    topic: S1,
    subscription: S2,
    sub_type: SubType,
    batch_size: Option<u32>,
    consumer_name: Option<String>,
    consumer_id: Option<u64>,
    unacked_message_redelivery_delay: Option<Duration>,
    options: ConsumerOptions
) -> impl Future<Item = Consumer<T>, Error = Error> where
    T: DeserializeMessage,
    S1: Into<String>,
    S2: Into<String>, 

pub fn create_partitioned_consumers<T: DeserializeMessage + Sized, S1: Into<String> + Clone, S2: Into<String> + Clone>(
    &self,
    topic: S1,
    subscription: S2,
    sub_type: SubType,
    options: ConsumerOptions
) -> impl Future<Item = Vec<Consumer<T>>, Error = Error>

pub fn create_producer<S: Into<String>>(
    &self,
    topic: S,
    name: Option<String>,
    options: ProducerOptions
) -> impl Future<Item = TopicProducer, Error = Error>

pub fn create_partitioned_producers<S: Into<String>>(
    &self,
    topic: S,
    options: ProducerOptions
) -> impl Future<Item = Vec<TopicProducer>, Error = Error>

pub fn send<S: Into<String>, M: SerializeMessage + ?Sized>(
    &self,
    topic: S,
    message: &M,
    options: ProducerOptions
) -> impl Future<Item = CommandSendReceipt, Error = Error>

pub fn send_raw<S: Into<String>>(
    &self,
    message: Message,
    topic: S,
    options: ProducerOptions
) -> impl Future<Item = CommandSendReceipt, Error = Error>

pub fn producer(&self, options: Option<ProducerOptions>) -> Producer

Trait Implementations

impl Clone for Pulsar

fn clone(&self) -> Pulsar

Returns a copy of the value.

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

Performs copy-assignment from source.