5
5
import grpclib .exceptions
6
6
if typing .TYPE_CHECKING :
7
7
import grpclib .server
8
+ from .... import app
8
9
from .... import common
9
10
import google .api .annotations_pb2
10
11
import google .protobuf .struct_pb2
@@ -20,8 +21,12 @@ async def Sync(self, stream: 'grpclib.server.Stream[service.datamanager.v1.data_
20
21
async def DoCommand (self , stream : 'grpclib.server.Stream[common.v1.common_pb2.DoCommandRequest, common.v1.common_pb2.DoCommandResponse]' ) -> None :
21
22
pass
22
23
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
+
23
28
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 ) }
25
30
26
31
class UnimplementedDataManagerServiceBase (DataManagerServiceBase ):
27
32
@@ -31,8 +36,12 @@ async def Sync(self, stream: 'grpclib.server.Stream[service.datamanager.v1.data_
31
36
async def DoCommand (self , stream : 'grpclib.server.Stream[common.v1.common_pb2.DoCommandRequest, common.v1.common_pb2.DoCommandResponse]' ) -> None :
32
37
raise grpclib .exceptions .GRPCError (grpclib .const .Status .UNIMPLEMENTED )
33
38
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
+
34
42
class DataManagerServiceStub :
35
43
36
44
def __init__ (self , channel : grpclib .client .Channel ) -> None :
37
45
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