package
0.0.0-20240328104128-aac5e323fe3e
Repository: https://github.com/ravenhuo/go-pkg.git
Documentation: pkg.go.dev

# Packages

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

# Functions

Addresses sets the host addresses to be used by the mq.
No description provided by the author
No description provided by the author
DisableAutoAck will disable auto acking of messages after they have been handled.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Retry set retry consume policy.
Secure communication with the mq.
SubscribeContext set context.
SubscribeGroupID sets the name of the queue to share messages on.
Specify TLS Config.
No description provided by the author

# Structs

Options 配置Opt.
PublishOptions 发布opt.
SubscribeOptions 订阅Opt.

# Interfaces

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

# Type aliases

HandlerFunc 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
No description provided by the author