Documentation ¶
Index ¶
- type InternalMsgConsumer
- type ReqPostClaimKey
- func (ReqPostClaimKey) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error
- func (ReqPostClaimKey) GetAPIType() int8
- func (ReqPostClaimKey) GetMethod() []string
- func (ReqPostClaimKey) GetMetricsName() string
- func (ReqPostClaimKey) GetMsgType() int32
- func (ReqPostClaimKey) GetPrefix() []string
- func (ReqPostClaimKey) GetRoute() string
- func (ReqPostClaimKey) GetTopic(cfg *config.Dendrite) string
- func (ReqPostClaimKey) NewRequest() core.Coder
- func (ReqPostClaimKey) NewResponse(code int) core.Coder
- func (ReqPostClaimKey) Process(ctx context.Context, consumer interface{}, msg core.Coder, ...) (int, core.Coder)
- type ReqPostQueryKey
- func (ReqPostQueryKey) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error
- func (ReqPostQueryKey) GetAPIType() int8
- func (ReqPostQueryKey) GetMethod() []string
- func (ReqPostQueryKey) GetMetricsName() string
- func (ReqPostQueryKey) GetMsgType() int32
- func (ReqPostQueryKey) GetPrefix() []string
- func (ReqPostQueryKey) GetRoute() string
- func (ReqPostQueryKey) GetTopic(cfg *config.Dendrite) string
- func (ReqPostQueryKey) NewRequest() core.Coder
- func (ReqPostQueryKey) NewResponse(code int) core.Coder
- func (ReqPostQueryKey) Process(ctx context.Context, consumer interface{}, msg core.Coder, ...) (int, core.Coder)
- type ReqPostUploadKey
- func (ReqPostUploadKey) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error
- func (ReqPostUploadKey) GetAPIType() int8
- func (ReqPostUploadKey) GetMethod() []string
- func (ReqPostUploadKey) GetMetricsName() string
- func (ReqPostUploadKey) GetMsgType() int32
- func (ReqPostUploadKey) GetPrefix() []string
- func (ReqPostUploadKey) GetRoute() string
- func (ReqPostUploadKey) GetTopic(cfg *config.Dendrite) string
- func (ReqPostUploadKey) NewRequest() core.Coder
- func (ReqPostUploadKey) NewResponse(code int) core.Coder
- func (ReqPostUploadKey) Process(ctx context.Context, consumer interface{}, msg core.Coder, ...) (int, core.Coder)
- type ReqPostUploadKeyByDeviceID
- func (ReqPostUploadKeyByDeviceID) FillRequest(coder core.Coder, req *http.Request, vars map[string]string) error
- func (ReqPostUploadKeyByDeviceID) GetAPIType() int8
- func (ReqPostUploadKeyByDeviceID) GetMethod() []string
- func (ReqPostUploadKeyByDeviceID) GetMetricsName() string
- func (ReqPostUploadKeyByDeviceID) GetMsgType() int32
- func (ReqPostUploadKeyByDeviceID) GetPrefix() []string
- func (ReqPostUploadKeyByDeviceID) GetRoute() string
- func (ReqPostUploadKeyByDeviceID) GetTopic(cfg *config.Dendrite) string
- func (ReqPostUploadKeyByDeviceID) NewRequest() core.Coder
- func (ReqPostUploadKeyByDeviceID) NewResponse(code int) core.Coder
- func (ReqPostUploadKeyByDeviceID) Process(ctx context.Context, consumer interface{}, msg core.Coder, ...) (int, core.Coder)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type InternalMsgConsumer ¶
type InternalMsgConsumer struct { apiconsumer.APIConsumer // contains filtered or unexported fields }
func NewInternalMsgConsumer ¶
func NewInternalMsgConsumer( cfg config.Dendrite, encryptionDB model.EncryptorAPIDatabase, syncDB model.SyncAPIDatabase, idg *uid.UidGenerator, cache service.Cache, rpcCli *common.RpcClient, federation *gomatrixserverlib.FederationClient, serverName []string, ) *InternalMsgConsumer
func (*InternalMsgConsumer) Start ¶
func (c *InternalMsgConsumer) Start()
type ReqPostClaimKey ¶
type ReqPostClaimKey struct{}
func (ReqPostClaimKey) FillRequest ¶
func (ReqPostClaimKey) GetAPIType ¶
func (ReqPostClaimKey) GetAPIType() int8
func (ReqPostClaimKey) GetMethod ¶
func (ReqPostClaimKey) GetMethod() []string
func (ReqPostClaimKey) GetMetricsName ¶
func (ReqPostClaimKey) GetMetricsName() string
func (ReqPostClaimKey) GetMsgType ¶
func (ReqPostClaimKey) GetMsgType() int32
func (ReqPostClaimKey) GetPrefix ¶
func (ReqPostClaimKey) GetPrefix() []string
func (ReqPostClaimKey) GetRoute ¶
func (ReqPostClaimKey) GetRoute() string
func (ReqPostClaimKey) NewRequest ¶
func (ReqPostClaimKey) NewRequest() core.Coder
func (ReqPostClaimKey) NewResponse ¶
func (ReqPostClaimKey) NewResponse(code int) core.Coder
type ReqPostQueryKey ¶
type ReqPostQueryKey struct{}
func (ReqPostQueryKey) FillRequest ¶
func (ReqPostQueryKey) GetAPIType ¶
func (ReqPostQueryKey) GetAPIType() int8
func (ReqPostQueryKey) GetMethod ¶
func (ReqPostQueryKey) GetMethod() []string
func (ReqPostQueryKey) GetMetricsName ¶
func (ReqPostQueryKey) GetMetricsName() string
func (ReqPostQueryKey) GetMsgType ¶
func (ReqPostQueryKey) GetMsgType() int32
func (ReqPostQueryKey) GetPrefix ¶
func (ReqPostQueryKey) GetPrefix() []string
func (ReqPostQueryKey) GetRoute ¶
func (ReqPostQueryKey) GetRoute() string
func (ReqPostQueryKey) NewRequest ¶
func (ReqPostQueryKey) NewRequest() core.Coder
func (ReqPostQueryKey) NewResponse ¶
func (ReqPostQueryKey) NewResponse(code int) core.Coder
type ReqPostUploadKey ¶
type ReqPostUploadKey struct{}
func (ReqPostUploadKey) FillRequest ¶
func (ReqPostUploadKey) GetAPIType ¶
func (ReqPostUploadKey) GetAPIType() int8
func (ReqPostUploadKey) GetMethod ¶
func (ReqPostUploadKey) GetMethod() []string
func (ReqPostUploadKey) GetMetricsName ¶
func (ReqPostUploadKey) GetMetricsName() string
func (ReqPostUploadKey) GetMsgType ¶
func (ReqPostUploadKey) GetMsgType() int32
func (ReqPostUploadKey) GetPrefix ¶
func (ReqPostUploadKey) GetPrefix() []string
func (ReqPostUploadKey) GetRoute ¶
func (ReqPostUploadKey) GetRoute() string
func (ReqPostUploadKey) NewRequest ¶
func (ReqPostUploadKey) NewRequest() core.Coder
func (ReqPostUploadKey) NewResponse ¶
func (ReqPostUploadKey) NewResponse(code int) core.Coder
type ReqPostUploadKeyByDeviceID ¶
type ReqPostUploadKeyByDeviceID struct{}
func (ReqPostUploadKeyByDeviceID) FillRequest ¶
func (ReqPostUploadKeyByDeviceID) GetAPIType ¶
func (ReqPostUploadKeyByDeviceID) GetAPIType() int8
func (ReqPostUploadKeyByDeviceID) GetMethod ¶
func (ReqPostUploadKeyByDeviceID) GetMethod() []string
func (ReqPostUploadKeyByDeviceID) GetMetricsName ¶
func (ReqPostUploadKeyByDeviceID) GetMetricsName() string
func (ReqPostUploadKeyByDeviceID) GetMsgType ¶
func (ReqPostUploadKeyByDeviceID) GetMsgType() int32
func (ReqPostUploadKeyByDeviceID) GetPrefix ¶
func (ReqPostUploadKeyByDeviceID) GetPrefix() []string
func (ReqPostUploadKeyByDeviceID) GetRoute ¶
func (ReqPostUploadKeyByDeviceID) GetRoute() string
func (ReqPostUploadKeyByDeviceID) GetTopic ¶
func (ReqPostUploadKeyByDeviceID) GetTopic(cfg *config.Dendrite) string
func (ReqPostUploadKeyByDeviceID) NewRequest ¶
func (ReqPostUploadKeyByDeviceID) NewRequest() core.Coder
func (ReqPostUploadKeyByDeviceID) NewResponse ¶
func (ReqPostUploadKeyByDeviceID) NewResponse(code int) core.Coder
Click to show internal directories.
Click to hide internal directories.