pubsub

Documentation

Index

• 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
  • 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

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) GetMsgRefId

func (msg *Message) GetMsgRefId() string

GetMsgRefId - Get message id

func (*Message) GetPayload

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

GetPayload - Get message payload

func (*Message) GetPayloadAttributes

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

GetPayloadAttributes - Get message Attributes