googlepubsub

package

v0.13.0 Latest Latest Go to latest Published: Sep 4, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Package googlepubsub provides a Google cloud pubsub broker

This section is empty.

This section is empty.

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(b bool) broker.Option

CreateSubscription prevents the creation of the subscription if it not exists

func DeleteSubscription(b bool) broker.Option

DeleteSubscription prevents the deletion of the subscription if it not exists

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(max int) broker.SubscribeOption

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

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

NewBroker creates a new google pubsub broker

func ProjectID(id string) broker.Option

ProjectID provides an option which sets the google project id

This section is empty.