[FEATURE]: Added streaming support to services (#22)

OddDotNet · Feb 12, 2025 · 04d118e · 04d118e
1 parent e964272
commit 04d118e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/odddotproto/proto/logs/v1/log_query_service.proto b/odddotproto/proto/logs/v1/log_query_service.proto
@@ -4,6 +4,7 @@ package odddotnet.proto.logs.v1;
 
 import "odddotproto/proto/logs/v1/log_query_request.proto";
 import "odddotproto/proto/logs/v1/log_query_response.proto";
+import "odddotproto/proto/logs/v1/flat_log.proto";
 
 option csharp_namespace = "OddDotNet.Proto.Logs.V1";
 option java_multiple_files = true;
@@ -13,4 +14,5 @@ option go_package = "go.odddotnet.io/proto/otlp/logs/v1";
 
 service LogQueryService {
   rpc Query(LogQueryRequest) returns (LogQueryResponse);
+  rpc StreamQuery(LogQueryRequest) returns (stream FlatLog);
 }
diff --git a/odddotproto/proto/metrics/v1/metric_query_service.proto b/odddotproto/proto/metrics/v1/metric_query_service.proto
@@ -4,6 +4,7 @@ package odddotnet.proto.metrics.v1;
 
 import "odddotproto/proto/metrics/v1/metric_query_request.proto";
 import "odddotproto/proto/metrics/v1/metric_query_response.proto";
+import "odddotproto/proto/metrics/v1/flat_metric.proto";
 
 option csharp_namespace = "OddDotNet.Proto.Metrics.V1";
 option java_multiple_files = true;
@@ -13,4 +14,5 @@ option go_package = "go.odddotnet.io/proto/otlp/metrics/v1";
 
 service MetricQueryService {
   rpc Query(MetricQueryRequest) returns (MetricQueryResponse);
+  rpc StreamQuery(MetricQueryRequest) returns (stream FlatMetric);
 }
diff --git a/odddotproto/proto/trace/v1/span_query_service.proto b/odddotproto/proto/trace/v1/span_query_service.proto
@@ -6,6 +6,7 @@ import "odddotproto/proto/trace/v1/span_query_request.proto";
 import "odddotproto/proto/trace/v1/span_query_response.proto";
 import "odddotproto/proto/trace/v1/span_reset_request.proto";
 import "odddotproto/proto/trace/v1/span_reset_response.proto";
+import "odddotproto/proto/trace/v1/flat_span.proto";
 
 option csharp_namespace = "OddDotNet.Proto.Trace.V1";
 option java_multiple_files = true;
@@ -15,5 +16,6 @@ option go_package = "go.odddotnet.io/proto/otlp/trace/v1";
 
 service SpanQueryService {
   rpc Query(SpanQueryRequest) returns (SpanQueryResponse);
+  rpc StreamQuery(SpanQueryRequest) returns (stream FlatSpan);
   rpc Reset(SpanResetRequest) returns (SpanResetResponse); 
 }