messaging

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

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

type HandlerFunc func(cliInfo *gate.Info, message *messages.GlideMessage) error

type Interface interface {

	// Handle handles message from gate, the entry point for the messaging.
	Handle(clientInfo *gate.Info, msg *messages.GlideMessage) error

	AddHandler(i MessageHandler)
}

type MessageHandler interface {
	// Handle handles the message, returns true if the message is handled,
	// otherwise the message is delegated to next handler.
	Handle(h *MessageInterfaceImpl, cliInfo *gate.Info, message *messages.GlideMessage) bool
}

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

type Messaging interface {
	Interface

	SetSubscription(g subscription.Interface)

	SetGate(g gate.Gateway)
}

type ReplyHandlerFunc func(cliInfo *gate.Info, message *messages.GlideMessage) (*messages.GlideMessage, error)

type Server interface {
	Messaging

	Run() error
}