listener

Documentation

Index

• Constants
• Variables
• func InitHandler()
• func Process(module string)
• type Handle
• type Listener
• type MessageHandler
  • func (mh *MessageHandler) AddListener(key interface{}, han Handle)
  • func (mh *MessageHandler) DelCallback(messageID string)
  • func (mh *MessageHandler) HandleMessage(message *model.Message) error
  • func (mh *MessageHandler) RemoveListener(key interface{})
  • func (mh *MessageHandler) SetCallback(messageID string, callback func(message *model.Message))
• type RestHandler
  • func (rh *RestHandler) AddListener(key interface{}, han Handle)
  • func (rh *RestHandler) IsMatch(key interface{}, message interface{}) bool
  • func (rh *RestHandler) RemoveListener(key interface{})
  • func (rh *RestHandler) Serve()

Constants

const MaxMessageBytes = 12 * (1 << 20)

Variables

var MessageHandlerInstance = &MessageHandler{}

var (
	RestHandlerInstance = &RestHandler{}
)

Functions

func InitHandler

func InitHandler()

func Process

func Process(module string)

Types

type Handle

type Handle func(interface{}) (interface{}, error)

type Listener

type Listener interface {
	AddListener(interface{}, Handle)
	RemoveListener(interface{})
}

type MessageHandler

type MessageHandler struct {
	// contains filtered or unexported fields
}

func (*MessageHandler) AddListener

func (mh *MessageHandler) AddListener(key interface{}, han Handle)

func (*MessageHandler) DelCallback

func (mh *MessageHandler) DelCallback(messageID string)

func (*MessageHandler) HandleMessage

func (mh *MessageHandler) HandleMessage(message *model.Message) error

func (*MessageHandler) RemoveListener

func (mh *MessageHandler) RemoveListener(key interface{})

func (*MessageHandler) SetCallback

func (mh *MessageHandler) SetCallback(messageID string, callback func(message *model.Message))

type RestHandler

type RestHandler struct {
	// contains filtered or unexported fields
}

func (*RestHandler) AddListener

func (rh *RestHandler) AddListener(key interface{}, han Handle)

func (*RestHandler) IsMatch

func (rh *RestHandler) IsMatch(key interface{}, message interface{}) bool

func (*RestHandler) RemoveListener

func (rh *RestHandler) RemoveListener(key interface{})

func (*RestHandler) Serve

func (rh *RestHandler) Serve()