55import grpclib .exceptions
66if typing .TYPE_CHECKING :
77 import grpclib .server
8+ from .... import app
89from .... import common
910import google .api .annotations_pb2
1011import google .protobuf .struct_pb2
@@ -20,8 +21,12 @@ async def Sync(self, stream: 'grpclib.server.Stream[service.datamanager.v1.data_
2021 async def DoCommand (self , stream : 'grpclib.server.Stream[common.v1.common_pb2.DoCommandRequest, common.v1.common_pb2.DoCommandResponse]' ) -> None :
2122 pass
2223
24+ @abc .abstractmethod
25+ async def UploadBinaryDataToDatasets (self , stream : 'grpclib.server.Stream[service.datamanager.v1.data_manager_pb2.UploadBinaryDataToDatasetsRequest, service.datamanager.v1.data_manager_pb2.UploadBinaryDataToDatasetsResponse]' ) -> None :
26+ pass
27+
2328 def __mapping__ (self ) -> typing .Dict [str , grpclib .const .Handler ]:
24- return {'/viam.service.datamanager.v1.DataManagerService/Sync' : grpclib .const .Handler (self .Sync , grpclib .const .Cardinality .UNARY_UNARY , service .datamanager .v1 .data_manager_pb2 .SyncRequest , service .datamanager .v1 .data_manager_pb2 .SyncResponse ), '/viam.service.datamanager.v1.DataManagerService/DoCommand' : grpclib .const .Handler (self .DoCommand , grpclib .const .Cardinality .UNARY_UNARY , common .v1 .common_pb2 .DoCommandRequest , common .v1 .common_pb2 .DoCommandResponse )}
29+ return {'/viam.service.datamanager.v1.DataManagerService/Sync' : grpclib .const .Handler (self .Sync , grpclib .const .Cardinality .UNARY_UNARY , service .datamanager .v1 .data_manager_pb2 .SyncRequest , service .datamanager .v1 .data_manager_pb2 .SyncResponse ), '/viam.service.datamanager.v1.DataManagerService/DoCommand' : grpclib .const .Handler (self .DoCommand , grpclib .const .Cardinality .UNARY_UNARY , common .v1 .common_pb2 .DoCommandRequest , common .v1 .common_pb2 .DoCommandResponse ), '/viam.service.datamanager.v1.DataManagerService/UploadBinaryDataToDatasets' : grpclib . const . Handler ( self . UploadBinaryDataToDatasets , grpclib . const . Cardinality . UNARY_UNARY , service . datamanager . v1 . data_manager_pb2 . UploadBinaryDataToDatasetsRequest , service . datamanager . v1 . data_manager_pb2 . UploadBinaryDataToDatasetsResponse ) }
2530
2631class UnimplementedDataManagerServiceBase (DataManagerServiceBase ):
2732
@@ -31,8 +36,12 @@ async def Sync(self, stream: 'grpclib.server.Stream[service.datamanager.v1.data_
3136 async def DoCommand (self , stream : 'grpclib.server.Stream[common.v1.common_pb2.DoCommandRequest, common.v1.common_pb2.DoCommandResponse]' ) -> None :
3237 raise grpclib .exceptions .GRPCError (grpclib .const .Status .UNIMPLEMENTED )
3338
39+ async def UploadBinaryDataToDatasets (self , stream : 'grpclib.server.Stream[service.datamanager.v1.data_manager_pb2.UploadBinaryDataToDatasetsRequest, service.datamanager.v1.data_manager_pb2.UploadBinaryDataToDatasetsResponse]' ) -> None :
40+ raise grpclib .exceptions .GRPCError (grpclib .const .Status .UNIMPLEMENTED )
41+
3442class DataManagerServiceStub :
3543
3644 def __init__ (self , channel : grpclib .client .Channel ) -> None :
3745 self .Sync = grpclib .client .UnaryUnaryMethod (channel , '/viam.service.datamanager.v1.DataManagerService/Sync' , service .datamanager .v1 .data_manager_pb2 .SyncRequest , service .datamanager .v1 .data_manager_pb2 .SyncResponse )
38- self .DoCommand = grpclib .client .UnaryUnaryMethod (channel , '/viam.service.datamanager.v1.DataManagerService/DoCommand' , common .v1 .common_pb2 .DoCommandRequest , common .v1 .common_pb2 .DoCommandResponse )
46+ self .DoCommand = grpclib .client .UnaryUnaryMethod (channel , '/viam.service.datamanager.v1.DataManagerService/DoCommand' , common .v1 .common_pb2 .DoCommandRequest , common .v1 .common_pb2 .DoCommandResponse )
47+ self .UploadBinaryDataToDatasets = grpclib .client .UnaryUnaryMethod (channel , '/viam.service.datamanager.v1.DataManagerService/UploadBinaryDataToDatasets' , service .datamanager .v1 .data_manager_pb2 .UploadBinaryDataToDatasetsRequest , service .datamanager .v1 .data_manager_pb2 .UploadBinaryDataToDatasetsResponse )
0 commit comments