modulepackage
0.0.0-20221211031257-e2a6ffbcd992
Repository: https://github.com/nilorg/outbox.git
Documentation: pkg.go.dev
# Packages
No description provided by the author
# Functions
DecodeValue 对值进行解码.
EncodeValue 对值进行编码.
New 创建.
NewRedisMessageTracker 创建基于redis做的消息追踪,用于幂等操作.
# Constants
CallbackTypePublished ...
CallbackTypeReceived ...
EngineTypeGorm engine type for gorm.
MessageHeaderMsgCallbackKey 消息回调.
MessageHeaderMsgIDKey 消息ID.
MessageHeaderMsgSendTimeKey 消息发送时间.
MessageHeaderMsgTopicKey 消息主题.
MessageHeaderMsgTypeKey 消息内容类型.
MessageVersion 版本.
PublishedTableName ...
ReceivedTableName ...
StatusNameFailed 失败.
StatusNameScheduled 列入计划.
StatusNameSucceeded 成功.
# Variables
DefaultEngineOptions 默认选项.
# Structs
CommitMessage 提交message.
EngineOptions ...
Published ...
Received ...
StdLogger ...
# Interfaces
Engine ...
Logger logger.
MessageTracker 消息追踪.
Publisher 发布接口.
Subscriber 订阅接口.
Transactioner 事务接口.
# Type aliases
EngineType engine type.
FailedThresholdCallbackHandler 重试阈值的失败回调处理.
Message 消息.
SubscribeHandler 订阅处理.
TransactionHandler ...