Module connpy.grpc.remote_plugin_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

Functions

def add_RemotePluginServiceServicer_to_server(servicer, server)

Expand source code

def add_RemotePluginServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'get_plugin_source': grpc.unary_unary_rpc_method_handler(
                    servicer.get_plugin_source,
                    request_deserializer=remote__plugin__pb2.IdRequest.FromString,
                    response_serializer=remote__plugin__pb2.StringResponse.SerializeToString,
            ),
            'invoke_plugin': grpc.unary_stream_rpc_method_handler(
                    servicer.invoke_plugin,
                    request_deserializer=remote__plugin__pb2.PluginInvokeRequest.FromString,
                    response_serializer=remote__plugin__pb2.OutputChunk.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy_remote.RemotePluginService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy_remote.RemotePluginService', rpc_method_handlers)

Classes

class RemotePluginService

Expand source code

class RemotePluginService(object):
    """Missing associated documentation comment in .proto file."""

    @staticmethod
    def get_plugin_source(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(
            request,
            target,
            '/connpy_remote.RemotePluginService/get_plugin_source',
            remote__plugin__pb2.IdRequest.SerializeToString,
            remote__plugin__pb2.StringResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def invoke_plugin(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_stream(
            request,
            target,
            '/connpy_remote.RemotePluginService/invoke_plugin',
            remote__plugin__pb2.PluginInvokeRequest.SerializeToString,
            remote__plugin__pb2.OutputChunk.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

Missing associated documentation comment in .proto file.

Static methods

def get_plugin_source(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None)

Expand source code

@staticmethod
def get_plugin_source(request,
        target,
        options=(),
        channel_credentials=None,
        call_credentials=None,
        insecure=False,
        compression=None,
        wait_for_ready=None,
        timeout=None,
        metadata=None):
    return grpc.experimental.unary_unary(
        request,
        target,
        '/connpy_remote.RemotePluginService/get_plugin_source',
        remote__plugin__pb2.IdRequest.SerializeToString,
        remote__plugin__pb2.StringResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def invoke_plugin(request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
insecure=False,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None)

Expand source code

@staticmethod
def invoke_plugin(request,
        target,
        options=(),
        channel_credentials=None,
        call_credentials=None,
        insecure=False,
        compression=None,
        wait_for_ready=None,
        timeout=None,
        metadata=None):
    return grpc.experimental.unary_stream(
        request,
        target,
        '/connpy_remote.RemotePluginService/invoke_plugin',
        remote__plugin__pb2.PluginInvokeRequest.SerializeToString,
        remote__plugin__pb2.OutputChunk.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class RemotePluginServiceServicer

Expand source code

class RemotePluginServiceServicer(object):
    """Missing associated documentation comment in .proto file."""

    def get_plugin_source(self, request, 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!')

    def invoke_plugin(self, request, 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!')

Missing associated documentation comment in .proto file.

Subclasses

• PluginServicer

Methods

def get_plugin_source(self, request, context)

Expand source code

def get_plugin_source(self, request, 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!')

Missing associated documentation comment in .proto file.

def invoke_plugin(self, request, context)

Expand source code

def invoke_plugin(self, request, 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!')

Missing associated documentation comment in .proto file.

class RemotePluginServiceStub (channel)

Expand source code

class RemotePluginServiceStub(object):
    """Missing associated documentation comment in .proto file."""

    def __init__(self, channel):
        """Constructor.

        Args:
            channel: A grpc.Channel.
        """
        self.get_plugin_source = channel.unary_unary(
                '/connpy_remote.RemotePluginService/get_plugin_source',
                request_serializer=remote__plugin__pb2.IdRequest.SerializeToString,
                response_deserializer=remote__plugin__pb2.StringResponse.FromString,
                _registered_method=True)
        self.invoke_plugin = channel.unary_stream(
                '/connpy_remote.RemotePluginService/invoke_plugin',
                request_serializer=remote__plugin__pb2.PluginInvokeRequest.SerializeToString,
                response_deserializer=remote__plugin__pb2.OutputChunk.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.