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

import CBCManager_pb2 as protobufs_dot_CBCManager__pb2


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

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

        Args:
            channel: A grpc.Channel.
        """
        self.GetUserAccounts = channel.unary_unary(
                '/CBCManagerService/GetUserAccounts',
                request_serializer=protobufs_dot_CBCManager__pb2.UserAccountsRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.UserAccountsResponse.FromString,
                )
        self.CreateUserAccount = channel.unary_unary(
                '/CBCManagerService/CreateUserAccount',
                request_serializer=protobufs_dot_CBCManager__pb2.CreateUserAccountRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.CreateUserAccountResponse.FromString,
                )
        self.UpdateUserAccount = channel.unary_unary(
                '/CBCManagerService/UpdateUserAccount',
                request_serializer=protobufs_dot_CBCManager__pb2.UpdateUserAccountRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.UpdateUserAccountResponse.FromString,
                )
        self.DeleteUserAccount = channel.unary_unary(
                '/CBCManagerService/DeleteUserAccount',
                request_serializer=protobufs_dot_CBCManager__pb2.DeleteUserAccountRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.DeleteUserAccountResponse.FromString,
                )
        self.RetrieveVMs = channel.unary_unary(
                '/CBCManagerService/RetrieveVMs',
                request_serializer=protobufs_dot_CBCManager__pb2.RetrieveVMsRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.RetrieveVMsResponse.FromString,
                )
        self.RetrieveWorkloadSensors = channel.unary_unary(
                '/CBCManagerService/RetrieveWorkloadSensors',
                request_serializer=protobufs_dot_CBCManager__pb2.RetrieveSensorsRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.RetrieveSensorsResponse.FromString,
                )
        self.ServiceManage = channel.unary_unary(
                '/CBCManagerService/ServiceManage',
                request_serializer=protobufs_dot_CBCManager__pb2.ServiceManagementRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.ServiceManagementResponse.FromString,
                )
        self.SensorManage = channel.unary_unary(
                '/CBCManagerService/SensorManage',
                request_serializer=protobufs_dot_CBCManager__pb2.SensorManagementRequest.SerializeToString,
                response_deserializer=protobufs_dot_CBCManager__pb2.SensorManagementResponse.FromString,
                )


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

    def GetUserAccounts(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 CreateUserAccount(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 UpdateUserAccount(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 DeleteUserAccount(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 RetrieveVMs(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 RetrieveWorkloadSensors(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 ServiceManage(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 SensorManage(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_CBCManagerServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {
            'GetUserAccounts': grpc.unary_unary_rpc_method_handler(
                    servicer.GetUserAccounts,
                    request_deserializer=protobufs_dot_CBCManager__pb2.UserAccountsRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.UserAccountsResponse.SerializeToString,
            ),
            'CreateUserAccount': grpc.unary_unary_rpc_method_handler(
                    servicer.CreateUserAccount,
                    request_deserializer=protobufs_dot_CBCManager__pb2.CreateUserAccountRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.CreateUserAccountResponse.SerializeToString,
            ),
            'UpdateUserAccount': grpc.unary_unary_rpc_method_handler(
                    servicer.UpdateUserAccount,
                    request_deserializer=protobufs_dot_CBCManager__pb2.UpdateUserAccountRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.UpdateUserAccountResponse.SerializeToString,
            ),
            'DeleteUserAccount': grpc.unary_unary_rpc_method_handler(
                    servicer.DeleteUserAccount,
                    request_deserializer=protobufs_dot_CBCManager__pb2.DeleteUserAccountRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.DeleteUserAccountResponse.SerializeToString,
            ),
            'RetrieveVMs': grpc.unary_unary_rpc_method_handler(
                    servicer.RetrieveVMs,
                    request_deserializer=protobufs_dot_CBCManager__pb2.RetrieveVMsRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.RetrieveVMsResponse.SerializeToString,
            ),
            'RetrieveWorkloadSensors': grpc.unary_unary_rpc_method_handler(
                    servicer.RetrieveWorkloadSensors,
                    request_deserializer=protobufs_dot_CBCManager__pb2.RetrieveSensorsRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.RetrieveSensorsResponse.SerializeToString,
            ),
            'ServiceManage': grpc.unary_unary_rpc_method_handler(
                    servicer.ServiceManage,
                    request_deserializer=protobufs_dot_CBCManager__pb2.ServiceManagementRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.ServiceManagementResponse.SerializeToString,
            ),
            'SensorManage': grpc.unary_unary_rpc_method_handler(
                    servicer.SensorManage,
                    request_deserializer=protobufs_dot_CBCManager__pb2.SensorManagementRequest.FromString,
                    response_serializer=protobufs_dot_CBCManager__pb2.SensorManagementResponse.SerializeToString,
            ),
    }
    generic_handler = grpc.method_handlers_generic_handler(
            'CBCManagerService', rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))


 # This class is part of an EXPERIMENTAL API.
class CBCManagerService(object):
    """Missing associated documentation comment in .proto file."""

    @staticmethod
    def GetUserAccounts(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, '/CBCManagerService/GetUserAccounts',
            protobufs_dot_CBCManager__pb2.UserAccountsRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.UserAccountsResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def CreateUserAccount(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, '/CBCManagerService/CreateUserAccount',
            protobufs_dot_CBCManager__pb2.CreateUserAccountRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.CreateUserAccountResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def UpdateUserAccount(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, '/CBCManagerService/UpdateUserAccount',
            protobufs_dot_CBCManager__pb2.UpdateUserAccountRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.UpdateUserAccountResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def DeleteUserAccount(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, '/CBCManagerService/DeleteUserAccount',
            protobufs_dot_CBCManager__pb2.DeleteUserAccountRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.DeleteUserAccountResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def RetrieveVMs(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, '/CBCManagerService/RetrieveVMs',
            protobufs_dot_CBCManager__pb2.RetrieveVMsRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.RetrieveVMsResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def RetrieveWorkloadSensors(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, '/CBCManagerService/RetrieveWorkloadSensors',
            protobufs_dot_CBCManager__pb2.RetrieveSensorsRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.RetrieveSensorsResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def ServiceManage(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, '/CBCManagerService/ServiceManage',
            protobufs_dot_CBCManager__pb2.ServiceManagementRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.ServiceManagementResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def SensorManage(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, '/CBCManagerService/SensorManage',
            protobufs_dot_CBCManager__pb2.SensorManagementRequest.SerializeToString,
            protobufs_dot_CBCManager__pb2.SensorManagementResponse.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
