internal

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

type Error struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Status  string `json:"status"`
}

type Message struct {
	MessageID   string            `json:"messageId"`
	AckID       string            `json:"-"`
	Data        []byte            `json:"data"`
	PublishTime time.Time         `json:"publishTime"`
	Attributes  map[string]string `json:"attributes"`
}