The highest tagged major version is
Documentation
¶
Overview ¶
Package googlepubsub provides a Google cloud pubsub broker
Index ¶
- func ClientOption(c ...option.ClientOption) broker.Option
- func CreateSubscription(b bool) broker.Option
- func DeleteSubscription(b bool) broker.Option
- func MaxExtension(d time.Duration) broker.SubscribeOption
- func MaxOutstandingMessages(max int) broker.SubscribeOption
- func NewBroker(opts ...broker.Option) broker.Broker
- func ProjectID(id string) broker.Option
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 ¶
CreateSubscription prevents the creation of the subscription if it not exists
func DeleteSubscription ¶
DeleteSubscription prevents the deletion of the subscription if it not exists
func MaxExtension ¶
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 ¶
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.