pubsub2

type Body struct {
	Message      *Message `json:"message"`
	Subscription string   `json:"subscription"`

	// DeliveryAttempt is the number of times a message has been delivered.
	// This is part of the dead lettering feature that forwards messages that
	// fail to be processed (from nack/ack deadline timeout) to a dead letter topic.
	// If dead lettering is enabled, this will be set on all attempts, starting
	// with value 1. Otherwise, the value will be nil.
	// This field is read-only.
	DeliveryAttempt int `json:"deliveryAttempt"`
}

type HelloHandler struct {
	// contains filtered or unexported fields
}

type Message struct {
	// ID identifies this message. This ID is assigned by the server and is
	// populated for Messages obtained from a subscription.
	//
	// This field is read-only.
	MessageID string `json:"messageId"`

	// Data is the actual data in the message.
	Data []byte `json:"data"`

	// Attributes represents the key-value pairs the current message is
	// labelled with.
	Attributes map[string]string `json:"attributes"`

	// PublishTime is the time at which the message was published. This is
	// populated by the server for Messages obtained from a subscription.
	//
	// This field is read-only.
	PublishTime time.Time `json:"publishTime"`

	// OrderingKey identifies related messages for which publish order should
	// be respected. If empty string is used, message will be sent unordered.
	OrderingKey string `json:"orderingKey"`
}

type PubSubService struct {
	// contains filtered or unexported fields
}

type ReceiveHandler struct {
}