Struct PartitionedMessageBuilder 

pub struct PartitionedMessageBuilder<'a, P: ProducerApi = Producer> { /* private fields */ }

Partitioned-producer-bound counterpart to crate::MessageBuilder. Same chained setters; the terminal .send().await resolves the partition and dispatches.

Implementations

impl<P: ProducerApi> PartitionedMessageBuilder<'_, P>

pub fn key(self, key: impl Into<String>) -> Self

See OutgoingMessage::key.

pub fn ordering_key(self, key: impl Into<Bytes>) -> Self

See OutgoingMessage::ordering_key.

pub fn event_time_ms(self, ts: u64) -> Self

See OutgoingMessage::event_time_ms.

pub fn property(self, key: impl Into<String>, value: impl Into<String>) -> Self

See OutgoingMessage::property.

pub fn deliver_at_ms(self, ts_ms: i64) -> Self

See OutgoingMessage::deliver_at_ms.

pub fn deliver_after_ms(self, now_ms: i64, delay_ms: i64) -> Self

See OutgoingMessage::deliver_after_ms. The caller supplies now_ms (sans-io, ADR-0011 invariant #3).

pub fn replication_clusters(self, clusters: Vec<String>) -> Self

See OutgoingMessage::replication_clusters.

pub fn disable_replication(self) -> Self

See OutgoingMessage::disable_replication.

pub fn txn(self, txn_id: TxnId) -> Self

See OutgoingMessage::txn.

pub fn value(self, payload: impl Into<Bytes>) -> Self

Set the payload bytes. See OutgoingMessage::value.

pub async fn send(self) -> Result<MessageId, PulsarError>

Resolve the partition and dispatch. Returns the broker-assigned MessageId.

Trait Implementations

impl<'a, P: Debug + ProducerApi> Debug for PartitionedMessageBuilder<'a, P>

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

Formats the value using the given formatter.