Source code for ayx_python_sdk.providers.amp_provider.resources.generated.sdk_tool_service_v2_pb2_grpc

# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc

from . import sdk_tool_service_v2_pb2 as sdk__tool__service__v2__pb2


[docs]class SdkToolV2Stub(object): """Missing associated documentation comment in .proto file.""" def __init__(self, channel): """Constructor. Args: channel: A grpc.Channel. """ self.Control = channel.stream_stream( '/sdk.SdkToolV2/Control', request_serializer=sdk__tool__service__v2__pb2.ControlIn.SerializeToString, response_deserializer=sdk__tool__service__v2__pb2.ControlOut.FromString, ) self.RecordTransfer = channel.stream_stream( '/sdk.SdkToolV2/RecordTransfer', request_serializer=sdk__tool__service__v2__pb2.RecordTransferIn.SerializeToString, response_deserializer=sdk__tool__service__v2__pb2.RecordTransferOut.FromString, )
[docs]class SdkToolV2Servicer(object): """Missing associated documentation comment in .proto file."""
[docs] def Control(self, request_iterator, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!')
[docs] def RecordTransfer(self, request_iterator, context): """Missing associated documentation comment in .proto file.""" context.set_code(grpc.StatusCode.UNIMPLEMENTED) context.set_details('Method not implemented!') raise NotImplementedError('Method not implemented!')
[docs]def add_SdkToolV2Servicer_to_server(servicer, server): rpc_method_handlers = { 'Control': grpc.stream_stream_rpc_method_handler( servicer.Control, request_deserializer=sdk__tool__service__v2__pb2.ControlIn.FromString, response_serializer=sdk__tool__service__v2__pb2.ControlOut.SerializeToString, ), 'RecordTransfer': grpc.stream_stream_rpc_method_handler( servicer.RecordTransfer, request_deserializer=sdk__tool__service__v2__pb2.RecordTransferIn.FromString, response_serializer=sdk__tool__service__v2__pb2.RecordTransferOut.SerializeToString, ), } generic_handler = grpc.method_handlers_generic_handler( 'sdk.SdkToolV2', rpc_method_handlers) server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class SdkToolV2(object): """Missing associated documentation comment in .proto file."""
[docs] @staticmethod def Control(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): return grpc.experimental.stream_stream(request_iterator, target, '/sdk.SdkToolV2/Control', sdk__tool__service__v2__pb2.ControlIn.SerializeToString, sdk__tool__service__v2__pb2.ControlOut.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs] @staticmethod def RecordTransfer(request_iterator, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None): return grpc.experimental.stream_stream(request_iterator, target, '/sdk.SdkToolV2/RecordTransfer', sdk__tool__service__v2__pb2.RecordTransferIn.SerializeToString, sdk__tool__service__v2__pb2.RecordTransferOut.FromString, options, channel_credentials, insecure, call_credentials, compression, wait_for_ready, timeout, metadata)