messagebus

Documentation

Index

• type MessageSender
  • func InitMessageSender(plugins map[string]*mods.YigPlugin) (MessageSender, error)

Types

type MessageSender

type MessageSender interface {
	// send the message async
	AsyncSend(value []byte) error
	// flush all the messages, timeout is in ms.
	Flush(timeout int) error
	// free this instance.
	Close()
}

var MsgSender MessageSender

func InitMessageSender

func InitMessageSender(plugins map[string]*mods.YigPlugin) (MessageSender, error)

create the singleton MessageSender