Struct PulsarPublish 

pub struct PulsarPublish;

The publish policy for PulsarPublisher: pure declaration, constructible anywhere, paired with the connected broker by the runtime after connect.

In the generated AsyncAPI document it describes the channel it publishes to: the specification’s pulsar channel binding is a namespace and a persistence, and both live in the destination’s topic name, which the runtime hands the policy. Its operation and message objects are empty, and a partition key belongs to one message rather than to the policy. Replies go to the destination the reply type or the mount site declares, the channel the document reports for them.

Examples

A routes file that does not import this crate’s prelude names the policy by this name:

use ruststream::prelude::*;
use ruststream_pulsar::{PulsarBroker, PulsarPublish, PulsarSubscription};
use serde::{Deserialize, Serialize};

#[derive(Deserialize)]
struct Order {
    id: u64,
}

#[derive(Outgoing, Serialize)]
#[outgoing(name = "receipts")]
struct Receipt {
    id: u64,
}

#[subscriber(PulsarSubscription::new("orders", "workers"), reply)]
async fn confirm(order: &Order) -> Receipt {
    Receipt { id: order.id }
}

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("orders", "0.1.0")).with_broker(
        PulsarBroker::new("pulsar://localhost:6650"),
        |b| {
            b.include(confirm).out_reply(PulsarPublish);
        },
    )
}

Trait Implementations

impl Clone for PulsarPublish

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for PulsarPublish

impl Debug for PulsarPublish

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

Formats the value using the given formatter.

impl Default for PulsarPublish

fn default() -> Self

Returns the “default value” for a type.

impl PublishPolicy<ConnectedPulsarBroker> for PulsarPublish

type Live = PulsarPublisher

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

fn pair( self, connected: &ConnectedPulsarBroker, ) -> impl Future<Output = Result<Self::Live, PairError>>

Pairs the policy with a connected broker, producing the live publisher.

fn channel_bindings(&self, channel: &str) -> Bindings

What a publish through this policy adds to its channel in the generated AsyncAPI document.

fn operation_bindings(&self, channel: &str) -> Bindings

What a publish through this policy adds to its send operation in the document.

fn message_bindings(&self, channel: &str) -> Bindings

What a publish through this policy adds to the messages that leave through it.

fn reply_address_location(&self) -> Option<&'static str>

Where a client finds the address of a reply this policy publishes, as a runtime expression.