Struct PubSubsStuff 

pub struct PubSubsStuff {
    pub publishers: Arc<[(String, Publisher)]>,
    pub subscriptions: Arc<[(String, Subscription)]>,
}

Fields

publishers: Arc<[(String, Publisher)]>

subscriptions: Arc<[(String, Subscription)]>

Implementations

impl PubSubsStuff

pub async fn new( project_id: Option<String>, instance_id: &str, topics: Arc<[&'static str]>, subs: Arc<[&'static str]>, ) -> Result<Self, Box<dyn Error + Send + Sync>>

pub fn get_publisher(&self, name: &str) -> Option<Publisher>

pub fn get_subscription(&self, name: &str) -> Option<Subscription>

pub fn create_message<T: Serialize>( &self, payload: T, ordering_key: Option<String>, ) -> Result<PubsubMessage, Error>

pub async fn publish_fire_and_forget<T: Serialize + Send + 'static>( &self, topic: &str, payload: T, ordering_key: Option<String>, )