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
No description provided by the author
No description provided by the author
# Functions
AddEventHandler 注册MQ事件处理回调函数.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Destroy Destroy释放Init申请的资源.
Init 初始化参数，申请资源.
No description provided by the author
No description provided by the author
Publish 发布事件到MQ key为此消息的有序标识，当为""时，消息为无序，非""时消息会Hash到某一个Partition.
No description provided by the author
No description provided by the author
StartHandler 开始接受MQ事件通知并调用相应的事件处理回调函数.
WrapperHandler 将Handler 包装成 kafka.HandlerFunc.
# Constants
No description provided by the author
如果是redis类型的需要执行redis.Init().
No description provided by the author
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
MQ事件处理回调函数定义.