diff options
| author | Kegsay <kegan@matrix.org> | 2020-06-12 12:10:08 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-06-12 12:10:08 +0100 |
| commit | 4675e1ddb6a48fe1425032dc4f3cef56cbde7243 (patch) | |
| tree | c1f900ab4bf0a4fadc7ca81ba614977f4a973f29 /syncapi | |
| parent | 079d8fe8fb521f76fee3bff5b47482d5fb911257 (diff) | |
Add trace logging to RoomserverInternalAPI (#1120)
This is a wrapper around whatever impl we have which then logs
the function name/request/response/error.
Also tweak when we log on kafka streams: only log on the producer
side not the consumer side: we've never had issues with comms and
having 1 message rather than N would be nice.
Diffstat (limited to 'syncapi')
| -rw-r--r-- | syncapi/consumers/roomserver.go | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/syncapi/consumers/roomserver.go b/syncapi/consumers/roomserver.go index 13597682..98be5bb7 100644 --- a/syncapi/consumers/roomserver.go +++ b/syncapi/consumers/roomserver.go @@ -98,11 +98,6 @@ func (s *OutputRoomEventConsumer) onNewRoomEvent( ctx context.Context, msg api.OutputNewRoomEvent, ) error { ev := msg.Event - log.WithFields(log.Fields{ - "event_id": ev.EventID(), - "room_id": ev.RoomID(), - "room_version": ev.RoomVersion, - }).Info("received event from roomserver") addsStateEvents := msg.AddsState() |