Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AuthHandler ¶
type AuthHandler struct { }
func (*AuthHandler) ProcessInputMsg ¶
func (auth *AuthHandler) ProcessInputMsg(ctx context.Context, msg *internals.InputMsg)
type IMshHandler ¶
type InputConsumer ¶
type InputConsumer struct {
// contains filtered or unexported fields
}
consumes events that originated in the client api server.
func NewInputConsumer ¶
func NewInputConsumer( cfg *config.Dendrite, client *common.RpcClient, ) *InputConsumer
func (*InputConsumer) RegisterHandler ¶
func (s *InputConsumer) RegisterHandler(key int32, handler IMshHandler)
type InputRpcCB ¶
type InputRpcCB struct {
// contains filtered or unexported fields
}
func (*InputRpcCB) Clean ¶
func (i *InputRpcCB) Clean()
func (*InputRpcCB) GetCB ¶
func (i *InputRpcCB) GetCB() common.MsgHandlerWithContext
func (*InputRpcCB) GetTopic ¶
func (i *InputRpcCB) GetTopic() string
Click to show internal directories.
Click to hide internal directories.