pubsub: add publish_messages methods

google-cloud/src/pubsub/mod.rs

@@ -2,7 +2,9 @@ mod client;
 mod message;
 mod subscription;
 mod topic;
-mod api {
+
+/// API proto structures
+pub mod api {
     include!("api/google.pubsub.v1.rs");
 }
 

google-cloud/src/pubsub/topic.rs

@@ -80,23 +80,34 @@ impl Topic {
     }
 
     /// Publish a message onto this topic.
-    pub async fn publish(&mut self, data: impl Into<Vec<u8>>) -> Result<(), Error> {
+    pub async fn publish_message(&mut self, msg: api::PubsubMessage) -> Result<(), Error> {
+        self.publish_messages(vec![msg]).await
+    }
+
+    /// Publish a message onto this topic.
+    pub async fn publish_messages(
+        &mut self,
+        messages: Vec<api::PubsubMessage>,
+    ) -> Result<(), Error> {
         let request = api::PublishRequest {
             topic: self.name.clone(),
-            messages: vec![api::PubsubMessage {
-                data: data.into(),
-                attributes: HashMap::new(),
-                message_id: String::new(),
-                ordering_key: String::new(),
-                publish_time: None,
-            }],
+            messages,
         };
         let request = self.client.construct_request(request).await?;
         self.client.publisher.publish(request).await?;
 
         Ok(())
     }
 
+    /// Publish a message onto this topic.
+    pub async fn publish(&mut self, data: impl Into<Vec<u8>>) -> Result<(), Error> {
+        self.publish_message(api::PubsubMessage {
+            data: data.into(),
+            ..Default::default()
+        })
+        .await
+    }
+
     /// Delete the topic.
     pub async fn delete(mut self) -> Result<(), Error> {
         let request = api::DeleteTopicRequest {