pubsub

type AckMessage struct {
	AckIDs []string `json:"ackIds"`
}

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

type Message struct {
	// Data is the message data.
	Data []byte `json:"data"`

	// Attributes are any message attributes.
	Attributes map[string]string `json:"attributes"`

	// MessageID is assigned by the server.
	MessageID string `json:"messageId"`

	// PublishTime is the server timestamp for when the message was published.
	PublishTime *time.Time `json:"publishTime"`
}

type Messages struct {
	Messages []*Message `json:"messages"`
}

type ReceivedMessage struct {
	AckID   string   `json:"ackId"`
	Message *Message `json:"message"`
}

type ReceivedMessages struct {
	ReceivedMessages []*ReceivedMessage `json:"receivedMessages"`
}