googlepubsub

package
Version: v1.5.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 11, 2019 License: Apache-2.0 Imports: 8 Imported by: 4

Documentation

Overview

Package googlepubsub provides a Google cloud pubsub broker

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClientOption

func ClientOption(c ...option.ClientOption) broker.Option

ClientOption is a broker Option which allows google pubsub client options to be set for the client

func CreateSubscription added in v0.13.0

func CreateSubscription(b bool) broker.Option

CreateSubscription prevents the creation of the subscription if it not exists

func DeleteSubscription added in v0.13.0

func DeleteSubscription(b bool) broker.Option

DeleteSubscription prevents the deletion of the subscription if it not exists

func MaxExtension added in v0.4.0

func MaxExtension(d time.Duration) broker.SubscribeOption

MaxExtension is the maximum period for which the Subscription should automatically extend the ack deadline for each message.

func MaxOutstandingMessages added in v0.4.0

func MaxOutstandingMessages(max int) broker.SubscribeOption

MaxOutstandingMessages sets the maximum number of unprocessed messages (unacknowledged but not yet expired) to receive.

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

NewBroker creates a new google pubsub broker

func ProjectID

func ProjectID(id string) broker.Option

ProjectID provides an option which sets the google project id

Types

This section is empty.

Directories

Path Synopsis
module

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL