@@ -26,6 +26,11 @@ def __init__(self, channel):
2626 request_serializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyRequest .SerializeToString ,
2727 response_deserializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorStreamResponse .FromString ,
2828 )
29+ self .DailyVectorKeyStream = channel .unary_stream (
30+ '/systemathics.apis.services.daily.v2.DailyService/DailyVectorKeyStream' ,
31+ request_serializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorKeyRequest .SerializeToString ,
32+ response_deserializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorStreamResponse .FromString ,
33+ )
2934 self .DailyFields = channel .unary_unary (
3035 '/systemathics.apis.services.daily.v2.DailyService/DailyFields' ,
3136 request_serializer = google_dot_protobuf_dot_empty__pb2 .Empty .SerializeToString ,
@@ -56,6 +61,13 @@ def DailyVectorStream(self, request, context):
5661 context .set_details ('Method not implemented!' )
5762 raise NotImplementedError ('Method not implemented!' )
5863
64+ def DailyVectorKeyStream (self , request , context ):
65+ """Gets daily historical data timeseries by identifier and key using streaming
66+ """
67+ context .set_code (grpc .StatusCode .UNIMPLEMENTED )
68+ context .set_details ('Method not implemented!' )
69+ raise NotImplementedError ('Method not implemented!' )
70+
5971 def DailyFields (self , request , context ):
6072 """Gets all available fields by asset and provider.
6173 """
@@ -83,6 +95,11 @@ def add_DailyServiceServicer_to_server(servicer, server):
8395 request_deserializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyRequest .FromString ,
8496 response_serializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorStreamResponse .SerializeToString ,
8597 ),
98+ 'DailyVectorKeyStream' : grpc .unary_stream_rpc_method_handler (
99+ servicer .DailyVectorKeyStream ,
100+ request_deserializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorKeyRequest .FromString ,
101+ response_serializer = systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorStreamResponse .SerializeToString ,
102+ ),
86103 'DailyFields' : grpc .unary_unary_rpc_method_handler (
87104 servicer .DailyFields ,
88105 request_deserializer = google_dot_protobuf_dot_empty__pb2 .Empty .FromString ,
@@ -138,6 +155,23 @@ def DailyVectorStream(request,
138155 options , channel_credentials ,
139156 insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
140157
158+ @staticmethod
159+ def DailyVectorKeyStream (request ,
160+ target ,
161+ options = (),
162+ channel_credentials = None ,
163+ call_credentials = None ,
164+ insecure = False ,
165+ compression = None ,
166+ wait_for_ready = None ,
167+ timeout = None ,
168+ metadata = None ):
169+ return grpc .experimental .unary_stream (request , target , '/systemathics.apis.services.daily.v2.DailyService/DailyVectorKeyStream' ,
170+ systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorKeyRequest .SerializeToString ,
171+ systemathics_dot_apis_dot_services_dot_daily_dot_v2_dot_get__daily__pb2 .DailyVectorStreamResponse .FromString ,
172+ options , channel_credentials ,
173+ insecure , call_credentials , compression , wait_for_ready , timeout , metadata )
174+
141175 @staticmethod
142176 def DailyFields (request ,
143177 target ,
0 commit comments