messagebus

Documentation

Index

• Variables
• func AddMsgBuilder(builderType int, builder MessageSenderBuilder)
• func ClearInit()
• type MessageSender
  • func GetMessageSender() (MessageSender, error)
• type MessageSenderBuilder

Variables

var MsgBuilders = make(map[int]MessageSenderBuilder)

Functions

func AddMsgBuilder

func AddMsgBuilder(builderType int, builder MessageSenderBuilder)

func ClearInit

func ClearInit()

this func is just for testing. Don't use it in other place.

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)
}