Categorygithub.com/xmlking/broker/pubsub
modulepackage
0.1.1
Repository: https://github.com/xmlking/broker.git
Documentation: pkg.go.dev

# Packages

No description provided by the author

# Functions

ClientOption is a broker Option which allows google pubsub client options to be set for the client.
CreateSubscription prevents the creation of the subscription if it not exists.
DeleteSubscription prevents the deletion of the subscription if it not exists.
DisableAutoAck will disable auto acking of messages after they have been handled.
ErrorHandler will catch all broker errors that cant be handled in normal way, for example Codec errors.
MaxExtension is the maximum period for which the Subscription should automatically extend the ack deadline for each message.
MaxOutstandingMessages sets the maximum number of unprocessed messages (unacknowledged but not yet expired) to receive.
NewBroker creates a new google pubsub broker.
No description provided by the author
ProjectID provides an option which sets the google project id.
No description provided by the author
PublishContext set context.
Queue sets the name of the queue to share messages on.
No description provided by the author
No description provided by the author
No description provided by the author
SubscribeContext set context.

# Variables

No description provided by the author

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Interfaces

Broker is an interface used for asynchronous messaging.
Event is given to a subscription handler for processing.
Subscriber is a convenience return type for the Subscribe method.

# Type aliases

Handler is used to process messages via a subscription of a topic.
No description provided by the author
No description provided by the author
No description provided by the author