Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBufferedPublisherWithRetryFactory ¶
func NewBufferedPublisherWithRetryFactory( ctx context.Context, projectID string, batchSize int32, flushDelayThresholdMillis int32, maxRetryCount int16, initialRetryIntervalMillis int32, opts ...option.ClientOption) (publisher.BufferedPublisherWithRetry, error)
NewBufferedPublisherWithRetryFactory - factory that create a cloud_pubsub client and then initialize a publisher.BufferedPublisherWithRetry.
func NewPubSubBufferedPublisherFactory ¶
func NewPubSubBufferedPublisherFactory( ctx context.Context, projectID string, batchSize int32, flushDelayThreshold *time.Duration, opts ...option.ClientOption) (publisher.BufferedPublisher, error)
NewPubSubBufferedPublisherFactory - factory that create a cloud_pubsub client and then initialize a publisher.BufferedPublisher.
Types ¶
type Message ¶
type Message struct {
// MessageId - Pubsub message id
MessageId string
// data - Pubsub message payload
Data []byte
// Attributes - Pubsub topic Attributes
Attributes map[string]string
}
Message - Message GetPayload model implementing Message interface.
func NewPubSubMessage ¶
func NewPubSubMessage(messageId string, payloadBody []byte, payloadAttrs map[string]string) *Message
NewPubSubMessage creates a new PipelineMessage.
func (*Message) GetPayload ¶
GetPayload - Get message payload
func (*Message) GetPayloadAttributes ¶
GetPayloadAttributes - Get message Attributes
Source Files
Click to show internal directories.
Click to hide internal directories.