"""
@generated by mypy-protobuf. Do not edit manually!
isort:skip_file
Copyright (c) 2016-2022 Deephaven Data Labs and Patent Pending
"""
import builtins
import collections.abc
import deephaven_enterprise.proto.auth_pb2
import deephaven_enterprise.proto.controller_common_pb2
import deephaven_enterprise.proto.persistent_query_pb2
import google.protobuf.descriptor
import google.protobuf.internal.containers
import google.protobuf.internal.enum_type_wrapper
import google.protobuf.message
import sys
import typing
if sys.version_info >= (3, 10):
import typing as typing_extensions
else:
import typing_extensions
[docs]
DESCRIPTOR: google.protobuf.descriptor.FileDescriptor
class _ServerTypeEnum:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
class _ServerTypeEnumEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_ServerTypeEnum.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
STE_UNSPECIFIED: _ServerTypeEnum.ValueType # 0
STE_DISPATCHER: _ServerTypeEnum.ValueType # 1
STE_GROUP: _ServerTypeEnum.ValueType # 2
[docs]
class ServerTypeEnum(_ServerTypeEnum, metaclass=_ServerTypeEnumEnumTypeWrapper): ...
[docs]
STE_UNSPECIFIED: ServerTypeEnum.ValueType # 0
[docs]
STE_DISPATCHER: ServerTypeEnum.ValueType # 1
[docs]
STE_GROUP: ServerTypeEnum.ValueType # 2
[docs]
Global___ServerTypeEnum: typing_extensions.TypeAlias = ServerTypeEnum
class _WorkerProtocol:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
class _WorkerProtocolEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_WorkerProtocol.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
WP_UNSPECIFIED: _WorkerProtocol.ValueType # 0
WP_ENTERPRISE_COMM: _WorkerProtocol.ValueType # 1
"""The enterprise "Comm" Java-serialization based protocol used by Swing and other Java Client Processes"""
WP_ENTERPRISE_WEBSOCKET: _WorkerProtocol.ValueType # 2
"""The GWT-RPC based web socket protocol for the web UI"""
WP_COMMUNITY: _WorkerProtocol.ValueType # 3
"""The Community Core gRPC protocol"""
[docs]
class WorkerProtocol(_WorkerProtocol, metaclass=_WorkerProtocolEnumTypeWrapper): ...
[docs]
WP_UNSPECIFIED: WorkerProtocol.ValueType # 0
[docs]
WP_ENTERPRISE_COMM: WorkerProtocol.ValueType # 1
"""The enterprise "Comm" Java-serialization based protocol used by Swing and other Java Client Processes"""
[docs]
WP_ENTERPRISE_WEBSOCKET: WorkerProtocol.ValueType # 2
"""The GWT-RPC based web socket protocol for the web UI"""
"""The Community Core gRPC protocol"""
[docs]
Global___WorkerProtocol: typing_extensions.TypeAlias = WorkerProtocol
class _ScriptCommandEnum:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
class _ScriptCommandEnumEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_ScriptCommandEnum.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
SCE_UNSPECIFIED: _ScriptCommandEnum.ValueType # 0
SCE_GET_AS_SELF: _ScriptCommandEnum.ValueType # 1
SCE_GET_AS_OTHER: _ScriptCommandEnum.ValueType # 2
SCE_GET_FOR_QUERY: _ScriptCommandEnum.ValueType # 3
[docs]
class ScriptCommandEnum(_ScriptCommandEnum, metaclass=_ScriptCommandEnumEnumTypeWrapper): ...
[docs]
SCE_UNSPECIFIED: ScriptCommandEnum.ValueType # 0
[docs]
SCE_GET_AS_SELF: ScriptCommandEnum.ValueType # 1
[docs]
SCE_GET_AS_OTHER: ScriptCommandEnum.ValueType # 2
[docs]
SCE_GET_FOR_QUERY: ScriptCommandEnum.ValueType # 3
[docs]
Global___ScriptCommandEnum: typing_extensions.TypeAlias = ScriptCommandEnum
class _SubscriptionEvent:
ValueType = typing.NewType("ValueType", builtins.int)
V: typing_extensions.TypeAlias = ValueType
class _SubscriptionEventEnumTypeWrapper(google.protobuf.internal.enum_type_wrapper._EnumTypeWrapper[_SubscriptionEvent.ValueType], builtins.type):
DESCRIPTOR: google.protobuf.descriptor.EnumDescriptor
SE_UNSPECIFIED: _SubscriptionEvent.ValueType # 0
SE_PUT: _SubscriptionEvent.ValueType # 1
"""New query was added, or existing query was updated with the same serial"""
SE_REMOVE: _SubscriptionEvent.ValueType # 2
"""An existing query was removed"""
SE_CONFIG_UPDATE: _SubscriptionEvent.ValueType # 3
"""Configuration for the controller was updated"""
SE_BATCH_END: _SubscriptionEvent.ValueType # 4
"""Marks the end of the initial batch of events after subscription, may or may not include a queryInfo value; otherwise equivalent to SE_PUT"""
[docs]
class SubscriptionEvent(_SubscriptionEvent, metaclass=_SubscriptionEventEnumTypeWrapper): ...
[docs]
SE_UNSPECIFIED: SubscriptionEvent.ValueType # 0
[docs]
SE_PUT: SubscriptionEvent.ValueType # 1
"""New query was added, or existing query was updated with the same serial"""
[docs]
SE_REMOVE: SubscriptionEvent.ValueType # 2
"""An existing query was removed"""
[docs]
SE_CONFIG_UPDATE: SubscriptionEvent.ValueType # 3
"""Configuration for the controller was updated"""
[docs]
SE_BATCH_END: SubscriptionEvent.ValueType # 4
"""Marks the end of the initial batch of events after subscription, may or may not include a queryInfo value; otherwise equivalent to SE_PUT"""
[docs]
Global___SubscriptionEvent: typing_extensions.TypeAlias = SubscriptionEvent
@typing.final
[docs]
class AuthenticationRequest(google.protobuf.message.Message):
"""Controller API messages"""
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
TOKEN_FIELD_NUMBER: builtins.int
[docs]
CLIENTID_FIELD_NUMBER: builtins.int
[docs]
GETCONFIGURATION_FIELD_NUMBER: builtins.int
[docs]
getConfiguration: builtins.bool
@property
[docs]
def token(self) -> deephaven_enterprise.proto.auth_pb2.Token: ...
@property
[docs]
def clientId(self) -> deephaven_enterprise.proto.auth_pb2.ClientId: ...
def __init__(
self,
*,
token: deephaven_enterprise.proto.auth_pb2.Token | None = ...,
clientId: deephaven_enterprise.proto.auth_pb2.ClientId | None = ...,
getConfiguration: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["clientId", b"clientId", "token", b"token"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["clientId", b"clientId", "getConfiguration", b"getConfiguration", "token", b"token"]) -> None: ...
[docs]
Global___AuthenticationRequest: typing_extensions.TypeAlias = AuthenticationRequest
@typing.final
[docs]
class AuthenticationResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
AUTHENTICATED_FIELD_NUMBER: builtins.int
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
CONFIG_FIELD_NUMBER: builtins.int
[docs]
authenticated: builtins.bool
@property
[docs]
def config(self) -> Global___ControllerConfigurationMessage: ...
def __init__(
self,
*,
authenticated: builtins.bool = ...,
cookie: builtins.bytes = ...,
config: Global___ControllerConfigurationMessage | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_config", b"_config", "config", b"config"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_config", b"_config", "authenticated", b"authenticated", "config", b"config", "cookie", b"cookie"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_config", b"_config"]) -> typing.Literal["config"] | None: ...
[docs]
Global___AuthenticationResponse: typing_extensions.TypeAlias = AuthenticationResponse
@typing.final
[docs]
class AddQueryRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
CONFIG_FIELD_NUMBER: builtins.int
@property
[docs]
def config(self) -> deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
config: deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["config", b"config"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["config", b"config", "cookie", b"cookie"]) -> None: ...
[docs]
Global___AddQueryRequest: typing_extensions.TypeAlias = AddQueryRequest
@typing.final
[docs]
class AddQueryResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
QUERYSERIAL_FIELD_NUMBER: builtins.int
[docs]
querySerial: builtins.int
def __init__(
self,
*,
querySerial: builtins.int = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["querySerial", b"querySerial"]) -> None: ...
[docs]
Global___AddQueryResponse: typing_extensions.TypeAlias = AddQueryResponse
@typing.final
[docs]
class RemoveQueryRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
SERIAL_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
cookie: builtins.bytes = ...,
serial: builtins.int = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "serial", b"serial"]) -> None: ...
[docs]
Global___RemoveQueryRequest: typing_extensions.TypeAlias = RemoveQueryRequest
@typing.final
[docs]
class RemoveQueryResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
def __init__(
self,
) -> None: ...
[docs]
Global___RemoveQueryResponse: typing_extensions.TypeAlias = RemoveQueryResponse
@typing.final
[docs]
class ModifyQueryRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
CONFIG_FIELD_NUMBER: builtins.int
[docs]
DORESTART_FIELD_NUMBER: builtins.int
[docs]
doRestart: builtins.bool
@property
[docs]
def config(self) -> deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
config: deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage | None = ...,
doRestart: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["config", b"config"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["config", b"config", "cookie", b"cookie", "doRestart", b"doRestart"]) -> None: ...
[docs]
Global___ModifyQueryRequest: typing_extensions.TypeAlias = ModifyQueryRequest
@typing.final
[docs]
class ModifyQueryResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
def __init__(
self,
) -> None: ...
[docs]
Global___ModifyQueryResponse: typing_extensions.TypeAlias = ModifyQueryResponse
@typing.final
[docs]
class ReplicaSpecifier(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
SERIAL_FIELD_NUMBER: builtins.int
[docs]
REPLICA_FIELD_NUMBER: builtins.int
[docs]
SPARE_FIELD_NUMBER: builtins.int
[docs]
PROCESSINFOID_FIELD_NUMBER: builtins.int
[docs]
processInfoId: builtins.str
def __init__(
self,
*,
serial: builtins.int = ...,
replica: builtins.int = ...,
spare: builtins.int = ...,
processInfoId: builtins.str | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_processInfoId", b"_processInfoId", "id", b"id", "processInfoId", b"processInfoId", "replica", b"replica", "spare", b"spare"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_processInfoId", b"_processInfoId", "id", b"id", "processInfoId", b"processInfoId", "replica", b"replica", "serial", b"serial", "spare", b"spare"]) -> None: ...
@typing.overload
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_processInfoId", b"_processInfoId"]) -> typing.Literal["processInfoId"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing.Literal["id", b"id"]) -> typing.Literal["replica", "spare"] | None: ...
[docs]
Global___ReplicaSpecifier: typing_extensions.TypeAlias = ReplicaSpecifier
@typing.final
[docs]
class ReplicaStatus(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
REPLICA_FIELD_NUMBER: builtins.int
[docs]
SUCCESS_FIELD_NUMBER: builtins.int
[docs]
ERROR_FIELD_NUMBER: builtins.int
@property
[docs]
def replica(self) -> Global___ReplicaSpecifier: ...
def __init__(
self,
*,
replica: Global___ReplicaSpecifier | None = ...,
success: builtins.bool = ...,
error: builtins.str | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_error", b"_error", "error", b"error", "replica", b"replica"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_error", b"_error", "error", b"error", "replica", b"replica", "success", b"success"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_error", b"_error"]) -> typing.Literal["error"] | None: ...
[docs]
Global___ReplicaStatus: typing_extensions.TypeAlias = ReplicaStatus
@typing.final
[docs]
class RestartReplicaRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
REPLICAS_FIELD_NUMBER: builtins.int
@property
[docs]
def replicas(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ReplicaSpecifier]: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
replicas: collections.abc.Iterable[Global___ReplicaSpecifier] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "replicas", b"replicas"]) -> None: ...
[docs]
Global___RestartReplicaRequest: typing_extensions.TypeAlias = RestartReplicaRequest
@typing.final
[docs]
class RestartReplicaResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
STATUS_FIELD_NUMBER: builtins.int
@property
[docs]
def status(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ReplicaStatus]: ...
def __init__(
self,
*,
status: collections.abc.Iterable[Global___ReplicaStatus] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["status", b"status"]) -> None: ...
[docs]
Global___RestartReplicaResponse: typing_extensions.TypeAlias = RestartReplicaResponse
@typing.final
[docs]
class StopReplicaRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
REPLICAS_FIELD_NUMBER: builtins.int
@property
[docs]
def replicas(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ReplicaSpecifier]: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
replicas: collections.abc.Iterable[Global___ReplicaSpecifier] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "replicas", b"replicas"]) -> None: ...
[docs]
Global___StopReplicaRequest: typing_extensions.TypeAlias = StopReplicaRequest
@typing.final
[docs]
class StopReplicaResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
STATUS_FIELD_NUMBER: builtins.int
@property
[docs]
def status(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ReplicaStatus]: ...
def __init__(
self,
*,
status: collections.abc.Iterable[Global___ReplicaStatus] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["status", b"status"]) -> None: ...
[docs]
Global___StopReplicaResponse: typing_extensions.TypeAlias = StopReplicaResponse
@typing.final
[docs]
class RestartQueryRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
SERIALS_FIELD_NUMBER: builtins.int
@property
[docs]
def serials(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.int]: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
serials: collections.abc.Iterable[builtins.int] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "serials", b"serials"]) -> None: ...
[docs]
Global___RestartQueryRequest: typing_extensions.TypeAlias = RestartQueryRequest
@typing.final
[docs]
class RestartQueryResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@typing.final
[docs]
class ErrorSerialsEntry(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
KEY_FIELD_NUMBER: builtins.int
[docs]
VALUE_FIELD_NUMBER: builtins.int
[docs]
value: builtins.str
def __init__(
self,
*,
key: builtins.int = ...,
value: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["key", b"key", "value", b"value"]) -> None: ...
[docs]
SUCCESSSERIALS_FIELD_NUMBER: builtins.int
[docs]
ERRORSERIALS_FIELD_NUMBER: builtins.int
@property
[docs]
def successSerials(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.int]: ...
@property
[docs]
def errorSerials(self) -> google.protobuf.internal.containers.ScalarMap[builtins.int, builtins.str]: ...
def __init__(
self,
*,
successSerials: collections.abc.Iterable[builtins.int] | None = ...,
errorSerials: collections.abc.Mapping[builtins.int, builtins.str] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["errorSerials", b"errorSerials", "successSerials", b"successSerials"]) -> None: ...
[docs]
Global___RestartQueryResponse: typing_extensions.TypeAlias = RestartQueryResponse
@typing.final
[docs]
class StopQueryRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
SERIALS_FIELD_NUMBER: builtins.int
@property
[docs]
def serials(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.int]: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
serials: collections.abc.Iterable[builtins.int] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "serials", b"serials"]) -> None: ...
[docs]
Global___StopQueryRequest: typing_extensions.TypeAlias = StopQueryRequest
@typing.final
[docs]
class StopQueryResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@typing.final
[docs]
class ErrorSerialsEntry(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
KEY_FIELD_NUMBER: builtins.int
[docs]
VALUE_FIELD_NUMBER: builtins.int
[docs]
value: builtins.str
def __init__(
self,
*,
key: builtins.int = ...,
value: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["key", b"key", "value", b"value"]) -> None: ...
[docs]
SUCCESSSERIALS_FIELD_NUMBER: builtins.int
[docs]
ERRORSERIALS_FIELD_NUMBER: builtins.int
@property
[docs]
def successSerials(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.int]: ...
@property
[docs]
def errorSerials(self) -> google.protobuf.internal.containers.ScalarMap[builtins.int, builtins.str]: ...
def __init__(
self,
*,
successSerials: collections.abc.Iterable[builtins.int] | None = ...,
errorSerials: collections.abc.Mapping[builtins.int, builtins.str] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["errorSerials", b"errorSerials", "successSerials", b"successSerials"]) -> None: ...
[docs]
Global___StopQueryResponse: typing_extensions.TypeAlias = StopQueryResponse
@typing.final
[docs]
class DetermineDispatcherRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
SERVERGROUPNAME_FIELD_NUMBER: builtins.int
[docs]
HEAPSIZEMB_FIELD_NUMBER: builtins.int
[docs]
WORKERKIND_FIELD_NUMBER: builtins.int
[docs]
serverGroupName: builtins.str
[docs]
heapSizeMb: builtins.int
[docs]
workerKind: builtins.str
def __init__(
self,
*,
cookie: builtins.bytes = ...,
serverGroupName: builtins.str = ...,
heapSizeMb: builtins.int = ...,
workerKind: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "heapSizeMb", b"heapSizeMb", "serverGroupName", b"serverGroupName", "workerKind", b"workerKind"]) -> None: ...
[docs]
Global___DetermineDispatcherRequest: typing_extensions.TypeAlias = DetermineDispatcherRequest
@typing.final
[docs]
class DetermineDispatcherResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
SERVERCONFIG_FIELD_NUMBER: builtins.int
@property
[docs]
def serverConfig(self) -> Global___PQDBServerConfigMessage: ...
def __init__(
self,
*,
serverConfig: Global___PQDBServerConfigMessage | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["serverConfig", b"serverConfig"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["serverConfig", b"serverConfig"]) -> None: ...
[docs]
Global___DetermineDispatcherResponse: typing_extensions.TypeAlias = DetermineDispatcherResponse
@typing.final
[docs]
class PQDBServerConfigMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
HOST_FIELD_NUMBER: builtins.int
[docs]
PORT_FIELD_NUMBER: builtins.int
[docs]
CLASSPUSHLISTRESOURCENAME_FIELD_NUMBER: builtins.int
[docs]
SERVERCLASS_FIELD_NUMBER: builtins.int
[docs]
MAXHEAPSIZEGB_FIELD_NUMBER: builtins.int
[docs]
SERVERTYPE_FIELD_NUMBER: builtins.int
[docs]
CONSOLEGROUPS_FIELD_NUMBER: builtins.int
[docs]
SERVERINFO_FIELD_NUMBER: builtins.int
[docs]
CONSOLE_PERMITTED_FIELD_NUMBER: builtins.int
"""Will always be "Group" if serverType is STE_GROUP"""
[docs]
classPushListResourceName: builtins.str
[docs]
serverClass: builtins.str
[docs]
maxHeapSizeGb: builtins.float
[docs]
serverType: Global___ServerTypeEnum.ValueType
[docs]
serverInfo: builtins.str
[docs]
console_permitted: builtins.bool
"""True if the current user is permitted to create consoles on this server"""
@property
[docs]
def consoleGroups(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]:
"""Indicates which groups can start consoles on this server. Empty means any user may do this."""
def __init__(
self,
*,
name: builtins.str = ...,
host: builtins.str = ...,
port: builtins.int = ...,
classPushListResourceName: builtins.str | None = ...,
serverClass: builtins.str = ...,
maxHeapSizeGb: builtins.float = ...,
serverType: Global___ServerTypeEnum.ValueType = ...,
consoleGroups: collections.abc.Iterable[builtins.str] | None = ...,
serverInfo: builtins.str | None = ...,
console_permitted: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_classPushListResourceName", b"_classPushListResourceName", "_serverInfo", b"_serverInfo", "classPushListResourceName", b"classPushListResourceName", "serverInfo", b"serverInfo"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_classPushListResourceName", b"_classPushListResourceName", "_serverInfo", b"_serverInfo", "classPushListResourceName", b"classPushListResourceName", "consoleGroups", b"consoleGroups", "console_permitted", b"console_permitted", "host", b"host", "maxHeapSizeGb", b"maxHeapSizeGb", "name", b"name", "port", b"port", "serverClass", b"serverClass", "serverInfo", b"serverInfo", "serverType", b"serverType"]) -> None: ...
@typing.overload
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_classPushListResourceName", b"_classPushListResourceName"]) -> typing.Literal["classPushListResourceName"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing.Literal["_serverInfo", b"_serverInfo"]) -> typing.Literal["serverInfo"] | None: ...
[docs]
Global___PQDBServerConfigMessage: typing_extensions.TypeAlias = PQDBServerConfigMessage
@typing.final
[docs]
class AssignmentPolicyConfigMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
DISPLAYNAME_FIELD_NUMBER: builtins.int
[docs]
DESCRIPTION_FIELD_NUMBER: builtins.int
[docs]
ACCEPTSPARAMETERS_FIELD_NUMBER: builtins.int
[docs]
displayName: builtins.str
[docs]
description: builtins.str
[docs]
acceptsParameters: builtins.bool
def __init__(
self,
*,
name: builtins.str = ...,
displayName: builtins.str = ...,
description: builtins.str | None = ...,
acceptsParameters: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_description", b"_description", "description", b"description"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_description", b"_description", "acceptsParameters", b"acceptsParameters", "description", b"description", "displayName", b"displayName", "name", b"name"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_description", b"_description"]) -> typing.Literal["description"] | None: ...
[docs]
Global___AssignmentPolicyConfigMessage: typing_extensions.TypeAlias = AssignmentPolicyConfigMessage
@typing.final
[docs]
class WorkerKind(google.protobuf.message.Message):
"""A WorkerKind is displayed as an "Engine" in the UI, and defines either the Legacy worker or version of Core+ with
associated configuration (e.g., extra packages; properties, etc.).
"""
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
DESCRIPTION_FIELD_NUMBER: builtins.int
[docs]
TITLE_FIELD_NUMBER: builtins.int
[docs]
WORKER_CONTROL_TYPES_FIELD_NUMBER: builtins.int
[docs]
IMPLEMENTED_PROTOCOLS_FIELD_NUMBER: builtins.int
[docs]
EPHEMERAL_VENV_DEFAULT_FIELD_NUMBER: builtins.int
"""The name of the worker kind used in persistent query configurations"""
[docs]
description: builtins.str
"""The title used for drop-down selections in the UI"""
[docs]
ephemeral_venv_default: builtins.bool
"""Should this worker kind create an ephemeral Python virtual environment by default."""
@property
[docs]
def worker_control_types(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]:
"""What kind of worker control types are supported by this worker kind (e.g., local process or kubernetes)"""
@property
[docs]
def implemented_protocols(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[Global___WorkerProtocol.ValueType]:
"""The protocols implemented by this worker kind"""
def __init__(
self,
*,
name: builtins.str = ...,
description: builtins.str = ...,
title: builtins.str = ...,
worker_control_types: collections.abc.Iterable[builtins.str] | None = ...,
implemented_protocols: collections.abc.Iterable[Global___WorkerProtocol.ValueType] | None = ...,
ephemeral_venv_default: builtins.bool = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["description", b"description", "ephemeral_venv_default", b"ephemeral_venv_default", "implemented_protocols", b"implemented_protocols", "name", b"name", "title", b"title", "worker_control_types", b"worker_control_types"]) -> None: ...
[docs]
Global___WorkerKind: typing_extensions.TypeAlias = WorkerKind
@typing.final
[docs]
class GetConfigurationRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
cookie: builtins.bytes = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie"]) -> None: ...
[docs]
Global___GetConfigurationRequest: typing_extensions.TypeAlias = GetConfigurationRequest
@typing.final
[docs]
class GetConfigurationResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
CONFIG_FIELD_NUMBER: builtins.int
@property
[docs]
def config(self) -> Global___ControllerConfigurationMessage: ...
def __init__(
self,
*,
config: Global___ControllerConfigurationMessage | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["config", b"config"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["config", b"config"]) -> None: ...
[docs]
Global___GetConfigurationResponse: typing_extensions.TypeAlias = GetConfigurationResponse
@typing.final
[docs]
class ControllerConfigurationMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
MAXHEAPSIZEGB_FIELD_NUMBER: builtins.int
[docs]
MINDATABUFFERPOOLRATIO_FIELD_NUMBER: builtins.int
[docs]
MAXDATABUFFERPOOLRATIO_FIELD_NUMBER: builtins.int
[docs]
CONFIGURATIONTYPES_FIELD_NUMBER: builtins.int
[docs]
TEMPORARYQUEUEDETAILS_FIELD_NUMBER: builtins.int
[docs]
DEFAULTTEMPQUEUENAME_FIELD_NUMBER: builtins.int
[docs]
DBSERVERS_FIELD_NUMBER: builtins.int
[docs]
DEFAULTSCHEDULINGDETAILS_FIELD_NUMBER: builtins.int
[docs]
SCHEDULELOOKFORWARDDAYS_FIELD_NUMBER: builtins.int
[docs]
PUBLICKEY_FIELD_NUMBER: builtins.int
[docs]
ALGORITHM_FIELD_NUMBER: builtins.int
[docs]
CONSOLESERVERGROUPS_FIELD_NUMBER: builtins.int
[docs]
JVMPROFILENAMES_FIELD_NUMBER: builtins.int
[docs]
DEFAULTJVMPROFILENAME_FIELD_NUMBER: builtins.int
[docs]
DATAROUTINGIMPLNAME_FIELD_NUMBER: builtins.int
[docs]
TDSCONFIGS_FIELD_NUMBER: builtins.int
[docs]
DISCONFIGS_FIELD_NUMBER: builtins.int
[docs]
LASCONFIGS_FIELD_NUMBER: builtins.int
[docs]
ASSIGNMENTPOLICIES_FIELD_NUMBER: builtins.int
[docs]
DEFAULTASSIGNMENTPOLICYNAME_FIELD_NUMBER: builtins.int
[docs]
DEFAULTASSIGNMENTPOLICYPARAMS_FIELD_NUMBER: builtins.int
[docs]
SUPPORTED_WORKER_KINDS_FIELD_NUMBER: builtins.int
[docs]
DEFAULT_WORKER_KIND_FIELD_NUMBER: builtins.int
[docs]
MIN_HEAP_SIZE_GB_FIELD_NUMBER: builtins.int
[docs]
maxHeapSizeGb: builtins.int
[docs]
minDataBufferPoolRatio: builtins.float
[docs]
maxDataBufferPoolRatio: builtins.float
[docs]
defaultTempQueueName: builtins.str
[docs]
scheduleLookForwardDays: builtins.int
[docs]
publicKey: builtins.bytes
[docs]
algorithm: builtins.str
[docs]
defaultJvmProfileName: builtins.str
[docs]
dataRoutingImplName: builtins.str
[docs]
defaultAssignmentPolicyName: builtins.str
[docs]
defaultAssignmentPolicyParams: builtins.str
[docs]
default_worker_kind: builtins.str
"""the default worker kind for configurations that do not have a worker kind specified; this is distinct from the
default value that should be displayed in the UI, which is determined by the order of the worker kinds in the
supported_worker_kinds field.
"""
[docs]
min_heap_size_gb: builtins.float
@property
[docs]
def configurationTypes(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ConsoleConfigurationTypeMessage]: ...
@property
[docs]
def temporaryQueueDetails(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ControllerTempQueueDetailsMessage]: ...
@property
[docs]
def dbServers(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___PQDBServerConfigMessage]: ...
@property
[docs]
def defaultSchedulingDetails(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: ...
@property
[docs]
def consoleServerGroups(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[deephaven_enterprise.proto.controller_common_pb2.NamedStringList]: ...
@property
[docs]
def jvmProfileNames(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: ...
@property
[docs]
def tdsConfigs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___RoutingConfigMessage]: ...
@property
[docs]
def disConfigs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___RoutingConfigMessage]: ...
@property
[docs]
def lasConfigs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___RoutingConfigMessage]: ...
@property
[docs]
def assignmentPolicies(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___AssignmentPolicyConfigMessage]: ...
@property
[docs]
def supported_worker_kinds(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___WorkerKind]: ...
def __init__(
self,
*,
maxHeapSizeGb: builtins.int = ...,
minDataBufferPoolRatio: builtins.float = ...,
maxDataBufferPoolRatio: builtins.float = ...,
configurationTypes: collections.abc.Iterable[Global___ConsoleConfigurationTypeMessage] | None = ...,
temporaryQueueDetails: collections.abc.Iterable[Global___ControllerTempQueueDetailsMessage] | None = ...,
defaultTempQueueName: builtins.str = ...,
dbServers: collections.abc.Iterable[Global___PQDBServerConfigMessage] | None = ...,
defaultSchedulingDetails: collections.abc.Iterable[builtins.str] | None = ...,
scheduleLookForwardDays: builtins.int = ...,
publicKey: builtins.bytes = ...,
algorithm: builtins.str = ...,
consoleServerGroups: collections.abc.Iterable[deephaven_enterprise.proto.controller_common_pb2.NamedStringList] | None = ...,
jvmProfileNames: collections.abc.Iterable[builtins.str] | None = ...,
defaultJvmProfileName: builtins.str = ...,
dataRoutingImplName: builtins.str = ...,
tdsConfigs: collections.abc.Iterable[Global___RoutingConfigMessage] | None = ...,
disConfigs: collections.abc.Iterable[Global___RoutingConfigMessage] | None = ...,
lasConfigs: collections.abc.Iterable[Global___RoutingConfigMessage] | None = ...,
assignmentPolicies: collections.abc.Iterable[Global___AssignmentPolicyConfigMessage] | None = ...,
defaultAssignmentPolicyName: builtins.str = ...,
defaultAssignmentPolicyParams: builtins.str = ...,
supported_worker_kinds: collections.abc.Iterable[Global___WorkerKind] | None = ...,
default_worker_kind: builtins.str = ...,
min_heap_size_gb: builtins.float = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["algorithm", b"algorithm", "assignmentPolicies", b"assignmentPolicies", "configurationTypes", b"configurationTypes", "consoleServerGroups", b"consoleServerGroups", "dataRoutingImplName", b"dataRoutingImplName", "dbServers", b"dbServers", "defaultAssignmentPolicyName", b"defaultAssignmentPolicyName", "defaultAssignmentPolicyParams", b"defaultAssignmentPolicyParams", "defaultJvmProfileName", b"defaultJvmProfileName", "defaultSchedulingDetails", b"defaultSchedulingDetails", "defaultTempQueueName", b"defaultTempQueueName", "default_worker_kind", b"default_worker_kind", "disConfigs", b"disConfigs", "jvmProfileNames", b"jvmProfileNames", "lasConfigs", b"lasConfigs", "maxDataBufferPoolRatio", b"maxDataBufferPoolRatio", "maxHeapSizeGb", b"maxHeapSizeGb", "minDataBufferPoolRatio", b"minDataBufferPoolRatio", "min_heap_size_gb", b"min_heap_size_gb", "publicKey", b"publicKey", "scheduleLookForwardDays", b"scheduleLookForwardDays", "supported_worker_kinds", b"supported_worker_kinds", "tdsConfigs", b"tdsConfigs", "temporaryQueueDetails", b"temporaryQueueDetails"]) -> None: ...
[docs]
Global___ControllerConfigurationMessage: typing_extensions.TypeAlias = ControllerConfigurationMessage
@typing.final
[docs]
class RoutingConfigMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
DESCRIPTION_FIELD_NUMBER: builtins.int
[docs]
description: builtins.str
@property
def __init__(
self,
*,
name: builtins.str = ...,
tags: collections.abc.Iterable[builtins.str] | None = ...,
description: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["description", b"description", "name", b"name", "tags", b"tags"]) -> None: ...
[docs]
Global___RoutingConfigMessage: typing_extensions.TypeAlias = RoutingConfigMessage
@typing.final
[docs]
class ControllerTempQueueDetailsMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
MAXCONCURRENTQUERIES_FIELD_NUMBER: builtins.int
[docs]
MAXHEAPMB_FIELD_NUMBER: builtins.int
[docs]
maxConcurrentQueries: builtins.int
[docs]
maxHeapMb: builtins.int
def __init__(
self,
*,
name: builtins.str = ...,
maxConcurrentQueries: builtins.int = ...,
maxHeapMb: builtins.int = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["maxConcurrentQueries", b"maxConcurrentQueries", "maxHeapMb", b"maxHeapMb", "name", b"name"]) -> None: ...
[docs]
Global___ControllerTempQueueDetailsMessage: typing_extensions.TypeAlias = ControllerTempQueueDetailsMessage
@typing.final
[docs]
class ConsoleConfigurationTypeMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@typing.final
[docs]
class PropertiesEntry(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
KEY_FIELD_NUMBER: builtins.int
[docs]
VALUE_FIELD_NUMBER: builtins.int
[docs]
value: builtins.str
def __init__(
self,
*,
key: builtins.str = ...,
value: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["key", b"key", "value", b"value"]) -> None: ...
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
DISPLAYNAME_FIELD_NUMBER: builtins.int
[docs]
DISPLAYABLE_FIELD_NUMBER: builtins.int
[docs]
PROPERTIES_FIELD_NUMBER: builtins.int
[docs]
HASSCRIPT_FIELD_NUMBER: builtins.int
[docs]
SERVERCLASSES_FIELD_NUMBER: builtins.int
[docs]
ALLOWEDGROUPS_FIELD_NUMBER: builtins.int
[docs]
EXTRACOLUMNS_FIELD_NUMBER: builtins.int
[docs]
TYPESPECIFICWIRECONFIGJSON_FIELD_NUMBER: builtins.int
[docs]
CONFIGCHECKERCLASS_FIELD_NUMBER: builtins.int
[docs]
CONFIGPANELFACTORYCLASS_FIELD_NUMBER: builtins.int
[docs]
CUSTOMACTIONPROVIDERCLASS_FIELD_NUMBER: builtins.int
[docs]
SETUPQUERYCLASS_FIELD_NUMBER: builtins.int
[docs]
CONFIGCLASS_FIELD_NUMBER: builtins.int
[docs]
SHUTDOWNPROCEDURECLASS_FIELD_NUMBER: builtins.int
[docs]
CONFIGPROCESSORCLASS_FIELD_NUMBER: builtins.int
[docs]
EXTRACOLUMNGETTERCLASS_FIELD_NUMBER: builtins.int
[docs]
CONFIGTYPEDETAILSCLASS_FIELD_NUMBER: builtins.int
[docs]
HASSCRIPTLANGUAGE_FIELD_NUMBER: builtins.int
[docs]
SUPPORTSREPLICAS_FIELD_NUMBER: builtins.int
[docs]
displayName: builtins.str
[docs]
displayable: builtins.bool
[docs]
hasScript: builtins.bool
[docs]
typeSpecificWireConfigJSON: builtins.str
[docs]
configCheckerClass: builtins.str
[docs]
configPanelFactoryClass: builtins.str
[docs]
customActionProviderClass: builtins.str
[docs]
setupQueryClass: builtins.str
[docs]
configClass: builtins.str
[docs]
shutdownProcedureClass: builtins.str
[docs]
configProcessorClass: builtins.str
[docs]
extraColumnGetterClass: builtins.str
[docs]
configTypeDetailsClass: builtins.str
[docs]
hasScriptLanguage: builtins.bool
[docs]
supportsReplicas: builtins.bool
@property
[docs]
def properties(self) -> google.protobuf.internal.containers.ScalarMap[builtins.str, builtins.str]: ...
@property
[docs]
def serverClasses(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: ...
@property
[docs]
def allowedGroups(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: ...
@property
[docs]
def extraColumns(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___ExtraColumnMessage]: ...
@property
def __init__(
self,
*,
name: builtins.str = ...,
displayName: builtins.str = ...,
displayable: builtins.bool = ...,
properties: collections.abc.Mapping[builtins.str, builtins.str] | None = ...,
hasScript: builtins.bool = ...,
serverClasses: collections.abc.Iterable[builtins.str] | None = ...,
allowedGroups: collections.abc.Iterable[builtins.str] | None = ...,
extraColumns: collections.abc.Iterable[Global___ExtraColumnMessage] | None = ...,
typeSpecificWireConfigJSON: builtins.str | None = ...,
configCheckerClass: builtins.str = ...,
configPanelFactoryClass: builtins.str = ...,
customActionProviderClass: builtins.str = ...,
setupQueryClass: builtins.str = ...,
configClass: builtins.str = ...,
shutdownProcedureClass: builtins.str = ...,
extraJvmArgsClass: builtins.str = ...,
configProcessorClass: builtins.str = ...,
extraColumnGetterClass: builtins.str = ...,
popupProviderClass: collections.abc.Iterable[builtins.str] | None = ...,
configTypeDetailsClass: builtins.str = ...,
communityInitializerClass: builtins.str = ...,
hasScriptLanguage: builtins.bool = ...,
communityRequestProcessorClass: builtins.str = ...,
supportsReplicas: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_typeSpecificWireConfigJSON", b"_typeSpecificWireConfigJSON", "typeSpecificWireConfigJSON", b"typeSpecificWireConfigJSON"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_typeSpecificWireConfigJSON", b"_typeSpecificWireConfigJSON", "allowedGroups", b"allowedGroups", "communityInitializerClass", b"communityInitializerClass", "communityRequestProcessorClass", b"communityRequestProcessorClass", "configCheckerClass", b"configCheckerClass", "configClass", b"configClass", "configPanelFactoryClass", b"configPanelFactoryClass", "configProcessorClass", b"configProcessorClass", "configTypeDetailsClass", b"configTypeDetailsClass", "customActionProviderClass", b"customActionProviderClass", "displayName", b"displayName", "displayable", b"displayable", "extraColumnGetterClass", b"extraColumnGetterClass", "extraColumns", b"extraColumns", "extraJvmArgsClass", b"extraJvmArgsClass", "hasScript", b"hasScript", "hasScriptLanguage", b"hasScriptLanguage", "name", b"name", "popupProviderClass", b"popupProviderClass", "properties", b"properties", "serverClasses", b"serverClasses", "setupQueryClass", b"setupQueryClass", "shutdownProcedureClass", b"shutdownProcedureClass", "supportsReplicas", b"supportsReplicas", "typeSpecificWireConfigJSON", b"typeSpecificWireConfigJSON"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_typeSpecificWireConfigJSON", b"_typeSpecificWireConfigJSON"]) -> typing.Literal["typeSpecificWireConfigJSON"] | None: ...
[docs]
Global___ConsoleConfigurationTypeMessage: typing_extensions.TypeAlias = ConsoleConfigurationTypeMessage
@typing.final
[docs]
class ExtraColumnMessage(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
NAME_FIELD_NUMBER: builtins.int
[docs]
RENDERERNAME_FIELD_NUMBER: builtins.int
[docs]
rendererName: builtins.str
def __init__(
self,
*,
name: builtins.str = ...,
rendererName: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["name", b"name", "rendererName", b"rendererName"]) -> None: ...
[docs]
Global___ExtraColumnMessage: typing_extensions.TypeAlias = ExtraColumnMessage
@typing.final
[docs]
class ServerSelectionStatusRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
cookie: builtins.bytes = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie"]) -> None: ...
[docs]
Global___ServerSelectionStatusRequest: typing_extensions.TypeAlias = ServerSelectionStatusRequest
@typing.final
[docs]
class ServerSelectionStatusResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
STATUS_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
status: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["status", b"status"]) -> None: ...
[docs]
Global___ServerSelectionStatusResponse: typing_extensions.TypeAlias = ServerSelectionStatusResponse
@typing.final
[docs]
class ServerSelectionAdminRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
COMMAND_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
cookie: builtins.bytes = ...,
command: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["command", b"command", "cookie", b"cookie"]) -> None: ...
[docs]
Global___ServerSelectionAdminRequest: typing_extensions.TypeAlias = ServerSelectionAdminRequest
@typing.final
[docs]
class ServerSelectionAdminResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
RESULT_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
result: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["result", b"result"]) -> None: ...
[docs]
Global___ServerSelectionAdminResponse: typing_extensions.TypeAlias = ServerSelectionAdminResponse
@typing.final
[docs]
class GetScriptPathsRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
COMMAND_FIELD_NUMBER: builtins.int
[docs]
QUERYSERIAL_FIELD_NUMBER: builtins.int
[docs]
EFFECTIVEUSER_FIELD_NUMBER: builtins.int
[docs]
SCRIPTLOADERSTATEJSON_FIELD_NUMBER: builtins.int
[docs]
USERELATIVEPATH_FIELD_NUMBER: builtins.int
[docs]
command: Global___ScriptCommandEnum.ValueType
[docs]
querySerial: builtins.int
[docs]
effectiveUser: builtins.str
[docs]
scriptLoaderStateJSON: builtins.str
[docs]
useRelativePath: builtins.bool
def __init__(
self,
*,
cookie: builtins.bytes = ...,
command: Global___ScriptCommandEnum.ValueType = ...,
querySerial: builtins.int | None = ...,
effectiveUser: builtins.str | None = ...,
scriptLoaderStateJSON: builtins.str | None = ...,
useRelativePath: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_effectiveUser", b"_effectiveUser", "_querySerial", b"_querySerial", "_scriptLoaderStateJSON", b"_scriptLoaderStateJSON", "effectiveUser", b"effectiveUser", "querySerial", b"querySerial", "scriptLoaderStateJSON", b"scriptLoaderStateJSON"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_effectiveUser", b"_effectiveUser", "_querySerial", b"_querySerial", "_scriptLoaderStateJSON", b"_scriptLoaderStateJSON", "command", b"command", "cookie", b"cookie", "effectiveUser", b"effectiveUser", "querySerial", b"querySerial", "scriptLoaderStateJSON", b"scriptLoaderStateJSON", "useRelativePath", b"useRelativePath"]) -> None: ...
@typing.overload
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_effectiveUser", b"_effectiveUser"]) -> typing.Literal["effectiveUser"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing.Literal["_querySerial", b"_querySerial"]) -> typing.Literal["querySerial"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing.Literal["_scriptLoaderStateJSON", b"_scriptLoaderStateJSON"]) -> typing.Literal["scriptLoaderStateJSON"] | None: ...
[docs]
Global___GetScriptPathsRequest: typing_extensions.TypeAlias = GetScriptPathsRequest
@typing.final
[docs]
class GetScriptPathsResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
RESULTS_FIELD_NUMBER: builtins.int
@property
[docs]
def results(self) -> google.protobuf.internal.containers.RepeatedScalarFieldContainer[builtins.str]: ...
def __init__(
self,
*,
results: collections.abc.Iterable[builtins.str] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["results", b"results"]) -> None: ...
[docs]
Global___GetScriptPathsResponse: typing_extensions.TypeAlias = GetScriptPathsResponse
@typing.final
[docs]
class GetScriptRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
COMMAND_FIELD_NUMBER: builtins.int
[docs]
QUERYSERIAL_FIELD_NUMBER: builtins.int
[docs]
EFFECTIVEUSER_FIELD_NUMBER: builtins.int
[docs]
SCRIPTLOADERSTATEJSON_FIELD_NUMBER: builtins.int
[docs]
SCRIPTPATH_FIELD_NUMBER: builtins.int
[docs]
USERELATIVEPATH_FIELD_NUMBER: builtins.int
[docs]
command: Global___ScriptCommandEnum.ValueType
[docs]
querySerial: builtins.int
[docs]
effectiveUser: builtins.str
[docs]
scriptLoaderStateJSON: builtins.str
[docs]
scriptPath: builtins.str
[docs]
useRelativePath: builtins.bool
def __init__(
self,
*,
cookie: builtins.bytes = ...,
command: Global___ScriptCommandEnum.ValueType = ...,
querySerial: builtins.int | None = ...,
effectiveUser: builtins.str | None = ...,
scriptLoaderStateJSON: builtins.str | None = ...,
scriptPath: builtins.str = ...,
useRelativePath: builtins.bool = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_effectiveUser", b"_effectiveUser", "_querySerial", b"_querySerial", "_scriptLoaderStateJSON", b"_scriptLoaderStateJSON", "effectiveUser", b"effectiveUser", "querySerial", b"querySerial", "scriptLoaderStateJSON", b"scriptLoaderStateJSON"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_effectiveUser", b"_effectiveUser", "_querySerial", b"_querySerial", "_scriptLoaderStateJSON", b"_scriptLoaderStateJSON", "command", b"command", "cookie", b"cookie", "effectiveUser", b"effectiveUser", "querySerial", b"querySerial", "scriptLoaderStateJSON", b"scriptLoaderStateJSON", "scriptPath", b"scriptPath", "useRelativePath", b"useRelativePath"]) -> None: ...
@typing.overload
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_effectiveUser", b"_effectiveUser"]) -> typing.Literal["effectiveUser"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing.Literal["_querySerial", b"_querySerial"]) -> typing.Literal["querySerial"] | None: ...
@typing.overload
def WhichOneof(self, oneof_group: typing.Literal["_scriptLoaderStateJSON", b"_scriptLoaderStateJSON"]) -> typing.Literal["scriptLoaderStateJSON"] | None: ...
[docs]
Global___GetScriptRequest: typing_extensions.TypeAlias = GetScriptRequest
@typing.final
[docs]
class GetScriptResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
SCRIPTBODY_FIELD_NUMBER: builtins.int
[docs]
scriptBody: builtins.str
def __init__(
self,
*,
scriptBody: builtins.str | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_scriptBody", b"_scriptBody", "scriptBody", b"scriptBody"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_scriptBody", b"_scriptBody", "scriptBody", b"scriptBody"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_scriptBody", b"_scriptBody"]) -> typing.Literal["scriptBody"] | None: ...
[docs]
Global___GetScriptResponse: typing_extensions.TypeAlias = GetScriptResponse
@typing.final
[docs]
class StatusUpdateRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
QUERYSERIAL_FIELD_NUMBER: builtins.int
[docs]
STATUS_FIELD_NUMBER: builtins.int
[docs]
HASEXPORTEDOBJECTS_FIELD_NUMBER: builtins.int
[docs]
EXPORTEDOBJECTS_FIELD_NUMBER: builtins.int
[docs]
HASTABLEGROUPS_FIELD_NUMBER: builtins.int
[docs]
TABLEGROUPS_FIELD_NUMBER: builtins.int
[docs]
PROCESSINFOID_FIELD_NUMBER: builtins.int
[docs]
querySerial: builtins.int
[docs]
status: deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryStatusEnum.ValueType
[docs]
hasExportedObjects: builtins.bool
[docs]
hasTableGroups: builtins.bool
[docs]
processInfoId: builtins.str
@property
[docs]
def exportedObjects(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[deephaven_enterprise.proto.persistent_query_pb2.ExportedObjectInfoMessage]: ...
@property
[docs]
def tableGroups(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[deephaven_enterprise.proto.controller_common_pb2.NamedStringList]: ...
def __init__(
self,
*,
cookie: builtins.bytes = ...,
querySerial: builtins.int = ...,
status: deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryStatusEnum.ValueType | None = ...,
hasExportedObjects: builtins.bool = ...,
exportedObjects: collections.abc.Iterable[deephaven_enterprise.proto.persistent_query_pb2.ExportedObjectInfoMessage] | None = ...,
hasTableGroups: builtins.bool = ...,
tableGroups: collections.abc.Iterable[deephaven_enterprise.proto.controller_common_pb2.NamedStringList] | None = ...,
processInfoId: builtins.str = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["_status", b"_status", "status", b"status"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["_status", b"_status", "cookie", b"cookie", "exportedObjects", b"exportedObjects", "hasExportedObjects", b"hasExportedObjects", "hasTableGroups", b"hasTableGroups", "processInfoId", b"processInfoId", "querySerial", b"querySerial", "status", b"status", "tableGroups", b"tableGroups"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["_status", b"_status"]) -> typing.Literal["status"] | None: ...
[docs]
Global___StatusUpdateRequest: typing_extensions.TypeAlias = StatusUpdateRequest
@typing.final
[docs]
class StatusUpdateResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
def __init__(
self,
) -> None: ...
[docs]
Global___StatusUpdateResponse: typing_extensions.TypeAlias = StatusUpdateResponse
@typing.final
[docs]
class ReloadConfigRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
cookie: builtins.bytes = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie"]) -> None: ...
[docs]
Global___ReloadConfigRequest: typing_extensions.TypeAlias = ReloadConfigRequest
@typing.final
[docs]
class ReloadConfigResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
def __init__(
self,
) -> None: ...
[docs]
Global___ReloadConfigResponse: typing_extensions.TypeAlias = ReloadConfigResponse
@typing.final
[docs]
class SubscriptionFilter(google.protobuf.message.Message):
"""A single subscription filter element matching a Persistent Query (PQ) either
by its serial, or by the combination of its owner and name.
Exactly one of the variants below must be set. A filter element with neither
variant set, or with an OwnerAndName where either field is empty, is malformed;
servers that honor filters MUST reject such a request with INVALID_ARGUMENT.
"""
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
@typing.final
[docs]
class OwnerAndName(google.protobuf.message.Message):
"""The (owner, name) pair identifying a PQ. Both fields are required and must
be non-empty; specifying only one is malformed.
"""
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
OWNER_FIELD_NUMBER: builtins.int
[docs]
NAME_FIELD_NUMBER: builtins.int
def __init__(
self,
*,
owner: builtins.str = ...,
name: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["name", b"name", "owner", b"owner"]) -> None: ...
[docs]
SERIAL_FIELD_NUMBER: builtins.int
[docs]
OWNERANDNAME_FIELD_NUMBER: builtins.int
"""Match the PQ whose serial equals this value."""
@property
[docs]
def ownerAndName(self) -> Global___SubscriptionFilter.OwnerAndName:
"""Match the PQ whose (owner, name) equals this pair."""
def __init__(
self,
*,
serial: builtins.int = ...,
ownerAndName: Global___SubscriptionFilter.OwnerAndName | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["match", b"match", "ownerAndName", b"ownerAndName", "serial", b"serial"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["match", b"match", "ownerAndName", b"ownerAndName", "serial", b"serial"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["match", b"match"]) -> typing.Literal["serial", "ownerAndName"] | None: ...
[docs]
Global___SubscriptionFilter: typing_extensions.TypeAlias = SubscriptionFilter
@typing.final
[docs]
class SubscribeRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
FILTERS_FIELD_NUMBER: builtins.int
@property
[docs]
def filters(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___SubscriptionFilter]:
"""Optional set of filters narrowing the subscription to a subset of the PQs
the client is otherwise allowed to see. Semantics:
- An empty list (the default) means "no filter": the subscription behaves
as it did before this field was added and the client receives events for
every PQ visible to it.
- A non-empty list is OR-combined: a PQ matches the filter iff at least
one element in the list matches it.
- The visibility/ACL check is always implied, the filter can only
further narrow the set; it can never widen visibility.
- Filtering applies only to PQ-scoped events (SE_PUT and SE_REMOVE).
SE_CONFIG_UPDATE and SE_BATCH_END are control/global events and are
always delivered regardless of the filter.
- The filter is re-evaluated on every PQ change. A PQ that transitions
into the matching set (e.g. via rename or owner change when filtering
by owner and name) is delivered as SE_PUT; a PQ that transitions out is
delivered as SE_REMOVE. Servers track which serials have been delivered
to a given subscription so that these enter/leave transitions are
emitted exactly once.
- Malformed filter elements (see SubscriptionFilter) MUST cause the RPC
to fail with INVALID_ARGUMENT on servers that honor this field.
Backwards-compatibility contract: a server MAY ignore this field (e.g. an
older server that predates filter support, where the unknown field is
silently dropped by proto3 parsing). Clients therefore MUST be prepared to
apply the same filter locally to the incoming stream to guarantee correct
behavior, including synthesizing the same enter/leave SE_PUT and SE_REMOVE
transitions described above against a fully unfiltered stream.
"""
def __init__(
self,
*,
cookie: builtins.bytes = ...,
filters: collections.abc.Iterable[Global___SubscriptionFilter] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "filters", b"filters"]) -> None: ...
[docs]
Global___SubscribeRequest: typing_extensions.TypeAlias = SubscribeRequest
@typing.final
[docs]
class SubscribeResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
EVENT_FIELD_NUMBER: builtins.int
[docs]
QUERYSERIAL_FIELD_NUMBER: builtins.int
[docs]
QUERYINFO_FIELD_NUMBER: builtins.int
[docs]
CONFIG_FIELD_NUMBER: builtins.int
[docs]
event: Global___SubscriptionEvent.ValueType
[docs]
querySerial: builtins.int
"""Only populated for SE_REMOVE"""
@property
[docs]
def queryInfo(self) -> deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryInfoMessage:
"""Only populated for SE_PUT, or optionally for SE_BATCH_END"""
@property
[docs]
def config(self) -> Global___ControllerConfigurationMessage:
"""Only populated for SE_CONFIG_UPDATE"""
def __init__(
self,
*,
event: Global___SubscriptionEvent.ValueType = ...,
querySerial: builtins.int = ...,
queryInfo: deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryInfoMessage | None = ...,
config: Global___ControllerConfigurationMessage | None = ...,
) -> None: ...
[docs]
def HasField(self, field_name: typing.Literal["config", b"config", "data", b"data", "queryInfo", b"queryInfo", "querySerial", b"querySerial"]) -> builtins.bool: ...
[docs]
def ClearField(self, field_name: typing.Literal["config", b"config", "data", b"data", "event", b"event", "queryInfo", b"queryInfo", "querySerial", b"querySerial"]) -> None: ...
[docs]
def WhichOneof(self, oneof_group: typing.Literal["data", b"data"]) -> typing.Literal["querySerial", "queryInfo", "config"] | None: ...
[docs]
Global___SubscribeResponse: typing_extensions.TypeAlias = SubscribeResponse
@typing.final
[docs]
class SerializeQueryConfigurationRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
CONFIGS_FIELD_NUMBER: builtins.int
"""the authentication cookie for this request"""
@property
[docs]
def configs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage]:
"""the query configuration to serialize"""
def __init__(
self,
*,
cookie: builtins.bytes = ...,
configs: collections.abc.Iterable[deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["configs", b"configs", "cookie", b"cookie"]) -> None: ...
[docs]
Global___SerializeQueryConfigurationRequest: typing_extensions.TypeAlias = SerializeQueryConfigurationRequest
@typing.final
[docs]
class SerializeQueryConfigurationResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
XML_FIELD_NUMBER: builtins.int
"""the serialized query configuration as XML"""
def __init__(
self,
*,
xml: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["xml", b"xml"]) -> None: ...
[docs]
Global___SerializeQueryConfigurationResponse: typing_extensions.TypeAlias = SerializeQueryConfigurationResponse
@typing.final
[docs]
class DeserializeQueryConfigurationRequest(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
COOKIE_FIELD_NUMBER: builtins.int
[docs]
XML_FIELD_NUMBER: builtins.int
"""the authentication cookie for this request"""
"""The XML to parse into a query configuration message"""
def __init__(
self,
*,
cookie: builtins.bytes = ...,
xml: builtins.str = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["cookie", b"cookie", "xml", b"xml"]) -> None: ...
[docs]
Global___DeserializeQueryConfigurationRequest: typing_extensions.TypeAlias = DeserializeQueryConfigurationRequest
@typing.final
[docs]
class DeserializeQueryConfigurationResponse(google.protobuf.message.Message):
[docs]
DESCRIPTOR: google.protobuf.descriptor.Descriptor
[docs]
CONFIGS_FIELD_NUMBER: builtins.int
@property
[docs]
def configs(self) -> google.protobuf.internal.containers.RepeatedCompositeFieldContainer[deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage]:
"""The persistent query configuration produced from the XML (or other format) in a DeserializeQueryConfigurationRequest"""
def __init__(
self,
*,
configs: collections.abc.Iterable[deephaven_enterprise.proto.persistent_query_pb2.PersistentQueryConfigMessage] | None = ...,
) -> None: ...
[docs]
def ClearField(self, field_name: typing.Literal["configs", b"configs"]) -> None: ...
[docs]
Global___DeserializeQueryConfigurationResponse: typing_extensions.TypeAlias = DeserializeQueryConfigurationResponse