Module connpy.grpc_layer.connpy_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

Functions

def add_AIServiceServicer_to_server(servicer, server)

Expand source code

def add_AIServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'ask': grpc.stream_stream_rpc_method_handler(
                    servicer.ask,
                    request_deserializer=connpy__pb2.AskRequest.FromString,
                    response_serializer=connpy__pb2.AIResponse.SerializeToString,
            ),
            'confirm': grpc.unary_unary_rpc_method_handler(
                    servicer.confirm,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=connpy__pb2.BoolResponse.SerializeToString,
            ),
            'list_sessions': grpc.unary_unary_rpc_method_handler(
                    servicer.list_sessions,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=connpy__pb2.ValueResponse.SerializeToString,
            ),
            'delete_session': grpc.unary_unary_rpc_method_handler(
                    servicer.delete_session,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'configure_provider': grpc.unary_unary_rpc_method_handler(
                    servicer.configure_provider,
                    request_deserializer=connpy__pb2.ProviderRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'load_session_data': grpc.unary_unary_rpc_method_handler(
                    servicer.load_session_data,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.AIService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.AIService', rpc_method_handlers)

def add_ConfigServiceServicer_to_server(servicer, server)

Expand source code

def add_ConfigServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'get_settings': grpc.unary_unary_rpc_method_handler(
                    servicer.get_settings,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
            'get_default_dir': grpc.unary_unary_rpc_method_handler(
                    servicer.get_default_dir,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=connpy__pb2.StringResponse.SerializeToString,
            ),
            'set_config_folder': grpc.unary_unary_rpc_method_handler(
                    servicer.set_config_folder,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'update_setting': grpc.unary_unary_rpc_method_handler(
                    servicer.update_setting,
                    request_deserializer=connpy__pb2.UpdateRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'encrypt_password': grpc.unary_unary_rpc_method_handler(
                    servicer.encrypt_password,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=connpy__pb2.StringResponse.SerializeToString,
            ),
            'apply_theme_from_file': grpc.unary_unary_rpc_method_handler(
                    servicer.apply_theme_from_file,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.ConfigService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.ConfigService', rpc_method_handlers)

def add_ExecutionServiceServicer_to_server(servicer, server)

Expand source code

def add_ExecutionServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'run_commands': grpc.unary_stream_rpc_method_handler(
                    servicer.run_commands,
                    request_deserializer=connpy__pb2.RunRequest.FromString,
                    response_serializer=connpy__pb2.NodeRunResult.SerializeToString,
            ),
            'test_commands': grpc.unary_stream_rpc_method_handler(
                    servicer.test_commands,
                    request_deserializer=connpy__pb2.TestRequest.FromString,
                    response_serializer=connpy__pb2.NodeRunResult.SerializeToString,
            ),
            'run_cli_script': grpc.unary_unary_rpc_method_handler(
                    servicer.run_cli_script,
                    request_deserializer=connpy__pb2.ScriptRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
            'run_yaml_playbook': grpc.unary_unary_rpc_method_handler(
                    servicer.run_yaml_playbook,
                    request_deserializer=connpy__pb2.ScriptRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.ExecutionService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.ExecutionService', rpc_method_handlers)

def add_ImportExportServiceServicer_to_server(servicer, server)

Expand source code

def add_ImportExportServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'export_to_file': grpc.unary_unary_rpc_method_handler(
                    servicer.export_to_file,
                    request_deserializer=connpy__pb2.ExportRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'import_from_file': grpc.unary_unary_rpc_method_handler(
                    servicer.import_from_file,
                    request_deserializer=connpy__pb2.StringRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'set_reserved_names': grpc.unary_unary_rpc_method_handler(
                    servicer.set_reserved_names,
                    request_deserializer=connpy__pb2.ListRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.ImportExportService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.ImportExportService', rpc_method_handlers)

def add_NodeServiceServicer_to_server(servicer, server)

Expand source code

def add_NodeServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'list_nodes': grpc.unary_unary_rpc_method_handler(
                    servicer.list_nodes,
                    request_deserializer=connpy__pb2.FilterRequest.FromString,
                    response_serializer=connpy__pb2.ValueResponse.SerializeToString,
            ),
            'list_folders': grpc.unary_unary_rpc_method_handler(
                    servicer.list_folders,
                    request_deserializer=connpy__pb2.FilterRequest.FromString,
                    response_serializer=connpy__pb2.ValueResponse.SerializeToString,
            ),
            'get_node_details': grpc.unary_unary_rpc_method_handler(
                    servicer.get_node_details,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
            'explode_unique': grpc.unary_unary_rpc_method_handler(
                    servicer.explode_unique,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=connpy__pb2.ValueResponse.SerializeToString,
            ),
            'generate_cache': grpc.unary_unary_rpc_method_handler(
                    servicer.generate_cache,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'add_node': grpc.unary_unary_rpc_method_handler(
                    servicer.add_node,
                    request_deserializer=connpy__pb2.NodeRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'update_node': grpc.unary_unary_rpc_method_handler(
                    servicer.update_node,
                    request_deserializer=connpy__pb2.NodeRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'delete_node': grpc.unary_unary_rpc_method_handler(
                    servicer.delete_node,
                    request_deserializer=connpy__pb2.DeleteRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'move_node': grpc.unary_unary_rpc_method_handler(
                    servicer.move_node,
                    request_deserializer=connpy__pb2.MoveRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'bulk_add': grpc.unary_unary_rpc_method_handler(
                    servicer.bulk_add,
                    request_deserializer=connpy__pb2.BulkRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'validate_parent_folder': grpc.unary_unary_rpc_method_handler(
                    servicer.validate_parent_folder,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'set_reserved_names': grpc.unary_unary_rpc_method_handler(
                    servicer.set_reserved_names,
                    request_deserializer=connpy__pb2.ListRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'interact_node': grpc.stream_stream_rpc_method_handler(
                    servicer.interact_node,
                    request_deserializer=connpy__pb2.InteractRequest.FromString,
                    response_serializer=connpy__pb2.InteractResponse.SerializeToString,
            ),
            'full_replace': grpc.unary_unary_rpc_method_handler(
                    servicer.full_replace,
                    request_deserializer=connpy__pb2.FullReplaceRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'get_inventory': grpc.unary_unary_rpc_method_handler(
                    servicer.get_inventory,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=connpy__pb2.FullReplaceRequest.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.NodeService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.NodeService', rpc_method_handlers)

def add_PluginServiceServicer_to_server(servicer, server)

Expand source code

def add_PluginServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'list_plugins': grpc.unary_unary_rpc_method_handler(
                    servicer.list_plugins,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=connpy__pb2.ValueResponse.SerializeToString,
            ),
            'add_plugin': grpc.unary_unary_rpc_method_handler(
                    servicer.add_plugin,
                    request_deserializer=connpy__pb2.PluginRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'delete_plugin': grpc.unary_unary_rpc_method_handler(
                    servicer.delete_plugin,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'enable_plugin': grpc.unary_unary_rpc_method_handler(
                    servicer.enable_plugin,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'disable_plugin': grpc.unary_unary_rpc_method_handler(
                    servicer.disable_plugin,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.PluginService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.PluginService', rpc_method_handlers)

def add_ProfileServiceServicer_to_server(servicer, server)

Expand source code

def add_ProfileServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'list_profiles': grpc.unary_unary_rpc_method_handler(
                    servicer.list_profiles,
                    request_deserializer=connpy__pb2.FilterRequest.FromString,
                    response_serializer=connpy__pb2.ValueResponse.SerializeToString,
            ),
            'get_profile': grpc.unary_unary_rpc_method_handler(
                    servicer.get_profile,
                    request_deserializer=connpy__pb2.ProfileRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
            'add_profile': grpc.unary_unary_rpc_method_handler(
                    servicer.add_profile,
                    request_deserializer=connpy__pb2.NodeRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'resolve_node_data': grpc.unary_unary_rpc_method_handler(
                    servicer.resolve_node_data,
                    request_deserializer=connpy__pb2.StructRequest.FromString,
                    response_serializer=connpy__pb2.StructResponse.SerializeToString,
            ),
            'delete_profile': grpc.unary_unary_rpc_method_handler(
                    servicer.delete_profile,
                    request_deserializer=connpy__pb2.IdRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'update_profile': grpc.unary_unary_rpc_method_handler(
                    servicer.update_profile,
                    request_deserializer=connpy__pb2.NodeRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.ProfileService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.ProfileService', rpc_method_handlers)

def add_SystemServiceServicer_to_server(servicer, server)

Expand source code

def add_SystemServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'start_api': grpc.unary_unary_rpc_method_handler(
                    servicer.start_api,
                    request_deserializer=connpy__pb2.IntRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'debug_api': grpc.unary_unary_rpc_method_handler(
                    servicer.debug_api,
                    request_deserializer=connpy__pb2.IntRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'stop_api': grpc.unary_unary_rpc_method_handler(
                    servicer.stop_api,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'restart_api': grpc.unary_unary_rpc_method_handler(
                    servicer.restart_api,
                    request_deserializer=connpy__pb2.IntRequest.FromString,
                    response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            ),
            'get_api_status': grpc.unary_unary_rpc_method_handler(
                    servicer.get_api_status,
                    request_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                    response_serializer=connpy__pb2.BoolResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'connpy.SystemService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))
    server.add_registered_method_handlers('connpy.SystemService', rpc_method_handlers)

Classes

class AIService

Expand source code

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

    @staticmethod
    def ask(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,
            '/connpy.AIService/ask',
            connpy__pb2.AskRequest.SerializeToString,
            connpy__pb2.AIResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def confirm(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.AIService/confirm',
            connpy__pb2.StringRequest.SerializeToString,
            connpy__pb2.BoolResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def list_sessions(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.AIService/list_sessions',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            connpy__pb2.ValueResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def delete_session(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.AIService/delete_session',
            connpy__pb2.StringRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def configure_provider(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.AIService/configure_provider',
            connpy__pb2.ProviderRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def load_session_data(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.AIService/load_session_data',
            connpy__pb2.StringRequest.SerializeToString,
            connpy__pb2.StructResponse.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 ask(request_iterator,
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 ask(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,
        '/connpy.AIService/ask',
        connpy__pb2.AskRequest.SerializeToString,
        connpy__pb2.AIResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def configure_provider(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 configure_provider(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.AIService/configure_provider',
        connpy__pb2.ProviderRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def confirm(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 confirm(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.AIService/confirm',
        connpy__pb2.StringRequest.SerializeToString,
        connpy__pb2.BoolResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def delete_session(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 delete_session(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.AIService/delete_session',
        connpy__pb2.StringRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def list_sessions(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 list_sessions(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.AIService/list_sessions',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        connpy__pb2.ValueResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def load_session_data(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 load_session_data(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.AIService/load_session_data',
        connpy__pb2.StringRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class AIServiceServicer

Expand source code

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

    def ask(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!')

    def confirm(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 list_sessions(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 delete_session(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 configure_provider(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 load_session_data(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

• AIServicer

Methods

def ask(self, request_iterator, context)

Expand source code

def ask(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!')

Missing associated documentation comment in .proto file.

def configure_provider(self, request, context)

Expand source code

def configure_provider(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 confirm(self, request, context)

Expand source code

def confirm(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 delete_session(self, request, context)

Expand source code

def delete_session(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 list_sessions(self, request, context)

Expand source code

def list_sessions(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 load_session_data(self, request, context)

Expand source code

def load_session_data(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 AIServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.ask = channel.stream_stream(
                '/connpy.AIService/ask',
                request_serializer=connpy__pb2.AskRequest.SerializeToString,
                response_deserializer=connpy__pb2.AIResponse.FromString,
                _registered_method=True)
        self.confirm = channel.unary_unary(
                '/connpy.AIService/confirm',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=connpy__pb2.BoolResponse.FromString,
                _registered_method=True)
        self.list_sessions = channel.unary_unary(
                '/connpy.AIService/list_sessions',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=connpy__pb2.ValueResponse.FromString,
                _registered_method=True)
        self.delete_session = channel.unary_unary(
                '/connpy.AIService/delete_session',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.configure_provider = channel.unary_unary(
                '/connpy.AIService/configure_provider',
                request_serializer=connpy__pb2.ProviderRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.load_session_data = channel.unary_unary(
                '/connpy.AIService/load_session_data',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class ConfigService

Expand source code

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

    @staticmethod
    def get_settings(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.ConfigService/get_settings',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            connpy__pb2.StructResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def get_default_dir(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.ConfigService/get_default_dir',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            connpy__pb2.StringResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def set_config_folder(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.ConfigService/set_config_folder',
            connpy__pb2.StringRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def update_setting(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.ConfigService/update_setting',
            connpy__pb2.UpdateRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def encrypt_password(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.ConfigService/encrypt_password',
            connpy__pb2.StringRequest.SerializeToString,
            connpy__pb2.StringResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def apply_theme_from_file(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.ConfigService/apply_theme_from_file',
            connpy__pb2.StringRequest.SerializeToString,
            connpy__pb2.StructResponse.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 apply_theme_from_file(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 apply_theme_from_file(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.ConfigService/apply_theme_from_file',
        connpy__pb2.StringRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def encrypt_password(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 encrypt_password(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.ConfigService/encrypt_password',
        connpy__pb2.StringRequest.SerializeToString,
        connpy__pb2.StringResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def get_default_dir(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_default_dir(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.ConfigService/get_default_dir',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        connpy__pb2.StringResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def get_settings(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_settings(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.ConfigService/get_settings',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def set_config_folder(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 set_config_folder(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.ConfigService/set_config_folder',
        connpy__pb2.StringRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def update_setting(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 update_setting(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.ConfigService/update_setting',
        connpy__pb2.UpdateRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class ConfigServiceServicer

Expand source code

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

    def get_settings(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 get_default_dir(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 set_config_folder(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 update_setting(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 encrypt_password(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 apply_theme_from_file(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

• ConfigServicer

Methods

def apply_theme_from_file(self, request, context)

Expand source code

def apply_theme_from_file(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 encrypt_password(self, request, context)

Expand source code

def encrypt_password(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 get_default_dir(self, request, context)

Expand source code

def get_default_dir(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 get_settings(self, request, context)

Expand source code

def get_settings(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 set_config_folder(self, request, context)

Expand source code

def set_config_folder(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 update_setting(self, request, context)

Expand source code

def update_setting(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 ConfigServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.get_settings = channel.unary_unary(
                '/connpy.ConfigService/get_settings',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)
        self.get_default_dir = channel.unary_unary(
                '/connpy.ConfigService/get_default_dir',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=connpy__pb2.StringResponse.FromString,
                _registered_method=True)
        self.set_config_folder = channel.unary_unary(
                '/connpy.ConfigService/set_config_folder',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.update_setting = channel.unary_unary(
                '/connpy.ConfigService/update_setting',
                request_serializer=connpy__pb2.UpdateRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.encrypt_password = channel.unary_unary(
                '/connpy.ConfigService/encrypt_password',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=connpy__pb2.StringResponse.FromString,
                _registered_method=True)
        self.apply_theme_from_file = channel.unary_unary(
                '/connpy.ConfigService/apply_theme_from_file',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class ExecutionService

Expand source code

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

    @staticmethod
    def run_commands(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.ExecutionService/run_commands',
            connpy__pb2.RunRequest.SerializeToString,
            connpy__pb2.NodeRunResult.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def test_commands(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.ExecutionService/test_commands',
            connpy__pb2.TestRequest.SerializeToString,
            connpy__pb2.NodeRunResult.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def run_cli_script(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.ExecutionService/run_cli_script',
            connpy__pb2.ScriptRequest.SerializeToString,
            connpy__pb2.StructResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def run_yaml_playbook(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.ExecutionService/run_yaml_playbook',
            connpy__pb2.ScriptRequest.SerializeToString,
            connpy__pb2.StructResponse.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 run_cli_script(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 run_cli_script(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.ExecutionService/run_cli_script',
        connpy__pb2.ScriptRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def run_commands(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 run_commands(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.ExecutionService/run_commands',
        connpy__pb2.RunRequest.SerializeToString,
        connpy__pb2.NodeRunResult.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def run_yaml_playbook(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 run_yaml_playbook(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.ExecutionService/run_yaml_playbook',
        connpy__pb2.ScriptRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def test_commands(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 test_commands(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.ExecutionService/test_commands',
        connpy__pb2.TestRequest.SerializeToString,
        connpy__pb2.NodeRunResult.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class ExecutionServiceServicer

Expand source code

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

    def run_commands(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 test_commands(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 run_cli_script(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 run_yaml_playbook(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

• ExecutionServicer

Methods

def run_cli_script(self, request, context)

Expand source code

def run_cli_script(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 run_commands(self, request, context)

Expand source code

def run_commands(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 run_yaml_playbook(self, request, context)

Expand source code

def run_yaml_playbook(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 test_commands(self, request, context)

Expand source code

def test_commands(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 ExecutionServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.run_commands = channel.unary_stream(
                '/connpy.ExecutionService/run_commands',
                request_serializer=connpy__pb2.RunRequest.SerializeToString,
                response_deserializer=connpy__pb2.NodeRunResult.FromString,
                _registered_method=True)
        self.test_commands = channel.unary_stream(
                '/connpy.ExecutionService/test_commands',
                request_serializer=connpy__pb2.TestRequest.SerializeToString,
                response_deserializer=connpy__pb2.NodeRunResult.FromString,
                _registered_method=True)
        self.run_cli_script = channel.unary_unary(
                '/connpy.ExecutionService/run_cli_script',
                request_serializer=connpy__pb2.ScriptRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)
        self.run_yaml_playbook = channel.unary_unary(
                '/connpy.ExecutionService/run_yaml_playbook',
                request_serializer=connpy__pb2.ScriptRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class ImportExportService

Expand source code

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

    @staticmethod
    def export_to_file(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.ImportExportService/export_to_file',
            connpy__pb2.ExportRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def import_from_file(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.ImportExportService/import_from_file',
            connpy__pb2.StringRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def set_reserved_names(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.ImportExportService/set_reserved_names',
            connpy__pb2.ListRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.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 export_to_file(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 export_to_file(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.ImportExportService/export_to_file',
        connpy__pb2.ExportRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def import_from_file(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 import_from_file(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.ImportExportService/import_from_file',
        connpy__pb2.StringRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def set_reserved_names(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 set_reserved_names(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.ImportExportService/set_reserved_names',
        connpy__pb2.ListRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class ImportExportServiceServicer

Expand source code

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

    def export_to_file(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 import_from_file(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 set_reserved_names(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

• ImportExportServicer

Methods

def export_to_file(self, request, context)

Expand source code

def export_to_file(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 import_from_file(self, request, context)

Expand source code

def import_from_file(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 set_reserved_names(self, request, context)

Expand source code

def set_reserved_names(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 ImportExportServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.export_to_file = channel.unary_unary(
                '/connpy.ImportExportService/export_to_file',
                request_serializer=connpy__pb2.ExportRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.import_from_file = channel.unary_unary(
                '/connpy.ImportExportService/import_from_file',
                request_serializer=connpy__pb2.StringRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.set_reserved_names = channel.unary_unary(
                '/connpy.ImportExportService/set_reserved_names',
                request_serializer=connpy__pb2.ListRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class NodeService

Expand source code

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

    @staticmethod
    def list_nodes(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.NodeService/list_nodes',
            connpy__pb2.FilterRequest.SerializeToString,
            connpy__pb2.ValueResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def list_folders(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.NodeService/list_folders',
            connpy__pb2.FilterRequest.SerializeToString,
            connpy__pb2.ValueResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def get_node_details(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.NodeService/get_node_details',
            connpy__pb2.IdRequest.SerializeToString,
            connpy__pb2.StructResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def explode_unique(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.NodeService/explode_unique',
            connpy__pb2.IdRequest.SerializeToString,
            connpy__pb2.ValueResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def generate_cache(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.NodeService/generate_cache',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def add_node(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.NodeService/add_node',
            connpy__pb2.NodeRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def update_node(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.NodeService/update_node',
            connpy__pb2.NodeRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def delete_node(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.NodeService/delete_node',
            connpy__pb2.DeleteRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def move_node(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.NodeService/move_node',
            connpy__pb2.MoveRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def bulk_add(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.NodeService/bulk_add',
            connpy__pb2.BulkRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def validate_parent_folder(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.NodeService/validate_parent_folder',
            connpy__pb2.IdRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def set_reserved_names(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.NodeService/set_reserved_names',
            connpy__pb2.ListRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def interact_node(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,
            '/connpy.NodeService/interact_node',
            connpy__pb2.InteractRequest.SerializeToString,
            connpy__pb2.InteractResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def full_replace(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.NodeService/full_replace',
            connpy__pb2.FullReplaceRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def get_inventory(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.NodeService/get_inventory',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            connpy__pb2.FullReplaceRequest.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 add_node(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 add_node(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.NodeService/add_node',
        connpy__pb2.NodeRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def bulk_add(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 bulk_add(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.NodeService/bulk_add',
        connpy__pb2.BulkRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def delete_node(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 delete_node(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.NodeService/delete_node',
        connpy__pb2.DeleteRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def explode_unique(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 explode_unique(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.NodeService/explode_unique',
        connpy__pb2.IdRequest.SerializeToString,
        connpy__pb2.ValueResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def full_replace(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 full_replace(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.NodeService/full_replace',
        connpy__pb2.FullReplaceRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def generate_cache(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 generate_cache(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.NodeService/generate_cache',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def get_inventory(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_inventory(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.NodeService/get_inventory',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        connpy__pb2.FullReplaceRequest.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def get_node_details(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_node_details(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.NodeService/get_node_details',
        connpy__pb2.IdRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def interact_node(request_iterator,
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 interact_node(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,
        '/connpy.NodeService/interact_node',
        connpy__pb2.InteractRequest.SerializeToString,
        connpy__pb2.InteractResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def list_folders(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 list_folders(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.NodeService/list_folders',
        connpy__pb2.FilterRequest.SerializeToString,
        connpy__pb2.ValueResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def list_nodes(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 list_nodes(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.NodeService/list_nodes',
        connpy__pb2.FilterRequest.SerializeToString,
        connpy__pb2.ValueResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def move_node(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 move_node(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.NodeService/move_node',
        connpy__pb2.MoveRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def set_reserved_names(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 set_reserved_names(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.NodeService/set_reserved_names',
        connpy__pb2.ListRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def update_node(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 update_node(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.NodeService/update_node',
        connpy__pb2.NodeRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def validate_parent_folder(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 validate_parent_folder(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.NodeService/validate_parent_folder',
        connpy__pb2.IdRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class NodeServiceServicer

Expand source code

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

    def list_nodes(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 list_folders(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 get_node_details(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 explode_unique(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 generate_cache(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 add_node(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 update_node(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 delete_node(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 move_node(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 bulk_add(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 validate_parent_folder(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 set_reserved_names(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 interact_node(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!')

    def full_replace(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 get_inventory(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

• NodeServicer

Methods

def add_node(self, request, context)

Expand source code

def add_node(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 bulk_add(self, request, context)

Expand source code

def bulk_add(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 delete_node(self, request, context)

Expand source code

def delete_node(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 explode_unique(self, request, context)

Expand source code

def explode_unique(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 full_replace(self, request, context)

Expand source code

def full_replace(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 generate_cache(self, request, context)

Expand source code

def generate_cache(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 get_inventory(self, request, context)

Expand source code

def get_inventory(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 get_node_details(self, request, context)

Expand source code

def get_node_details(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 interact_node(self, request_iterator, context)

Expand source code

def interact_node(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!')

Missing associated documentation comment in .proto file.

def list_folders(self, request, context)

Expand source code

def list_folders(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 list_nodes(self, request, context)

Expand source code

def list_nodes(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 move_node(self, request, context)

Expand source code

def move_node(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 set_reserved_names(self, request, context)

Expand source code

def set_reserved_names(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 update_node(self, request, context)

Expand source code

def update_node(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 validate_parent_folder(self, request, context)

Expand source code

def validate_parent_folder(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 NodeServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.list_nodes = channel.unary_unary(
                '/connpy.NodeService/list_nodes',
                request_serializer=connpy__pb2.FilterRequest.SerializeToString,
                response_deserializer=connpy__pb2.ValueResponse.FromString,
                _registered_method=True)
        self.list_folders = channel.unary_unary(
                '/connpy.NodeService/list_folders',
                request_serializer=connpy__pb2.FilterRequest.SerializeToString,
                response_deserializer=connpy__pb2.ValueResponse.FromString,
                _registered_method=True)
        self.get_node_details = channel.unary_unary(
                '/connpy.NodeService/get_node_details',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)
        self.explode_unique = channel.unary_unary(
                '/connpy.NodeService/explode_unique',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=connpy__pb2.ValueResponse.FromString,
                _registered_method=True)
        self.generate_cache = channel.unary_unary(
                '/connpy.NodeService/generate_cache',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.add_node = channel.unary_unary(
                '/connpy.NodeService/add_node',
                request_serializer=connpy__pb2.NodeRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.update_node = channel.unary_unary(
                '/connpy.NodeService/update_node',
                request_serializer=connpy__pb2.NodeRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.delete_node = channel.unary_unary(
                '/connpy.NodeService/delete_node',
                request_serializer=connpy__pb2.DeleteRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.move_node = channel.unary_unary(
                '/connpy.NodeService/move_node',
                request_serializer=connpy__pb2.MoveRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.bulk_add = channel.unary_unary(
                '/connpy.NodeService/bulk_add',
                request_serializer=connpy__pb2.BulkRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.validate_parent_folder = channel.unary_unary(
                '/connpy.NodeService/validate_parent_folder',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.set_reserved_names = channel.unary_unary(
                '/connpy.NodeService/set_reserved_names',
                request_serializer=connpy__pb2.ListRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.interact_node = channel.stream_stream(
                '/connpy.NodeService/interact_node',
                request_serializer=connpy__pb2.InteractRequest.SerializeToString,
                response_deserializer=connpy__pb2.InteractResponse.FromString,
                _registered_method=True)
        self.full_replace = channel.unary_unary(
                '/connpy.NodeService/full_replace',
                request_serializer=connpy__pb2.FullReplaceRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.get_inventory = channel.unary_unary(
                '/connpy.NodeService/get_inventory',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=connpy__pb2.FullReplaceRequest.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class PluginService

Expand source code

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

    @staticmethod
    def list_plugins(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.PluginService/list_plugins',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            connpy__pb2.ValueResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def add_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_unary(
            request,
            target,
            '/connpy.PluginService/add_plugin',
            connpy__pb2.PluginRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def delete_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_unary(
            request,
            target,
            '/connpy.PluginService/delete_plugin',
            connpy__pb2.IdRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def enable_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_unary(
            request,
            target,
            '/connpy.PluginService/enable_plugin',
            connpy__pb2.IdRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def disable_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_unary(
            request,
            target,
            '/connpy.PluginService/disable_plugin',
            connpy__pb2.IdRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.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 add_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 add_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_unary(
        request,
        target,
        '/connpy.PluginService/add_plugin',
        connpy__pb2.PluginRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def delete_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 delete_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_unary(
        request,
        target,
        '/connpy.PluginService/delete_plugin',
        connpy__pb2.IdRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def disable_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 disable_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_unary(
        request,
        target,
        '/connpy.PluginService/disable_plugin',
        connpy__pb2.IdRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def enable_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 enable_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_unary(
        request,
        target,
        '/connpy.PluginService/enable_plugin',
        connpy__pb2.IdRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def list_plugins(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 list_plugins(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.PluginService/list_plugins',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        connpy__pb2.ValueResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class PluginServiceServicer

Expand source code

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

    def list_plugins(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 add_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!')

    def delete_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!')

    def enable_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!')

    def disable_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 add_plugin(self, request, context)

Expand source code

def add_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.

def delete_plugin(self, request, context)

Expand source code

def delete_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.

def disable_plugin(self, request, context)

Expand source code

def disable_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.

def enable_plugin(self, request, context)

Expand source code

def enable_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.

def list_plugins(self, request, context)

Expand source code

def list_plugins(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 PluginServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.list_plugins = channel.unary_unary(
                '/connpy.PluginService/list_plugins',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=connpy__pb2.ValueResponse.FromString,
                _registered_method=True)
        self.add_plugin = channel.unary_unary(
                '/connpy.PluginService/add_plugin',
                request_serializer=connpy__pb2.PluginRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.delete_plugin = channel.unary_unary(
                '/connpy.PluginService/delete_plugin',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.enable_plugin = channel.unary_unary(
                '/connpy.PluginService/enable_plugin',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.disable_plugin = channel.unary_unary(
                '/connpy.PluginService/disable_plugin',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class ProfileService

Expand source code

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

    @staticmethod
    def list_profiles(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.ProfileService/list_profiles',
            connpy__pb2.FilterRequest.SerializeToString,
            connpy__pb2.ValueResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def get_profile(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.ProfileService/get_profile',
            connpy__pb2.ProfileRequest.SerializeToString,
            connpy__pb2.StructResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def add_profile(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.ProfileService/add_profile',
            connpy__pb2.NodeRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def resolve_node_data(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.ProfileService/resolve_node_data',
            connpy__pb2.StructRequest.SerializeToString,
            connpy__pb2.StructResponse.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def delete_profile(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.ProfileService/delete_profile',
            connpy__pb2.IdRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def update_profile(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.ProfileService/update_profile',
            connpy__pb2.NodeRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.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 add_profile(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 add_profile(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.ProfileService/add_profile',
        connpy__pb2.NodeRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def delete_profile(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 delete_profile(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.ProfileService/delete_profile',
        connpy__pb2.IdRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def get_profile(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_profile(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.ProfileService/get_profile',
        connpy__pb2.ProfileRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def list_profiles(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 list_profiles(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.ProfileService/list_profiles',
        connpy__pb2.FilterRequest.SerializeToString,
        connpy__pb2.ValueResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def resolve_node_data(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 resolve_node_data(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.ProfileService/resolve_node_data',
        connpy__pb2.StructRequest.SerializeToString,
        connpy__pb2.StructResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def update_profile(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 update_profile(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.ProfileService/update_profile',
        connpy__pb2.NodeRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class ProfileServiceServicer

Expand source code

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

    def list_profiles(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 get_profile(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 add_profile(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 resolve_node_data(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 delete_profile(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 update_profile(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

• ProfileServicer

Methods

def add_profile(self, request, context)

Expand source code

def add_profile(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 delete_profile(self, request, context)

Expand source code

def delete_profile(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 get_profile(self, request, context)

Expand source code

def get_profile(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 list_profiles(self, request, context)

Expand source code

def list_profiles(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 resolve_node_data(self, request, context)

Expand source code

def resolve_node_data(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 update_profile(self, request, context)

Expand source code

def update_profile(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 ProfileServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.list_profiles = channel.unary_unary(
                '/connpy.ProfileService/list_profiles',
                request_serializer=connpy__pb2.FilterRequest.SerializeToString,
                response_deserializer=connpy__pb2.ValueResponse.FromString,
                _registered_method=True)
        self.get_profile = channel.unary_unary(
                '/connpy.ProfileService/get_profile',
                request_serializer=connpy__pb2.ProfileRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)
        self.add_profile = channel.unary_unary(
                '/connpy.ProfileService/add_profile',
                request_serializer=connpy__pb2.NodeRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.resolve_node_data = channel.unary_unary(
                '/connpy.ProfileService/resolve_node_data',
                request_serializer=connpy__pb2.StructRequest.SerializeToString,
                response_deserializer=connpy__pb2.StructResponse.FromString,
                _registered_method=True)
        self.delete_profile = channel.unary_unary(
                '/connpy.ProfileService/delete_profile',
                request_serializer=connpy__pb2.IdRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.update_profile = channel.unary_unary(
                '/connpy.ProfileService/update_profile',
                request_serializer=connpy__pb2.NodeRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.

class SystemService

Expand source code

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

    @staticmethod
    def start_api(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.SystemService/start_api',
            connpy__pb2.IntRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def debug_api(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.SystemService/debug_api',
            connpy__pb2.IntRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def stop_api(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.SystemService/stop_api',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def restart_api(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.SystemService/restart_api',
            connpy__pb2.IntRequest.SerializeToString,
            google_dot_protobuf_dot_empty__pb2.Empty.FromString,
            options,
            channel_credentials,
            insecure,
            call_credentials,
            compression,
            wait_for_ready,
            timeout,
            metadata,
            _registered_method=True)

    @staticmethod
    def get_api_status(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.SystemService/get_api_status',
            google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
            connpy__pb2.BoolResponse.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 debug_api(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 debug_api(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.SystemService/debug_api',
        connpy__pb2.IntRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def get_api_status(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_api_status(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.SystemService/get_api_status',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        connpy__pb2.BoolResponse.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def restart_api(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 restart_api(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.SystemService/restart_api',
        connpy__pb2.IntRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def start_api(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 start_api(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.SystemService/start_api',
        connpy__pb2.IntRequest.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

def stop_api(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 stop_api(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.SystemService/stop_api',
        google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
        google_dot_protobuf_dot_empty__pb2.Empty.FromString,
        options,
        channel_credentials,
        insecure,
        call_credentials,
        compression,
        wait_for_ready,
        timeout,
        metadata,
        _registered_method=True)

class SystemServiceServicer

Expand source code

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

    def start_api(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 debug_api(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 stop_api(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 restart_api(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 get_api_status(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

• SystemServicer

Methods

def debug_api(self, request, context)

Expand source code

def debug_api(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 get_api_status(self, request, context)

Expand source code

def get_api_status(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 restart_api(self, request, context)

Expand source code

def restart_api(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 start_api(self, request, context)

Expand source code

def start_api(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 stop_api(self, request, context)

Expand source code

def stop_api(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 SystemServiceStub (channel)

Expand source code

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

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

        Args:
            channel: A grpc.Channel.
        """
        self.start_api = channel.unary_unary(
                '/connpy.SystemService/start_api',
                request_serializer=connpy__pb2.IntRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.debug_api = channel.unary_unary(
                '/connpy.SystemService/debug_api',
                request_serializer=connpy__pb2.IntRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.stop_api = channel.unary_unary(
                '/connpy.SystemService/stop_api',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.restart_api = channel.unary_unary(
                '/connpy.SystemService/restart_api',
                request_serializer=connpy__pb2.IntRequest.SerializeToString,
                response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
                _registered_method=True)
        self.get_api_status = channel.unary_unary(
                '/connpy.SystemService/get_api_status',
                request_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
                response_deserializer=connpy__pb2.BoolResponse.FromString,
                _registered_method=True)

Missing associated documentation comment in .proto file.

Constructor.

Args

channel

A grpc.Channel.