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

from bosdyn.api import data_index_pb2 as bosdyn_dot_api_dot_data__index__pb2


class DataServiceStub(object):
    """The DataService is a mechanism for querying and managing data stored on robot.
    """

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

        Args:
            channel: A grpc.Channel.
        """
        self.GetDataIndex = channel.unary_unary(
                '/bosdyn.api.DataService/GetDataIndex',
                request_serializer=bosdyn_dot_api_dot_data__index__pb2.GetDataIndexRequest.SerializeToString,
                response_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetDataIndexResponse.FromString,
                )
        self.GetEventsComments = channel.unary_unary(
                '/bosdyn.api.DataService/GetEventsComments',
                request_serializer=bosdyn_dot_api_dot_data__index__pb2.GetEventsCommentsRequest.SerializeToString,
                response_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetEventsCommentsResponse.FromString,
                )
        self.GetDataBufferStatus = channel.unary_unary(
                '/bosdyn.api.DataService/GetDataBufferStatus',
                request_serializer=bosdyn_dot_api_dot_data__index__pb2.GetDataBufferStatusRequest.SerializeToString,
                response_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetDataBufferStatusResponse.FromString,
                )
        self.GetDataPages = channel.unary_unary(
                '/bosdyn.api.DataService/GetDataPages',
                request_serializer=bosdyn_dot_api_dot_data__index__pb2.GetDataPagesRequest.SerializeToString,
                response_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetDataPagesResponse.FromString,
                )
        self.DeleteDataPages = channel.unary_unary(
                '/bosdyn.api.DataService/DeleteDataPages',
                request_serializer=bosdyn_dot_api_dot_data__index__pb2.DeleteDataPagesRequest.SerializeToString,
                response_deserializer=bosdyn_dot_api_dot_data__index__pb2.DeleteDataPagesResponse.FromString,
                )


class DataServiceServicer(object):
    """The DataService is a mechanism for querying and managing data stored on robot.
    """

    def GetDataIndex(self, request, context):
        """Get index of current data matching a given DataQuery.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetEventsComments(self, request, context):
        """Get events and comments.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetDataBufferStatus(self, request, context):
        """Get basic stats on data buffer storage.
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetDataPages(self, request, context):
        """Get a list pf pages matching a given time range
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def DeleteDataPages(self, request, context):
        """Delete a list of pages matching a given time range or page ids
        """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


def add_DataServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'GetDataIndex': grpc.unary_unary_rpc_method_handler(
                    servicer.GetDataIndex,
                    request_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetDataIndexRequest.FromString,
                    response_serializer=bosdyn_dot_api_dot_data__index__pb2.GetDataIndexResponse.SerializeToString,
            ),
            'GetEventsComments': grpc.unary_unary_rpc_method_handler(
                    servicer.GetEventsComments,
                    request_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetEventsCommentsRequest.FromString,
                    response_serializer=bosdyn_dot_api_dot_data__index__pb2.GetEventsCommentsResponse.SerializeToString,
            ),
            'GetDataBufferStatus': grpc.unary_unary_rpc_method_handler(
                    servicer.GetDataBufferStatus,
                    request_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetDataBufferStatusRequest.FromString,
                    response_serializer=bosdyn_dot_api_dot_data__index__pb2.GetDataBufferStatusResponse.SerializeToString,
            ),
            'GetDataPages': grpc.unary_unary_rpc_method_handler(
                    servicer.GetDataPages,
                    request_deserializer=bosdyn_dot_api_dot_data__index__pb2.GetDataPagesRequest.FromString,
                    response_serializer=bosdyn_dot_api_dot_data__index__pb2.GetDataPagesResponse.SerializeToString,
            ),
            'DeleteDataPages': grpc.unary_unary_rpc_method_handler(
                    servicer.DeleteDataPages,
                    request_deserializer=bosdyn_dot_api_dot_data__index__pb2.DeleteDataPagesRequest.FromString,
                    response_serializer=bosdyn_dot_api_dot_data__index__pb2.DeleteDataPagesResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'bosdyn.api.DataService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))


 # This class is part of an EXPERIMENTAL API.
class DataService(object):
    """The DataService is a mechanism for querying and managing data stored on robot.
    """

    @staticmethod
    def GetDataIndex(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, '/bosdyn.api.DataService/GetDataIndex',
            bosdyn_dot_api_dot_data__index__pb2.GetDataIndexRequest.SerializeToString,
            bosdyn_dot_api_dot_data__index__pb2.GetDataIndexResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def GetEventsComments(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, '/bosdyn.api.DataService/GetEventsComments',
            bosdyn_dot_api_dot_data__index__pb2.GetEventsCommentsRequest.SerializeToString,
            bosdyn_dot_api_dot_data__index__pb2.GetEventsCommentsResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def GetDataBufferStatus(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, '/bosdyn.api.DataService/GetDataBufferStatus',
            bosdyn_dot_api_dot_data__index__pb2.GetDataBufferStatusRequest.SerializeToString,
            bosdyn_dot_api_dot_data__index__pb2.GetDataBufferStatusResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def GetDataPages(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, '/bosdyn.api.DataService/GetDataPages',
            bosdyn_dot_api_dot_data__index__pb2.GetDataPagesRequest.SerializeToString,
            bosdyn_dot_api_dot_data__index__pb2.GetDataPagesResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def DeleteDataPages(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, '/bosdyn.api.DataService/DeleteDataPages',
            bosdyn_dot_api_dot_data__index__pb2.DeleteDataPagesRequest.SerializeToString,
            bosdyn_dot_api_dot_data__index__pb2.DeleteDataPagesResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)