mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-29 01:33:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add trace for new endpoints

Browse source
This commit is contained in:
Till Faelligen 2021-08-05 08:39:14 +02:00
parent 4b94f52ce4
commit 3e62a638b1
2 changed files with 24 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
setup/config/config_kafka.go
View file

@ -10,11 +10,8 @@ const (
TopicOutputRoomEvent = "OutputRoomEvent" TopicOutputRoomEvent = "OutputRoomEvent"
TopicOutputClientData = "OutputClientData" TopicOutputClientData = "OutputClientData"
TopicOutputReceiptEvent = "OutputReceiptEvent" TopicOutputReceiptEvent = "OutputReceiptEvent"
<<<<<<< HEAD
TopicOutputPresenceData = "OutputPresenceData" TopicOutputPresenceData = "OutputPresenceData"
=======
TopicOutputSigningKeyUpdate = "OutputSigningKeyUpdate" TopicOutputSigningKeyUpdate = "OutputSigningKeyUpdate"
>>>>>>> eb0efa46361ca2d80050ef871d0a8f20652398af
) )
type Kafka struct { type Kafka struct {

24
userapi/api/api_trace.go
View file

@ -116,6 +116,30 @@ func (t *UserInternalAPITrace) QueryOpenIDToken(ctx context.Context, req *QueryO
return err return err
} }
func (t *UserInternalAPITrace) InputPresenceData(ctx context.Context, req *InputPresenceRequest, res *InputPresenceResponse) error {
err := t.Impl.InputPresenceData(ctx, req, res)
util.GetLogger(ctx).Infof("InputPresenceData req=%+v res=%+v", js(req), js(res))
return err
}
func (t *UserInternalAPITrace) QueryPresenceForUser(ctx context.Context, req *QueryPresenceForUserRequest, res *QueryPresenceForUserResponse) error {
err := t.Impl.QueryPresenceForUser(ctx, req, res)
util.GetLogger(ctx).Infof("QueryPresenceForUser req=%+v res=%+v", js(req), js(res))
return err
}
func (t *UserInternalAPITrace) QueryPresenceAfter(ctx context.Context, req *QueryPresenceAfterRequest, res *QueryPresenceAfterResponse) error {
err := t.Impl.QueryPresenceAfter(ctx, req, res)
util.GetLogger(ctx).Infof("QueryPresenceAfter req=%+v res=%+v", js(req), js(res))
return err
}
func (t *UserInternalAPITrace) QueryMaxPresenceID(ctx context.Context, req *QueryMaxPresenceIDRequest, res *QueryMaxPresenceIDResponse) error {
err := t.Impl.QueryMaxPresenceID(ctx, req, res)
util.GetLogger(ctx).Infof("QueryMaxPresenceID req=%+v res=%+v", js(req), js(res))
return err
}
func js(thing interface{}) string { func js(thing interface{}) string {
b, err := json.Marshal(thing) b, err := json.Marshal(thing)
if err != nil { if err != nil {