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)

Functions

func NewBufferedPublisherWithRetryFactory

func NewBufferedPublisherWithRetryFactory(
	ctx context.Context,
	projectID string,
	batchSize int32,
	flushDelayThreshold *time.Duration,
	maxRetryCount int16,
	initialRetryInterval *time.Duration,
	opts ...option.ClientOption) (publisher.BufferedPublisherWithRetry, error)

NewBufferedPublisherWithRetryFactory - factory that create a 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 pubsub client and then initialize a publisher.BufferedPublisher.