# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc
from deephaven_enterprise.proto import acl_pb2 as deephaven__enterprise_dot_proto_dot_acl__pb2
from deephaven_enterprise.proto import auth_pb2 as deephaven__enterprise_dot_proto_dot_auth__pb2
from deephaven_enterprise.proto import controller_common_pb2 as deephaven__enterprise_dot_proto_dot_controller__common__pb2
from deephaven_enterprise.proto import controller_pb2 as deephaven__enterprise_dot_proto_dot_controller__pb2
[docs]class ControllerApiStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.authenticate = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/authenticate',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AuthenticationRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AuthenticationResponse.FromString,
)
self.addQuery = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/addQuery',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AddQueryRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AddQueryResponse.FromString,
)
self.removeQuery = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/removeQuery',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RemoveQueryRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RemoveQueryResponse.FromString,
)
self.modifyQuery = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/modifyQuery',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ModifyQueryRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ModifyQueryResponse.FromString,
)
self.restartQuery = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/restartQuery',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RestartQueryRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RestartQueryResponse.FromString,
)
self.stopQuery = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/stopQuery',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StopQueryRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StopQueryResponse.FromString,
)
self.determineDispatcher = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/determineDispatcher',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.DetermineDispatcherRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.DetermineDispatcherResponse.FromString,
)
self.getConfiguration = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/getConfiguration',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetConfigurationRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetConfigurationResponse.FromString,
)
self.getScriptPaths = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/getScriptPaths',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptPathsRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptPathsResponse.FromString,
)
self.getScript = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/getScript',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptResponse.FromString,
)
self.statusUpdate = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/statusUpdate',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StatusUpdateRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StatusUpdateResponse.FromString,
)
self.reloadConfig = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/reloadConfig',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ReloadConfigRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ReloadConfigResponse.FromString,
)
self.ping = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/ping',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__common__pb2.PingRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__common__pb2.PingResponse.FromString,
)
self.subscribe = channel.unary_stream(
'/io.deephaven.proto.controller.grpc.ControllerApi/subscribe',
request_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.SubscribeRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.SubscribeResponse.FromString,
)
self.invalidateCookie = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.ControllerApi/invalidateCookie',
request_serializer=deephaven__enterprise_dot_proto_dot_auth__pb2.InvalidateCookieRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_auth__pb2.InvalidateCookieResponse.FromString,
)
[docs]class ControllerApiServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs] def authenticate(self, request, context):
"""Authentication
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def addQuery(self, request, context):
"""These are for query management
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def removeQuery(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!')
[docs] def modifyQuery(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!')
[docs] def restartQuery(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!')
[docs] def stopQuery(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!')
[docs] def determineDispatcher(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!')
[docs] def getConfiguration(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!')
[docs] def getScriptPaths(self, request, context):
"""Script commands
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def getScript(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!')
[docs] def statusUpdate(self, request, context):
"""Configuration commands
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def reloadConfig(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!')
[docs] def ping(self, request, context):
"""Heartbeating
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details('Method not implemented!')
raise NotImplementedError('Method not implemented!')
[docs] def subscribe(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!')
[docs] def invalidateCookie(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_ControllerApiServicer_to_server(servicer, server):
rpc_method_handlers = {
'authenticate': grpc.unary_unary_rpc_method_handler(
servicer.authenticate,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AuthenticationRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AuthenticationResponse.SerializeToString,
),
'addQuery': grpc.unary_unary_rpc_method_handler(
servicer.addQuery,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AddQueryRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.AddQueryResponse.SerializeToString,
),
'removeQuery': grpc.unary_unary_rpc_method_handler(
servicer.removeQuery,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RemoveQueryRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RemoveQueryResponse.SerializeToString,
),
'modifyQuery': grpc.unary_unary_rpc_method_handler(
servicer.modifyQuery,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ModifyQueryRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ModifyQueryResponse.SerializeToString,
),
'restartQuery': grpc.unary_unary_rpc_method_handler(
servicer.restartQuery,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RestartQueryRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.RestartQueryResponse.SerializeToString,
),
'stopQuery': grpc.unary_unary_rpc_method_handler(
servicer.stopQuery,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StopQueryRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StopQueryResponse.SerializeToString,
),
'determineDispatcher': grpc.unary_unary_rpc_method_handler(
servicer.determineDispatcher,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.DetermineDispatcherRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.DetermineDispatcherResponse.SerializeToString,
),
'getConfiguration': grpc.unary_unary_rpc_method_handler(
servicer.getConfiguration,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetConfigurationRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetConfigurationResponse.SerializeToString,
),
'getScriptPaths': grpc.unary_unary_rpc_method_handler(
servicer.getScriptPaths,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptPathsRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptPathsResponse.SerializeToString,
),
'getScript': grpc.unary_unary_rpc_method_handler(
servicer.getScript,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptResponse.SerializeToString,
),
'statusUpdate': grpc.unary_unary_rpc_method_handler(
servicer.statusUpdate,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StatusUpdateRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.StatusUpdateResponse.SerializeToString,
),
'reloadConfig': grpc.unary_unary_rpc_method_handler(
servicer.reloadConfig,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ReloadConfigRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.ReloadConfigResponse.SerializeToString,
),
'ping': grpc.unary_unary_rpc_method_handler(
servicer.ping,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__common__pb2.PingRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__common__pb2.PingResponse.SerializeToString,
),
'subscribe': grpc.unary_stream_rpc_method_handler(
servicer.subscribe,
request_deserializer=deephaven__enterprise_dot_proto_dot_controller__pb2.SubscribeRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_controller__pb2.SubscribeResponse.SerializeToString,
),
'invalidateCookie': grpc.unary_unary_rpc_method_handler(
servicer.invalidateCookie,
request_deserializer=deephaven__enterprise_dot_proto_dot_auth__pb2.InvalidateCookieRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_auth__pb2.InvalidateCookieResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'io.deephaven.proto.controller.grpc.ControllerApi', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class ControllerApi(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def authenticate(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, '/io.deephaven.proto.controller.grpc.ControllerApi/authenticate',
deephaven__enterprise_dot_proto_dot_controller__pb2.AuthenticationRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.AuthenticationResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def addQuery(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, '/io.deephaven.proto.controller.grpc.ControllerApi/addQuery',
deephaven__enterprise_dot_proto_dot_controller__pb2.AddQueryRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.AddQueryResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def removeQuery(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, '/io.deephaven.proto.controller.grpc.ControllerApi/removeQuery',
deephaven__enterprise_dot_proto_dot_controller__pb2.RemoveQueryRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.RemoveQueryResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def modifyQuery(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, '/io.deephaven.proto.controller.grpc.ControllerApi/modifyQuery',
deephaven__enterprise_dot_proto_dot_controller__pb2.ModifyQueryRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.ModifyQueryResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def restartQuery(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, '/io.deephaven.proto.controller.grpc.ControllerApi/restartQuery',
deephaven__enterprise_dot_proto_dot_controller__pb2.RestartQueryRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.RestartQueryResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def stopQuery(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, '/io.deephaven.proto.controller.grpc.ControllerApi/stopQuery',
deephaven__enterprise_dot_proto_dot_controller__pb2.StopQueryRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.StopQueryResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def determineDispatcher(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, '/io.deephaven.proto.controller.grpc.ControllerApi/determineDispatcher',
deephaven__enterprise_dot_proto_dot_controller__pb2.DetermineDispatcherRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.DetermineDispatcherResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getConfiguration(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, '/io.deephaven.proto.controller.grpc.ControllerApi/getConfiguration',
deephaven__enterprise_dot_proto_dot_controller__pb2.GetConfigurationRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.GetConfigurationResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getScriptPaths(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, '/io.deephaven.proto.controller.grpc.ControllerApi/getScriptPaths',
deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptPathsRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptPathsResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getScript(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, '/io.deephaven.proto.controller.grpc.ControllerApi/getScript',
deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.GetScriptResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def statusUpdate(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, '/io.deephaven.proto.controller.grpc.ControllerApi/statusUpdate',
deephaven__enterprise_dot_proto_dot_controller__pb2.StatusUpdateRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.StatusUpdateResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def reloadConfig(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, '/io.deephaven.proto.controller.grpc.ControllerApi/reloadConfig',
deephaven__enterprise_dot_proto_dot_controller__pb2.ReloadConfigRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.ReloadConfigResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def ping(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, '/io.deephaven.proto.controller.grpc.ControllerApi/ping',
deephaven__enterprise_dot_proto_dot_controller__common__pb2.PingRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__common__pb2.PingResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def subscribe(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, '/io.deephaven.proto.controller.grpc.ControllerApi/subscribe',
deephaven__enterprise_dot_proto_dot_controller__pb2.SubscribeRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_controller__pb2.SubscribeResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def invalidateCookie(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, '/io.deephaven.proto.controller.grpc.ControllerApi/invalidateCookie',
deephaven__enterprise_dot_proto_dot_auth__pb2.InvalidateCookieRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_auth__pb2.InvalidateCookieResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
[docs]class AclApiStub(object):
"""Missing associated documentation comment in .proto file."""
def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
self.isSuperUser = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/isSuperUser',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
)
self.isAclEditor = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/isAclEditor',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
)
self.isQueryManager = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/isQueryManager',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
)
self.isSchemaManager = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/isSchemaManager',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
)
self.getUsersForGroup = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/getUsersForGroup',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryGroupRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
)
self.getGroupsForUser = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/getGroupsForUser',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
)
self.getAllUsers = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/getAllUsers',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.GetAllUsersRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
)
self.getAllGroups = channel.unary_unary(
'/io.deephaven.proto.controller.grpc.AclApi/getAllGroups',
request_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.GetAllGroupsRequest.SerializeToString,
response_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
)
[docs]class AclApiServicer(object):
"""Missing associated documentation comment in .proto file."""
[docs] def isSuperUser(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!')
[docs] def isAclEditor(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!')
[docs] def isQueryManager(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!')
[docs] def isSchemaManager(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!')
[docs] def getUsersForGroup(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!')
[docs] def getGroupsForUser(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!')
[docs] def getAllUsers(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!')
[docs] def getAllGroups(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_AclApiServicer_to_server(servicer, server):
rpc_method_handlers = {
'isSuperUser': grpc.unary_unary_rpc_method_handler(
servicer.isSuperUser,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.SerializeToString,
),
'isAclEditor': grpc.unary_unary_rpc_method_handler(
servicer.isAclEditor,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.SerializeToString,
),
'isQueryManager': grpc.unary_unary_rpc_method_handler(
servicer.isQueryManager,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.SerializeToString,
),
'isSchemaManager': grpc.unary_unary_rpc_method_handler(
servicer.isSchemaManager,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.SerializeToString,
),
'getUsersForGroup': grpc.unary_unary_rpc_method_handler(
servicer.getUsersForGroup,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryGroupRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.SerializeToString,
),
'getGroupsForUser': grpc.unary_unary_rpc_method_handler(
servicer.getGroupsForUser,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.SerializeToString,
),
'getAllUsers': grpc.unary_unary_rpc_method_handler(
servicer.getAllUsers,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.GetAllUsersRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.SerializeToString,
),
'getAllGroups': grpc.unary_unary_rpc_method_handler(
servicer.getAllGroups,
request_deserializer=deephaven__enterprise_dot_proto_dot_acl__pb2.GetAllGroupsRequest.FromString,
response_serializer=deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
'io.deephaven.proto.controller.grpc.AclApi', rpc_method_handlers)
server.add_generic_rpc_handlers((generic_handler,))
# This class is part of an EXPERIMENTAL API.
[docs]class AclApi(object):
"""Missing associated documentation comment in .proto file."""
@staticmethod
def isSuperUser(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, '/io.deephaven.proto.controller.grpc.AclApi/isSuperUser',
deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def isAclEditor(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, '/io.deephaven.proto.controller.grpc.AclApi/isAclEditor',
deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def isQueryManager(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, '/io.deephaven.proto.controller.grpc.AclApi/isQueryManager',
deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def isSchemaManager(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, '/io.deephaven.proto.controller.grpc.AclApi/isSchemaManager',
deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.BooleanResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getUsersForGroup(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, '/io.deephaven.proto.controller.grpc.AclApi/getUsersForGroup',
deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryGroupRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getGroupsForUser(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, '/io.deephaven.proto.controller.grpc.AclApi/getGroupsForUser',
deephaven__enterprise_dot_proto_dot_acl__pb2.UnaryUserRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getAllUsers(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, '/io.deephaven.proto.controller.grpc.AclApi/getAllUsers',
deephaven__enterprise_dot_proto_dot_acl__pb2.GetAllUsersRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)
@staticmethod
def getAllGroups(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, '/io.deephaven.proto.controller.grpc.AclApi/getAllGroups',
deephaven__enterprise_dot_proto_dot_acl__pb2.GetAllGroupsRequest.SerializeToString,
deephaven__enterprise_dot_proto_dot_acl__pb2.UserOrGroupList.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)