Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var MsgBuilders = make(map[int]MessageSenderBuilder)
Functions ¶
func AddMsgBuilder ¶
func AddMsgBuilder(builderType int, builder MessageSenderBuilder)
Types ¶
type MessageSender ¶
type MessageSender interface {
// send the message async
AsyncSend(msg *types.Message) error
// flush all the messages, timeout is in ms.
Flush(timeout int) error
// free this instance.
Close()
}
var MsgSender MessageSender
func GetMessageSender ¶
func GetMessageSender() (MessageSender, error)
create the singleton MessageSender
type MessageSenderBuilder ¶
type MessageSenderBuilder interface {
Create(config helper.MsgBusConfig) (MessageSender, error)
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.