pubsub

Aug 15, 2024

Changes in this version

type Message

+ func (msg *Message) GetMessageAttributes() map[string]string

Jul 9, 2024

Changes in this version

+ func NewBufferedPublisherWithRetryFactory(ctx context.Context, projectID string, batchSize int32, ...) (publisher.BufferedPublisherWithRetry, error)

+ func NewPubSubBufferedPublisherFactory(ctx context.Context, projectID string, batchSize int32, ...) (publisher.BufferedPublisher, error)

+ type Message struct

+ Attributes map[string]string

+ Data []byte

+ MessageId string

+ func NewPubSubMessage(messageId string, payloadBody []byte, payloadAttrs map[string]string) *Message

+ func (msg *Message) GetMsgRefId() string

+ func (msg *Message) GetPayload() []byte

+ func (msg *Message) GetPayloadAttributes() map[string]string