totole/services
1
0
Fork 0
mirror of https://github.com/kevin-DL/services.git synced 2026-01-20 14:35:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

add debugging to events handler

Browse Source
This commit is contained in:
Asim Aslam
2022-02-27 21:42:01 +00:00
parent 26e3e518ca
commit 5649e567fe
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
event/handler/event.go
View File

@@ -103,7 +103,6 @@ func (s *Event) Read(ctx context.Context, req *pb.ReadRequest, rsp *pb.ReadRespo
// create tenant based topics // create tenant based topics
topic := path.Join("event", id, req.Topic) topic := path.Join("event", id, req.Topic)
log.Infof("Tenant %v reading %v\n", id, req.Topic)
limit := uint(25) limit := uint(25)
offset := uint(0) offset := uint(0)
@@ -115,11 +114,15 @@ func (s *Event) Read(ctx context.Context, req *pb.ReadRequest, rsp *pb.ReadRespo
offset = uint(req.Offset) offset = uint(req.Offset)
} }
log.Infof("Tenant %v reading %v limit: %v offset: %v\n", id, req.Topic, req.Limit, req.Offset)
events, err := events.Read(topic, events.ReadLimit(limit), events.ReadOffset(offset)) events, err := events.Read(topic, events.ReadLimit(limit), events.ReadOffset(offset))
if err != nil { if err != nil {
return err return err
} }
log.Infof("Events read %v", len(events))
for _, ev := range events { for _, ev := range events {
// unmarshal the message into a struct // unmarshal the message into a struct
d := &structpb.Struct{} d := &structpb.Struct{}