'Protobuf files change'

systemathics · Dec 3, 2024 · 963f7f6 · 963f7f6
1 parent 1099f01
commit 963f7f6
Show file tree

Hide file tree

Showing 4 changed files with 118 additions and 42 deletions.
diff --git a/src/systemathics/apis/services/daily/v2/get_daily_pb2.py b/src/systemathics/apis/services/daily/v2/get_daily_pb2.py
diff --git a/src/systemathics/apis/services/daily/v2/get_daily_pb2_grpc.py b/src/systemathics/apis/services/daily/v2/get_daily_pb2_grpc.py
@@ -26,6 +26,11 @@ def __init__(self, channel):
                 request_serializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyRequest.SerializeToString,
                 response_deserializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorStreamResponse.FromString,
                 )
+        self.DailyVectorKeyStream = channel.unary_stream(
+                '/systemathics.apis.services.daily.v2.DailyService/DailyVectorKeyStream',
+                request_serializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorKeyRequest.SerializeToString,
+                response_deserializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorStreamResponse.FromString,
+                )
         self.DailyFields = channel.unary_unary(
                 '/systemathics.apis.services.daily.v2.DailyService/DailyFields',
                 request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
@@ -56,6 +61,13 @@ def DailyVectorStream(self, request, context):
         context.set_details('Method not implemented!')
         raise NotImplementedError('Method not implemented!')
 
+    def DailyVectorKeyStream(self, request, context):
+        """Gets daily historical data timeseries by identifier and key using streaming
+        """
+        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
+        context.set_details('Method not implemented!')
+        raise NotImplementedError('Method not implemented!')
+
     def DailyFields(self, request, context):
         """Gets all available fields by asset and provider.
         """
@@ -83,6 +95,11 @@ def add_DailyServiceServicer_to_server(servicer, server):
                     request_deserializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyRequest.FromString,
                     response_serializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorStreamResponse.SerializeToString,
             ),
+            'DailyVectorKeyStream': grpc.unary_stream_rpc_method_handler(
+                    servicer.DailyVectorKeyStream,
+                    request_deserializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorKeyRequest.FromString,
+                    response_serializer=systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorStreamResponse.SerializeToString,
+            ),
             'DailyFields': grpc.unary_unary_rpc_method_handler(
                     servicer.DailyFields,
                     request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
@@ -138,6 +155,23 @@ def DailyVectorStream(request,
             options, channel_credentials,
             insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
 
+    @staticmethod
+    def DailyVectorKeyStream(request,
+            target,
+            options=(),
+            channel_credentials=None,
+            call_credentials=None,
+            insecure=False,
+            compression=None,
+            wait_for_ready=None,
+            timeout=None,
+            metadata=None):
+        return grpc.experimental.unary_stream(request, target, '/systemathics.apis.services.daily.v2.DailyService/DailyVectorKeyStream',
+            systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorKeyRequest.SerializeToString,
+            systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2.DailyVectorStreamResponse.FromString,
+            options, channel_credentials,
+            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
+
     @staticmethod
     def DailyFields(request,
             target,