Struct google_pubsub1::PubsubMessage

pub struct PubsubMessage {
    pub attributes: Option<HashMap<String, String>>,
    pub data: Option<String>,
    pub publish_time: Option<String>,
    pub message_id: Option<String>,
}

A message that is published by publishers and consumed by subscribers. The message must contain either a non-empty data field or at least one attribute. Note that client libraries represent this object differently depending on the language. See the corresponding client library documentation for more information. See Quotas and limits for more information about message limits.

This type is not used in any activity, and only used as part of another schema.

Fields

attributes: Option<HashMap<String, String>>

Optional attributes for this message.

data: Option<String>

The message data field. If this field is empty, the message must contain at least one attribute.

publish_time: Option<String>

The time at which the message was published, populated by the server when it receives the Publish call. It must not be populated by the publisher in a Publish call.

message_id: Option<String>

ID of this message, assigned by the server when the message is published. Guaranteed to be unique within the topic. This value may be read by a subscriber that receives a PubsubMessage via a Pull call or a push delivery. It must not be populated by the publisher in a Publish call.

Trait Implementations

impl Part for PubsubMessage

impl Default for PubsubMessage

fn default() -> PubsubMessage

Returns the "default value" for a type.

impl Clone for PubsubMessage

fn clone(&self) -> PubsubMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PubsubMessage

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

Formats the value using the given formatter.

impl Serialize for PubsubMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl<'de> Deserialize<'de> for PubsubMessage

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.