Wire up caching for events

keyurva · keyurva · commit 856e8ee215bf · 2026-03-13T10:33:21.000-07:00
diff --git a/internal/server/redis/processor.go b/internal/server/redis/processor.go
@@ -85,6 +85,8 @@ func newEmptyResponse(requestType dispatcher.RequestType) (proto.Message, error)
 		return &pbv2.ResolveResponse{}, nil
 	case dispatcher.TypeSparql:
 		return &pb.QueryResponse{}, nil
+	case dispatcher.TypeEvent:
+		return &pbv2.EventResponse{}, nil
 	default:
 		return nil, fmt.Errorf("unknown request type for caching: %v", requestType)
 	}

Original file line number	Diff line number	Diff line change
`@@ -85,6 +85,8 @@ func newEmptyResponse(requestType dispatcher.RequestType) (proto.Message, error)`
`85`	`85`	`return &pbv2.ResolveResponse{}, nil`
`86`	`86`	`case dispatcher.TypeSparql:`
`87`	`87`	`return &pb.QueryResponse{}, nil`
	`88`	`+ case dispatcher.TypeEvent:`
	`89`	`+ return &pbv2.EventResponse{}, nil`
`88`	`90`	`default:`
`89`	`91`	`return nil, fmt.Errorf("unknown request type for caching: %v", requestType)`
`90`	`92`	`}`