in python-sdk/src/airavata_mft_sdk/MFTTransferApi_pb2_grpc.py [0:0]
def add_MFTTransferServiceServicer_to_server(servicer, server):
rpc_method_handlers = {
'submitTransfer': grpc.unary_unary_rpc_method_handler(
servicer.submitTransfer,
request_deserializer=MFTTransferApi__pb2.TransferApiRequest.FromString,
response_serializer=MFTTransferApi__pb2.TransferApiResponse.SerializeToString,
),
'getAllTransferStates': grpc.unary_stream_rpc_method_handler(
servicer.getAllTransferStates,
request_deserializer=MFTTransferApi__pb2.TransferStateApiRequest.FromString,
response_serializer=MFTTransferApi__pb2.TransferStateResponse.SerializeToString,
),
'getTransferStateSummary': grpc.unary_unary_rpc_method_handler(
servicer.getTransferStateSummary,
request_deserializer=MFTTransferApi__pb2.TransferStateApiRequest.FromString,
response_serializer=MFTTransferApi__pb2.TransferStateSummaryResponse.SerializeToString,
),
'getResourceAvailability': grpc.unary_unary_rpc_method_handler(
servicer.getResourceAvailability,
request_deserializer=MFTTransferApi__pb2.FetchResourceMetadataRequest.FromString,
response_serializer=MFTTransferApi__pb2.ResourceAvailabilityResponse.SerializeToString,
),
'resourceMetadata': grpc.unary_unary_rpc_method_handler(
servicer.resourceMetadata,
request_deserializer=MFTTransferApi__pb2.FetchResourceMetadataRequest.FromString,
response_serializer=MFTAgentStubs__pb2.ResourceMetadata.SerializeToString,
),
'removeTransfer': grpc.unary_unary_rpc_method_handler(
servicer.removeTransfer,
request_deserializer=MFTTransferApi__pb2.TransferRemoveRequest.FromString,
response_serializer=MFTTransferApi__pb2.TransferRemoveResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'org.apache.airavata.mft.api.service.MFTTransferService', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))