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 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.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.