from base import base_pb2 as _base_pb2
from google.protobuf.internal import containers as _containers
from google.protobuf.internal import enum_type_wrapper as _enum_type_wrapper
from google.protobuf import descriptor as _descriptor
from google.protobuf import message as _message
from typing import ClassVar as _ClassVar, Iterable as _Iterable, Mapping as _Mapping, Optional as _Optional, Union as _Union

CLUSTER_CONNECTION_TYPE_PRIVATE: ClusterConnectionType
CLUSTER_CONNECTION_TYPE_PUBLIC: ClusterConnectionType
CLUSTER_CONNECTION_TYPE_UNSPECIFIED: ClusterConnectionType
CLUSTER_JOB_TYPE_BACKUP: ClusterJobType
CLUSTER_JOB_TYPE_CDC: ClusterJobType
CLUSTER_JOB_TYPE_IMPORT: ClusterJobType
CLUSTER_JOB_TYPE_REPLICATION_PRIMARY: ClusterJobType
CLUSTER_JOB_TYPE_REPLICATION_SECONDARY: ClusterJobType
CLUSTER_JOB_TYPE_RESTORE: ClusterJobType
CLUSTER_JOB_TYPE_SERVERLESS_RESTORE: ClusterJobType
CLUSTER_JOB_TYPE_UNSPECIFIED: ClusterJobType
CLUSTER_JOB_TYPE_VOLUME_SNAPSHOT_RESTORE: ClusterJobType
CLUSTER_STATUS_CLEARED: ClusterStatus
CLUSTER_STATUS_DELETECOMPLETE: ClusterStatus
CLUSTER_STATUS_DELETED: ClusterStatus
CLUSTER_STATUS_HIBERNATED: ClusterStatus
CLUSTER_STATUS_INITIALIZING: ClusterStatus
CLUSTER_STATUS_LAUNCHING: ClusterStatus
CLUSTER_STATUS_NORMAL: ClusterStatus
CLUSTER_STATUS_PAUSED: ClusterStatus
CLUSTER_STATUS_PAUSING: ClusterStatus
CLUSTER_STATUS_PREPARING: ClusterStatus
CLUSTER_STATUS_RECOVERING: ClusterStatus
CLUSTER_STATUS_RESUMING: ClusterStatus
CLUSTER_STATUS_SCALING: ClusterStatus
CLUSTER_STATUS_UNSPECIFIED: ClusterStatus
CLUSTER_STATUS_VOLUME_SNAPSHOT_RESTORING: ClusterStatus
COMPONENT_TYPE_PD: ComponentType
COMPONENT_TYPE_TICDC: ComponentType
COMPONENT_TYPE_TIDB: ComponentType
COMPONENT_TYPE_TIFLASH: ComponentType
COMPONENT_TYPE_TIKV: ComponentType
COMPONENT_TYPE_UNSPECIFIED: ComponentType
DELEGATE_USER: AvailableFeature
DEPLOY_TYPE_DEDICATED: DeployType
DEPLOY_TYPE_HYBRID: DeployType
DEPLOY_TYPE_SHARED: DeployType
DEPLOY_TYPE_UNSPECIFIED: DeployType
DESCRIPTOR: _descriptor.FileDescriptor
DEVTIER_CLASSIC: DevTierClusterType
DEVTIER_SERVERLESS: DevTierClusterType
DEVTIER_UNSPECIFIED: DevTierClusterType
DISABLE_PUBLIC_LB: AvailableFeature
PROFILE_STATUS_ACTIVE: ProfileStatus
PROFILE_STATUS_DELETED: ProfileStatus
PROFILE_STATUS_INACTIVE: ProfileStatus
PROFILE_STATUS_UNSPECIFIED: ProfileStatus
SKU_TYPE_BACKUP_REPLICA: SKUType
SKU_TYPE_BACKUP_STORAGE: SKUType
SKU_TYPE_BACKUP_VOLUME_SNAPSHOT_STORAGE: SKUType
SKU_TYPE_DISK_IOPS: SKUType
SKU_TYPE_DISK_STORAGE: SKUType
SKU_TYPE_DISK_THROUGHPUT: SKUType
SKU_TYPE_DMINTERNET: SKUType
SKU_TYPE_DMNAT: SKUType
SKU_TYPE_DMNETWORK: SKUType
SKU_TYPE_DMRCU: SKUType
SKU_TYPE_NETWORK_TRAFFIC: SKUType
SKU_TYPE_NODE: SKUType
SKU_TYPE_PLENDPOINT: SKUType
SKU_TYPE_PLNETWORK: SKUType
SKU_TYPE_SERVERLESS_COLUMN_STORAGE: SKUType
SKU_TYPE_SERVERLESS_REQUEST_UNIT: SKUType
SKU_TYPE_SERVERLESS_ROW_STORAGE: SKUType
SKU_TYPE_TICDC_TCU: SKUType
SKU_TYPE_UNSPECIFIED: SKUType
SKU_TYPE_VPC_PEERING: SKUType
USER_CLUSTER_STATUS_CREATING: UserClusterStatus
USER_CLUSTER_STATUS_DELETED: UserClusterStatus
USER_CLUSTER_STATUS_IMPORTING: UserClusterStatus
USER_CLUSTER_STATUS_MAINTAINING: UserClusterStatus
USER_CLUSTER_STATUS_NORMAL: UserClusterStatus
USER_CLUSTER_STATUS_PAUSED: UserClusterStatus
USER_CLUSTER_STATUS_RECOVERING: UserClusterStatus
USER_CLUSTER_STATUS_RESUMING: UserClusterStatus
USER_CLUSTER_STATUS_SCALING: UserClusterStatus
USER_CLUSTER_STATUS_UNAVAILABLE: UserClusterStatus
USER_CLUSTER_STATUS_UPGRADING: UserClusterStatus
USER_CLUSTER_SUB_STATUS_HEALTHY: UserClusterSubStatus
USER_CLUSTER_SUB_STATUS_UNHEALTHY: UserClusterSubStatus

class AwsCmek(_message.Message):
    __slots__ = ["id", "kms_arn", "project_id", "region_name"]
    ID_FIELD_NUMBER: _ClassVar[int]
    KMS_ARN_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    id: int
    kms_arn: str
    project_id: int
    region_name: str
    def __init__(self, id: _Optional[int] = ..., project_id: _Optional[int] = ..., region_name: _Optional[str] = ..., kms_arn: _Optional[str] = ...) -> None: ...

class AwsCmekSpec(_message.Message):
    __slots__ = ["kms_arn", "region_name"]
    KMS_ARN_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    kms_arn: str
    region_name: str
    def __init__(self, region_name: _Optional[str] = ..., kms_arn: _Optional[str] = ...) -> None: ...

class AwsXAccountDeployParams(_message.Message):
    __slots__ = ["bucket_name", "eks_role_arn", "is_mtls_on", "kms_key_arn", "node_role_arn", "pca_client_arn", "pca_cluster_components_arn", "security_group_id", "subnet_ids", "tidb_cacert", "tidb_client_cert", "tidb_client_key", "tidb_service_role_arn", "vpc_id"]
    BUCKET_NAME_FIELD_NUMBER: _ClassVar[int]
    EKS_ROLE_ARN_FIELD_NUMBER: _ClassVar[int]
    IS_MTLS_ON_FIELD_NUMBER: _ClassVar[int]
    KMS_KEY_ARN_FIELD_NUMBER: _ClassVar[int]
    NODE_ROLE_ARN_FIELD_NUMBER: _ClassVar[int]
    PCA_CLIENT_ARN_FIELD_NUMBER: _ClassVar[int]
    PCA_CLUSTER_COMPONENTS_ARN_FIELD_NUMBER: _ClassVar[int]
    SECURITY_GROUP_ID_FIELD_NUMBER: _ClassVar[int]
    SUBNET_IDS_FIELD_NUMBER: _ClassVar[int]
    TIDB_CACERT_FIELD_NUMBER: _ClassVar[int]
    TIDB_CLIENT_CERT_FIELD_NUMBER: _ClassVar[int]
    TIDB_CLIENT_KEY_FIELD_NUMBER: _ClassVar[int]
    TIDB_SERVICE_ROLE_ARN_FIELD_NUMBER: _ClassVar[int]
    VPC_ID_FIELD_NUMBER: _ClassVar[int]
    bucket_name: str
    eks_role_arn: str
    is_mtls_on: bool
    kms_key_arn: str
    node_role_arn: str
    pca_client_arn: str
    pca_cluster_components_arn: str
    security_group_id: str
    subnet_ids: _containers.RepeatedScalarFieldContainer[str]
    tidb_cacert: str
    tidb_client_cert: str
    tidb_client_key: str
    tidb_service_role_arn: str
    vpc_id: str
    def __init__(self, vpc_id: _Optional[str] = ..., security_group_id: _Optional[str] = ..., subnet_ids: _Optional[_Iterable[str]] = ..., bucket_name: _Optional[str] = ..., kms_key_arn: _Optional[str] = ..., pca_cluster_components_arn: _Optional[str] = ..., pca_client_arn: _Optional[str] = ..., node_role_arn: _Optional[str] = ..., eks_role_arn: _Optional[str] = ..., tidb_service_role_arn: _Optional[str] = ..., tidb_cacert: _Optional[str] = ..., tidb_client_cert: _Optional[str] = ..., tidb_client_key: _Optional[str] = ..., is_mtls_on: bool = ...) -> None: ...

class BatchGetTiersReq(_message.Message):
    __slots__ = ["base_req", "identifiers"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    IDENTIFIERS_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    identifiers: _containers.RepeatedCompositeFieldContainer[TierIdentifier]
    def __init__(self, identifiers: _Optional[_Iterable[_Union[TierIdentifier, _Mapping]]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class BatchGetTiersResp(_message.Message):
    __slots__ = ["base_resp", "tiers"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    TIERS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    tiers: _containers.RepeatedCompositeFieldContainer[Tier]
    def __init__(self, tiers: _Optional[_Iterable[_Union[Tier, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CalcClusterFeeReq(_message.Message):
    __slots__ = ["base_req", "cloud_provider_name", "components", "deploy_type", "duration", "is_cluster_paused", "project_id", "region_name", "tenant_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    COMPONENTS_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    DURATION_FIELD_NUMBER: _ClassVar[int]
    IS_CLUSTER_PAUSED_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cloud_provider_name: str
    components: _containers.RepeatedCompositeFieldContainer[ClusterComponent]
    deploy_type: DeployType
    duration: int
    is_cluster_paused: bool
    project_id: int
    region_name: str
    tenant_id: int
    def __init__(self, tenant_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cloud_provider_name: _Optional[str] = ..., region_name: _Optional[str] = ..., duration: _Optional[int] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., components: _Optional[_Iterable[_Union[ClusterComponent, _Mapping]]] = ..., is_cluster_paused: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CalcClusterFeeResp(_message.Message):
    __slots__ = ["base_resp", "costs"]
    class ComponentCost(_message.Message):
        __slots__ = ["component_type", "compute", "raw_compute", "raw_storage", "storage"]
        COMPONENT_TYPE_FIELD_NUMBER: _ClassVar[int]
        COMPUTE_FIELD_NUMBER: _ClassVar[int]
        RAW_COMPUTE_FIELD_NUMBER: _ClassVar[int]
        RAW_STORAGE_FIELD_NUMBER: _ClassVar[int]
        STORAGE_FIELD_NUMBER: _ClassVar[int]
        component_type: ComponentType
        compute: float
        raw_compute: float
        raw_storage: float
        storage: float
        def __init__(self, component_type: _Optional[_Union[ComponentType, str]] = ..., compute: _Optional[float] = ..., storage: _Optional[float] = ..., raw_compute: _Optional[float] = ..., raw_storage: _Optional[float] = ...) -> None: ...
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    COSTS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    costs: _containers.RepeatedCompositeFieldContainer[CalcClusterFeeResp.ComponentCost]
    def __init__(self, costs: _Optional[_Iterable[_Union[CalcClusterFeeResp.ComponentCost, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ChangeClusterPasswdReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "passwd"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    PASSWD_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    passwd: str
    def __init__(self, cluster_id: _Optional[int] = ..., passwd: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ChangeClusterPasswdResp(_message.Message):
    __slots__ = ["base_resp", "synced"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    SYNCED_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    synced: bool
    def __init__(self, synced: bool = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CheckSkuSyncedReq(_message.Message):
    __slots__ = ["base_req"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    def __init__(self, base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CheckSkuSyncedResp(_message.Message):
    __slots__ = ["base_resp", "synced"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    SYNCED_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    synced: bool
    def __init__(self, synced: bool = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CleanClustersReq(_message.Message):
    __slots__ = ["base_req", "disable_final_backup", "is_dev_tier", "tenant_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    DISABLE_FINAL_BACKUP_FIELD_NUMBER: _ClassVar[int]
    IS_DEV_TIER_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    disable_final_backup: bool
    is_dev_tier: bool
    tenant_id: int
    def __init__(self, tenant_id: _Optional[int] = ..., is_dev_tier: bool = ..., disable_final_backup: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CleanClustersResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CleanProjectResourceReq(_message.Message):
    __slots__ = ["base_req", "project_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    project_id: int
    def __init__(self, project_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CleanProjectResourceResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CleanTenantResourceReq(_message.Message):
    __slots__ = ["base_req", "tenant_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    tenant_id: int
    def __init__(self, tenant_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CleanTenantResourceResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ClearClusterReq(_message.Message):
    __slots__ = ["base_req", "cluster_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    def __init__(self, cluster_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ClearClusterResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CloudProvider(_message.Message):
    __slots__ = ["name", "name2region", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    class Name2regionEntry(_message.Message):
        __slots__ = ["key", "value"]
        KEY_FIELD_NUMBER: _ClassVar[int]
        VALUE_FIELD_NUMBER: _ClassVar[int]
        key: str
        value: Region
        def __init__(self, key: _Optional[str] = ..., value: _Optional[_Union[Region, _Mapping]] = ...) -> None: ...
    NAME2REGION_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    STATUS_ACTIVE: CloudProvider.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_INACTIVE: CloudProvider.Status
    STATUS_UNSPECIFIED: CloudProvider.Status
    name: str
    name2region: _containers.MessageMap[str, Region]
    status: CloudProvider.Status
    def __init__(self, name: _Optional[str] = ..., status: _Optional[_Union[CloudProvider.Status, str]] = ..., name2region: _Optional[_Mapping[str, Region]] = ...) -> None: ...

class CloudRegion(_message.Message):
    __slots__ = ["area", "cloud_provider_name", "country_code", "default_backup_time", "display_name", "id", "is_public", "name", "opened_tenant_ids", "priority", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    AREA_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    COUNTRY_CODE_FIELD_NUMBER: _ClassVar[int]
    DEFAULT_BACKUP_TIME_FIELD_NUMBER: _ClassVar[int]
    DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    IS_PUBLIC_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    OPENED_TENANT_IDS_FIELD_NUMBER: _ClassVar[int]
    PRIORITY_FIELD_NUMBER: _ClassVar[int]
    STATUS_ACTIVE: CloudRegion.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_INACTIVE: CloudRegion.Status
    STATUS_UNSPECIFIED: CloudRegion.Status
    area: str
    cloud_provider_name: str
    country_code: str
    default_backup_time: str
    display_name: str
    id: int
    is_public: bool
    name: str
    opened_tenant_ids: _containers.RepeatedScalarFieldContainer[int]
    priority: int
    status: CloudRegion.Status
    def __init__(self, id: _Optional[int] = ..., name: _Optional[str] = ..., display_name: _Optional[str] = ..., status: _Optional[_Union[CloudRegion.Status, str]] = ..., cloud_provider_name: _Optional[str] = ..., priority: _Optional[int] = ..., area: _Optional[str] = ..., country_code: _Optional[str] = ..., is_public: bool = ..., opened_tenant_ids: _Optional[_Iterable[int]] = ..., default_backup_time: _Optional[str] = ...) -> None: ...

class CloudRegionFilter(_message.Message):
    __slots__ = ["cloud_provider_names", "ids", "names"]
    CLOUD_PROVIDER_NAMES_FIELD_NUMBER: _ClassVar[int]
    IDS_FIELD_NUMBER: _ClassVar[int]
    NAMES_FIELD_NUMBER: _ClassVar[int]
    cloud_provider_names: _containers.RepeatedScalarFieldContainer[str]
    ids: _containers.RepeatedScalarFieldContainer[int]
    names: _containers.RepeatedScalarFieldContainer[str]
    def __init__(self, cloud_provider_names: _Optional[_Iterable[str]] = ..., names: _Optional[_Iterable[str]] = ..., ids: _Optional[_Iterable[int]] = ...) -> None: ...

class Cluster(_message.Message):
    __slots__ = ["attributes", "cloud_provider_name", "cluster_jobs", "components", "connections", "created_at", "created_by", "creation_finished_at", "data_plane_info", "deleted_at", "deploy_type", "dev_tier_type", "features", "has_set_pwd", "id", "import_id", "infra_provider_type", "is_dev_tier", "name", "project_id", "read_only", "region_display_name", "region_name", "restore_id", "serverless_token", "status", "tenant_id", "traffic_filter", "user_status", "user_sub_status", "version", "xaccount_deploy_id"]
    class Attributes(_message.Message):
        __slots__ = ["with_builtin_cdc_admin_role"]
        WITH_BUILTIN_CDC_ADMIN_ROLE_FIELD_NUMBER: _ClassVar[int]
        with_builtin_cdc_admin_role: bool
        def __init__(self, with_builtin_cdc_admin_role: bool = ...) -> None: ...
    class DataPlaneInfo(_message.Message):
        __slots__ = ["dataplane_name", "k8s_namespace", "network_name", "shoot_name"]
        DATAPLANE_NAME_FIELD_NUMBER: _ClassVar[int]
        K8S_NAMESPACE_FIELD_NUMBER: _ClassVar[int]
        NETWORK_NAME_FIELD_NUMBER: _ClassVar[int]
        SHOOT_NAME_FIELD_NUMBER: _ClassVar[int]
        dataplane_name: str
        k8s_namespace: str
        network_name: str
        shoot_name: str
        def __init__(self, shoot_name: _Optional[str] = ..., k8s_namespace: _Optional[str] = ..., network_name: _Optional[str] = ..., dataplane_name: _Optional[str] = ...) -> None: ...
    ATTRIBUTES_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_JOBS_FIELD_NUMBER: _ClassVar[int]
    COMPONENTS_FIELD_NUMBER: _ClassVar[int]
    CONNECTIONS_FIELD_NUMBER: _ClassVar[int]
    CREATED_AT_FIELD_NUMBER: _ClassVar[int]
    CREATED_BY_FIELD_NUMBER: _ClassVar[int]
    CREATION_FINISHED_AT_FIELD_NUMBER: _ClassVar[int]
    DATA_PLANE_INFO_FIELD_NUMBER: _ClassVar[int]
    DELETED_AT_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    DEV_TIER_TYPE_FIELD_NUMBER: _ClassVar[int]
    FEATURES_FIELD_NUMBER: _ClassVar[int]
    HAS_SET_PWD_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    IMPORT_ID_FIELD_NUMBER: _ClassVar[int]
    INFRA_PROVIDER_TYPE_FIELD_NUMBER: _ClassVar[int]
    IS_DEV_TIER_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    READ_ONLY_FIELD_NUMBER: _ClassVar[int]
    REGION_DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    RESTORE_ID_FIELD_NUMBER: _ClassVar[int]
    SERVERLESS_TOKEN_FIELD_NUMBER: _ClassVar[int]
    STATUS_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    TRAFFIC_FILTER_FIELD_NUMBER: _ClassVar[int]
    USER_STATUS_FIELD_NUMBER: _ClassVar[int]
    USER_SUB_STATUS_FIELD_NUMBER: _ClassVar[int]
    VERSION_FIELD_NUMBER: _ClassVar[int]
    XACCOUNT_DEPLOY_ID_FIELD_NUMBER: _ClassVar[int]
    attributes: Cluster.Attributes
    cloud_provider_name: str
    cluster_jobs: _containers.RepeatedCompositeFieldContainer[ClusterJob]
    components: _containers.RepeatedCompositeFieldContainer[ClusterComponent]
    connections: _containers.RepeatedCompositeFieldContainer[ClusterConnection]
    created_at: int
    created_by: int
    creation_finished_at: int
    data_plane_info: Cluster.DataPlaneInfo
    deleted_at: int
    deploy_type: DeployType
    dev_tier_type: DevTierClusterType
    features: _containers.RepeatedScalarFieldContainer[AvailableFeature]
    has_set_pwd: bool
    id: int
    import_id: int
    infra_provider_type: str
    is_dev_tier: bool
    name: str
    project_id: int
    read_only: bool
    region_display_name: str
    region_name: str
    restore_id: int
    serverless_token: str
    status: ClusterStatus
    tenant_id: int
    traffic_filter: TrafficFilter
    user_status: UserClusterStatus
    user_sub_status: UserClusterSubStatus
    version: str
    xaccount_deploy_id: int
    def __init__(self, id: _Optional[int] = ..., tenant_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cloud_provider_name: _Optional[str] = ..., infra_provider_type: _Optional[str] = ..., region_name: _Optional[str] = ..., region_display_name: _Optional[str] = ..., name: _Optional[str] = ..., version: _Optional[str] = ..., components: _Optional[_Iterable[_Union[ClusterComponent, _Mapping]]] = ..., status: _Optional[_Union[ClusterStatus, str]] = ..., user_status: _Optional[_Union[UserClusterStatus, str]] = ..., user_sub_status: _Optional[_Union[UserClusterSubStatus, str]] = ..., is_dev_tier: bool = ..., import_id: _Optional[int] = ..., connections: _Optional[_Iterable[_Union[ClusterConnection, _Mapping]]] = ..., read_only: bool = ..., traffic_filter: _Optional[_Union[TrafficFilter, _Mapping]] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., created_at: _Optional[int] = ..., creation_finished_at: _Optional[int] = ..., created_by: _Optional[int] = ..., xaccount_deploy_id: _Optional[int] = ..., deleted_at: _Optional[int] = ..., data_plane_info: _Optional[_Union[Cluster.DataPlaneInfo, _Mapping]] = ..., has_set_pwd: bool = ..., dev_tier_type: _Optional[_Union[DevTierClusterType, str]] = ..., features: _Optional[_Iterable[_Union[AvailableFeature, str]]] = ..., restore_id: _Optional[int] = ..., serverless_token: _Optional[str] = ..., attributes: _Optional[_Union[Cluster.Attributes, _Mapping]] = ..., cluster_jobs: _Optional[_Iterable[_Union[ClusterJob, _Mapping]]] = ...) -> None: ...

class ClusterComponent(_message.Message):
    __slots__ = ["component_type", "compute_instance_type", "cpu_num", "memory_gi", "modify_progress", "node_profile_display_name", "node_profile_name", "replicas", "storage_instance_type", "storage_size_gi"]
    class ModifyProgress(_message.Message):
        __slots__ = ["expected_quantity", "pending", "remaining_deletion_quantity", "uptodate_quantity"]
        EXPECTED_QUANTITY_FIELD_NUMBER: _ClassVar[int]
        PENDING_FIELD_NUMBER: _ClassVar[int]
        REMAINING_DELETION_QUANTITY_FIELD_NUMBER: _ClassVar[int]
        UPTODATE_QUANTITY_FIELD_NUMBER: _ClassVar[int]
        expected_quantity: int
        pending: bool
        remaining_deletion_quantity: int
        uptodate_quantity: int
        def __init__(self, pending: bool = ..., expected_quantity: _Optional[int] = ..., uptodate_quantity: _Optional[int] = ..., remaining_deletion_quantity: _Optional[int] = ...) -> None: ...
    COMPONENT_TYPE_FIELD_NUMBER: _ClassVar[int]
    COMPUTE_INSTANCE_TYPE_FIELD_NUMBER: _ClassVar[int]
    CPU_NUM_FIELD_NUMBER: _ClassVar[int]
    MEMORY_GI_FIELD_NUMBER: _ClassVar[int]
    MODIFY_PROGRESS_FIELD_NUMBER: _ClassVar[int]
    NODE_PROFILE_DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    NODE_PROFILE_NAME_FIELD_NUMBER: _ClassVar[int]
    REPLICAS_FIELD_NUMBER: _ClassVar[int]
    STORAGE_INSTANCE_TYPE_FIELD_NUMBER: _ClassVar[int]
    STORAGE_SIZE_GI_FIELD_NUMBER: _ClassVar[int]
    component_type: ComponentType
    compute_instance_type: str
    cpu_num: int
    memory_gi: int
    modify_progress: ClusterComponent.ModifyProgress
    node_profile_display_name: str
    node_profile_name: str
    replicas: int
    storage_instance_type: str
    storage_size_gi: int
    def __init__(self, component_type: _Optional[_Union[ComponentType, str]] = ..., node_profile_name: _Optional[str] = ..., replicas: _Optional[int] = ..., node_profile_display_name: _Optional[str] = ..., compute_instance_type: _Optional[str] = ..., cpu_num: _Optional[int] = ..., memory_gi: _Optional[int] = ..., storage_instance_type: _Optional[str] = ..., storage_size_gi: _Optional[int] = ..., modify_progress: _Optional[_Union[ClusterComponent.ModifyProgress, _Mapping]] = ...) -> None: ...

class ClusterConfidentialInfo(_message.Message):
    __slots__ = ["encrypted_cloud_admin_passwd"]
    ENCRYPTED_CLOUD_ADMIN_PASSWD_FIELD_NUMBER: _ClassVar[int]
    encrypted_cloud_admin_passwd: str
    def __init__(self, encrypted_cloud_admin_passwd: _Optional[str] = ...) -> None: ...

class ClusterConnection(_message.Message):
    __slots__ = ["cluster_id", "create_success", "host", "port", "token", "type"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    CREATE_SUCCESS_FIELD_NUMBER: _ClassVar[int]
    HOST_FIELD_NUMBER: _ClassVar[int]
    PORT_FIELD_NUMBER: _ClassVar[int]
    TOKEN_FIELD_NUMBER: _ClassVar[int]
    TYPE_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    create_success: bool
    host: str
    port: int
    token: str
    type: ClusterConnectionType
    def __init__(self, cluster_id: _Optional[int] = ..., type: _Optional[_Union[ClusterConnectionType, str]] = ..., create_success: bool = ..., host: _Optional[str] = ..., port: _Optional[int] = ..., token: _Optional[str] = ...) -> None: ...

class ClusterFilter(_message.Message):
    __slots__ = ["cloud_provider_names", "cluster_ids", "cluster_names", "creator_ids", "deleted", "exclude_statuses", "is_dev_tier", "project_ids", "statuses", "tenant_ids"]
    CLOUD_PROVIDER_NAMES_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_IDS_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_NAMES_FIELD_NUMBER: _ClassVar[int]
    CREATOR_IDS_FIELD_NUMBER: _ClassVar[int]
    DELETED_FIELD_NUMBER: _ClassVar[int]
    EXCLUDE_STATUSES_FIELD_NUMBER: _ClassVar[int]
    IS_DEV_TIER_FIELD_NUMBER: _ClassVar[int]
    PROJECT_IDS_FIELD_NUMBER: _ClassVar[int]
    STATUSES_FIELD_NUMBER: _ClassVar[int]
    TENANT_IDS_FIELD_NUMBER: _ClassVar[int]
    cloud_provider_names: _containers.RepeatedScalarFieldContainer[str]
    cluster_ids: _containers.RepeatedScalarFieldContainer[int]
    cluster_names: _containers.RepeatedScalarFieldContainer[str]
    creator_ids: _containers.RepeatedScalarFieldContainer[int]
    deleted: bool
    exclude_statuses: _containers.RepeatedScalarFieldContainer[ClusterStatus]
    is_dev_tier: bool
    project_ids: _containers.RepeatedScalarFieldContainer[int]
    statuses: _containers.RepeatedScalarFieldContainer[ClusterStatus]
    tenant_ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, cloud_provider_names: _Optional[_Iterable[str]] = ..., statuses: _Optional[_Iterable[_Union[ClusterStatus, str]]] = ..., exclude_statuses: _Optional[_Iterable[_Union[ClusterStatus, str]]] = ..., tenant_ids: _Optional[_Iterable[int]] = ..., project_ids: _Optional[_Iterable[int]] = ..., cluster_ids: _Optional[_Iterable[int]] = ..., deleted: bool = ..., creator_ids: _Optional[_Iterable[int]] = ..., cluster_names: _Optional[_Iterable[str]] = ..., is_dev_tier: bool = ...) -> None: ...

class ClusterJob(_message.Message):
    __slots__ = ["cluster_id", "job_id", "job_type", "name"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    JOB_ID_FIELD_NUMBER: _ClassVar[int]
    JOB_TYPE_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    job_id: int
    job_type: ClusterJobType
    name: str
    def __init__(self, job_id: _Optional[int] = ..., cluster_id: _Optional[int] = ..., job_type: _Optional[_Union[ClusterJobType, str]] = ..., name: _Optional[str] = ...) -> None: ...

class ClusterJobFilter(_message.Message):
    __slots__ = ["cluster_ids", "job_type"]
    CLUSTER_IDS_FIELD_NUMBER: _ClassVar[int]
    JOB_TYPE_FIELD_NUMBER: _ClassVar[int]
    cluster_ids: _containers.RepeatedScalarFieldContainer[int]
    job_type: ClusterJobType
    def __init__(self, job_type: _Optional[_Union[ClusterJobType, str]] = ..., cluster_ids: _Optional[_Iterable[int]] = ...) -> None: ...

class ClusterJobIdentifier(_message.Message):
    __slots__ = ["cluster_id", "job_id", "job_type", "name"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    JOB_ID_FIELD_NUMBER: _ClassVar[int]
    JOB_TYPE_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    job_id: int
    job_type: ClusterJobType
    name: str
    def __init__(self, job_id: _Optional[int] = ..., cluster_id: _Optional[int] = ..., job_type: _Optional[_Union[ClusterJobType, str]] = ..., name: _Optional[str] = ...) -> None: ...

class ClusterProxyError(_message.Message):
    __slots__ = ["sql_err_msg", "sql_err_no"]
    SQL_ERR_MSG_FIELD_NUMBER: _ClassVar[int]
    SQL_ERR_NO_FIELD_NUMBER: _ClassVar[int]
    sql_err_msg: str
    sql_err_no: int
    def __init__(self, sql_err_no: _Optional[int] = ..., sql_err_msg: _Optional[str] = ...) -> None: ...

class ClusterSnapshot(_message.Message):
    __slots__ = ["cloud_provider_name", "components", "id", "project_id", "tenant_id"]
    CLOUD_PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    COMPONENTS_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    cloud_provider_name: str
    components: _containers.RepeatedCompositeFieldContainer[ClusterComponent]
    id: int
    project_id: int
    tenant_id: int
    def __init__(self, id: _Optional[int] = ..., tenant_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cloud_provider_name: _Optional[str] = ..., components: _Optional[_Iterable[_Union[ClusterComponent, _Mapping]]] = ...) -> None: ...

class ClusterSnapshotFilter(_message.Message):
    __slots__ = ["cluster_ids", "project_ids", "snapshot_ids", "tenant_ids"]
    CLUSTER_IDS_FIELD_NUMBER: _ClassVar[int]
    PROJECT_IDS_FIELD_NUMBER: _ClassVar[int]
    SNAPSHOT_IDS_FIELD_NUMBER: _ClassVar[int]
    TENANT_IDS_FIELD_NUMBER: _ClassVar[int]
    cluster_ids: _containers.RepeatedScalarFieldContainer[int]
    project_ids: _containers.RepeatedScalarFieldContainer[int]
    snapshot_ids: _containers.RepeatedScalarFieldContainer[int]
    tenant_ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, tenant_ids: _Optional[_Iterable[int]] = ..., project_ids: _Optional[_Iterable[int]] = ..., cluster_ids: _Optional[_Iterable[int]] = ..., snapshot_ids: _Optional[_Iterable[int]] = ...) -> None: ...

class CountClustersReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: ClusterFilter
    def __init__(self, filter: _Optional[_Union[ClusterFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CountClustersResp(_message.Message):
    __slots__ = ["base_resp", "count"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    COUNT_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    count: int
    def __init__(self, count: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateAwsCmekReq(_message.Message):
    __slots__ = ["base_req", "project_id", "specs"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    SPECS_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    project_id: int
    specs: _containers.RepeatedCompositeFieldContainer[AwsCmekSpec]
    def __init__(self, project_id: _Optional[int] = ..., specs: _Optional[_Iterable[_Union[AwsCmekSpec, _Mapping]]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateAwsCmekResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateClusterConnReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "conn_type"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    CONN_TYPE_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    conn_type: ClusterConnectionType
    def __init__(self, cluster_id: _Optional[int] = ..., conn_type: _Optional[_Union[ClusterConnectionType, str]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateClusterConnResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateClusterEcosystemAccountReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "password", "username"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    PASSWORD_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    password: str
    username: str
    def __init__(self, cluster_id: _Optional[int] = ..., username: _Optional[str] = ..., password: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateClusterEcosystemAccountResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateClusterJobReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "job_type", "name"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    JOB_TYPE_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    job_type: ClusterJobType
    name: str
    def __init__(self, cluster_id: _Optional[int] = ..., job_type: _Optional[_Union[ClusterJobType, str]] = ..., name: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateClusterJobResp(_message.Message):
    __slots__ = ["base_resp", "job_id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    JOB_ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    job_id: int
    def __init__(self, job_id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateClusterOption(_message.Message):
    __slots__ = ["tiflash_option", "tikv_option"]
    class ComponentOption(_message.Message):
        __slots__ = ["ignore_storage_size_check"]
        IGNORE_STORAGE_SIZE_CHECK_FIELD_NUMBER: _ClassVar[int]
        ignore_storage_size_check: bool
        def __init__(self, ignore_storage_size_check: bool = ...) -> None: ...
    TIFLASH_OPTION_FIELD_NUMBER: _ClassVar[int]
    TIKV_OPTION_FIELD_NUMBER: _ClassVar[int]
    tiflash_option: CreateClusterOption.ComponentOption
    tikv_option: CreateClusterOption.ComponentOption
    def __init__(self, tikv_option: _Optional[_Union[CreateClusterOption.ComponentOption, _Mapping]] = ..., tiflash_option: _Optional[_Union[CreateClusterOption.ComponentOption, _Mapping]] = ...) -> None: ...

class CreateClusterReq(_message.Message):
    __slots__ = ["base_req", "cloud_provider", "components", "create_by_id", "deploy_type", "dryrun", "initial_version", "is_dev_tier", "name", "option", "port", "primary_cluster_id", "project_id", "recovery_mode", "region", "restore_id", "root_password", "spend_limits", "tenant_id", "traffic_filter", "xaccount_deploy_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    COMPONENTS_FIELD_NUMBER: _ClassVar[int]
    CREATE_BY_ID_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    DRYRUN_FIELD_NUMBER: _ClassVar[int]
    INITIAL_VERSION_FIELD_NUMBER: _ClassVar[int]
    IS_DEV_TIER_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    OPTION_FIELD_NUMBER: _ClassVar[int]
    PORT_FIELD_NUMBER: _ClassVar[int]
    PRIMARY_CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    RECOVERY_MODE_FIELD_NUMBER: _ClassVar[int]
    REGION_FIELD_NUMBER: _ClassVar[int]
    RESTORE_ID_FIELD_NUMBER: _ClassVar[int]
    ROOT_PASSWORD_FIELD_NUMBER: _ClassVar[int]
    SPEND_LIMITS_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    TRAFFIC_FILTER_FIELD_NUMBER: _ClassVar[int]
    XACCOUNT_DEPLOY_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cloud_provider: str
    components: _containers.RepeatedCompositeFieldContainer[ClusterComponent]
    create_by_id: int
    deploy_type: DeployType
    dryrun: bool
    initial_version: str
    is_dev_tier: bool
    name: str
    option: CreateClusterOption
    port: int
    primary_cluster_id: int
    project_id: int
    recovery_mode: bool
    region: str
    restore_id: int
    root_password: str
    spend_limits: float
    tenant_id: int
    traffic_filter: TrafficFilter
    xaccount_deploy_id: int
    def __init__(self, tenant_id: _Optional[int] = ..., project_id: _Optional[int] = ..., name: _Optional[str] = ..., root_password: _Optional[str] = ..., cloud_provider: _Optional[str] = ..., region: _Optional[str] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., is_dev_tier: bool = ..., components: _Optional[_Iterable[_Union[ClusterComponent, _Mapping]]] = ..., create_by_id: _Optional[int] = ..., primary_cluster_id: _Optional[int] = ..., port: _Optional[int] = ..., xaccount_deploy_id: _Optional[int] = ..., traffic_filter: _Optional[_Union[TrafficFilter, _Mapping]] = ..., restore_id: _Optional[int] = ..., recovery_mode: bool = ..., initial_version: _Optional[str] = ..., option: _Optional[_Union[CreateClusterOption, _Mapping]] = ..., spend_limits: _Optional[float] = ..., dryrun: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateClusterResp(_message.Message):
    __slots__ = ["base_resp", "id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    id: int
    def __init__(self, id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateClusterSnapshotReq(_message.Message):
    __slots__ = ["base_req", "cluster_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    def __init__(self, cluster_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateClusterSnapshotResp(_message.Message):
    __slots__ = ["base_resp", "snapshot_id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    SNAPSHOT_ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    snapshot_id: int
    def __init__(self, snapshot_id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateDBRoleReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "grants", "operator", "revocation", "role_name"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    GRANTS_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    REVOCATION_FIELD_NUMBER: _ClassVar[int]
    ROLE_NAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    grants: str
    operator: DBUserOperator
    revocation: str
    role_name: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., role_name: _Optional[str] = ..., grants: _Optional[str] = ..., revocation: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateDBRoleResp(_message.Message):
    __slots__ = ["base_resp", "proxy_error"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    proxy_error: ClusterProxyError
    def __init__(self, proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateDBUserReq(_message.Message):
    __slots__ = ["auth_method", "base_req", "builtin_role", "cluster_id", "credential", "custom_roles", "email", "operator", "settings", "user_type", "username"]
    class Settings(_message.Message):
        __slots__ = ["ignore_exists"]
        IGNORE_EXISTS_FIELD_NUMBER: _ClassVar[int]
        ignore_exists: bool
        def __init__(self, ignore_exists: bool = ...) -> None: ...
    AUTH_METHOD_FIELD_NUMBER: _ClassVar[int]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    BUILTIN_ROLE_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    CREDENTIAL_FIELD_NUMBER: _ClassVar[int]
    CUSTOM_ROLES_FIELD_NUMBER: _ClassVar[int]
    EMAIL_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    SETTINGS_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    USER_TYPE_FIELD_NUMBER: _ClassVar[int]
    auth_method: DBUser.AuthMethod
    base_req: _base_pb2.BaseReq
    builtin_role: DBUser.BuiltinRole
    cluster_id: int
    credential: str
    custom_roles: _containers.RepeatedScalarFieldContainer[str]
    email: str
    operator: DBUserOperator
    settings: CreateDBUserReq.Settings
    user_type: DBUser.Type
    username: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., user_type: _Optional[_Union[DBUser.Type, str]] = ..., username: _Optional[str] = ..., email: _Optional[str] = ..., auth_method: _Optional[_Union[DBUser.AuthMethod, str]] = ..., credential: _Optional[str] = ..., builtin_role: _Optional[_Union[DBUser.BuiltinRole, str]] = ..., custom_roles: _Optional[_Iterable[str]] = ..., settings: _Optional[_Union[CreateDBUserReq.Settings, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateDBUserResp(_message.Message):
    __slots__ = ["base_resp", "proxy_error"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    proxy_error: ClusterProxyError
    def __init__(self, proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateIamRoleReq(_message.Message):
    __slots__ = ["base_req", "project_id", "role_arn"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    ROLE_ARN_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    project_id: int
    role_arn: str
    def __init__(self, project_id: _Optional[int] = ..., role_arn: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateIamRoleResp(_message.Message):
    __slots__ = ["base_resp", "id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    id: int
    def __init__(self, id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateMaintenanceTaskReq(_message.Message):
    __slots__ = ["base_req", "deadline", "description", "project_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    DEADLINE_FIELD_NUMBER: _ClassVar[int]
    DESCRIPTION_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    deadline: int
    description: str
    project_id: int
    def __init__(self, project_id: _Optional[int] = ..., description: _Optional[str] = ..., deadline: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateMaintenanceTaskResp(_message.Message):
    __slots__ = ["base_resp", "id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    id: int
    def __init__(self, id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateNetworkPeerReq(_message.Message):
    __slots__ = ["base_req", "operator_user_id", "peering"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_USER_ID_FIELD_NUMBER: _ClassVar[int]
    PEERING_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    operator_user_id: int
    peering: NetworkPeer
    def __init__(self, peering: _Optional[_Union[NetworkPeer, _Mapping]] = ..., operator_user_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateNetworkPeerResp(_message.Message):
    __slots__ = ["base_resp", "peering_id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PEERING_ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    peering_id: int
    def __init__(self, peering_id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreatePrivateLinkEndpointReq(_message.Message):
    __slots__ = ["cluster_id", "org_id", "privatelink_endpoint", "project_id"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    ORG_ID_FIELD_NUMBER: _ClassVar[int]
    PRIVATELINK_ENDPOINT_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    org_id: int
    privatelink_endpoint: PrivateLinkEndpoint
    project_id: int
    def __init__(self, org_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cluster_id: _Optional[int] = ..., privatelink_endpoint: _Optional[_Union[PrivateLinkEndpoint, _Mapping]] = ...) -> None: ...

class CreatePrivateLinkEndpointResp(_message.Message):
    __slots__ = ["base_resp", "privatelink_endpoint"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PRIVATELINK_ENDPOINT_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    privatelink_endpoint: PrivateLinkEndpoint
    def __init__(self, privatelink_endpoint: _Optional[_Union[PrivateLinkEndpoint, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreatePrivateLinkServiceReq(_message.Message):
    __slots__ = ["cluster_id", "org_id", "privatelink_service", "project_id"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    ORG_ID_FIELD_NUMBER: _ClassVar[int]
    PRIVATELINK_SERVICE_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    org_id: int
    privatelink_service: PrivateLinkService
    project_id: int
    def __init__(self, org_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cluster_id: _Optional[int] = ..., privatelink_service: _Optional[_Union[PrivateLinkService, _Mapping]] = ...) -> None: ...

class CreatePrivateLinkServiceResp(_message.Message):
    __slots__ = ["base_resp", "privatelink_service"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PRIVATELINK_SERVICE_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    privatelink_service: PrivateLinkService
    def __init__(self, privatelink_service: _Optional[_Union[PrivateLinkService, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class CreateXAccountDeployReq(_message.Message):
    __slots__ = ["aws", "base_req", "cloud_provider", "project_id", "region"]
    AWS_FIELD_NUMBER: _ClassVar[int]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_FIELD_NUMBER: _ClassVar[int]
    aws: AwsXAccountDeployParams
    base_req: _base_pb2.BaseReq
    cloud_provider: str
    project_id: int
    region: str
    def __init__(self, project_id: _Optional[int] = ..., cloud_provider: _Optional[str] = ..., region: _Optional[str] = ..., aws: _Optional[_Union[AwsXAccountDeployParams, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class CreateXAccountDeployResp(_message.Message):
    __slots__ = ["base_resp", "xaccount_deploy_id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    XACCOUNT_DEPLOY_ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    xaccount_deploy_id: int
    def __init__(self, xaccount_deploy_id: _Optional[int] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DBUser(_message.Message):
    __slots__ = ["builtin_role", "custom_roles", "username"]
    class AuthMethod(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    class BuiltinRole(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    class Type(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    AUTH_METHOD_PASSWORD: DBUser.AuthMethod
    AUTH_METHOD_TOKEN: DBUser.AuthMethod
    AUTH_METHOD_UNSPECIFIED: DBUser.AuthMethod
    BUILTIN_ROLE_CDC_ADMIN: DBUser.BuiltinRole
    BUILTIN_ROLE_FIELD_NUMBER: _ClassVar[int]
    BUILTIN_ROLE_UNSPECIFIED: DBUser.BuiltinRole
    BUILTIN_ROLE_USER_ADMIN: DBUser.BuiltinRole
    BUILTIN_ROLE_USER_MEMBER: DBUser.BuiltinRole
    BUILTIN_ROLE_USER_OBSERVER: DBUser.BuiltinRole
    CUSTOM_ROLES_FIELD_NUMBER: _ClassVar[int]
    TYPE_DELEGATE: DBUser.Type
    TYPE_UNSPECIFIED: DBUser.Type
    TYPE_USER_DEFINED: DBUser.Type
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    builtin_role: DBUser.BuiltinRole
    custom_roles: _containers.RepeatedScalarFieldContainer[str]
    username: str
    def __init__(self, username: _Optional[str] = ..., builtin_role: _Optional[_Union[DBUser.BuiltinRole, str]] = ..., custom_roles: _Optional[_Iterable[str]] = ...) -> None: ...

class DBUserOperator(_message.Message):
    __slots__ = ["auth_method", "credential", "username"]
    AUTH_METHOD_FIELD_NUMBER: _ClassVar[int]
    CREDENTIAL_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    auth_method: DBUser.AuthMethod
    credential: str
    username: str
    def __init__(self, username: _Optional[str] = ..., auth_method: _Optional[_Union[DBUser.AuthMethod, str]] = ..., credential: _Optional[str] = ...) -> None: ...

class DeferMaintenanceTaskReq(_message.Message):
    __slots__ = ["base_req", "id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    id: int
    def __init__(self, id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeferMaintenanceTaskResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeleteClusterJobReq(_message.Message):
    __slots__ = ["base_req", "identifier"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    IDENTIFIER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    identifier: ClusterJobIdentifier
    def __init__(self, identifier: _Optional[_Union[ClusterJobIdentifier, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeleteClusterJobResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeleteClusterReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "require_final_backup"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    REQUIRE_FINAL_BACKUP_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    require_final_backup: bool
    def __init__(self, cluster_id: _Optional[int] = ..., require_final_backup: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeleteClusterResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeleteDBUserReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "operator", "username"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    operator: DBUserOperator
    username: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., username: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeleteDBUserResp(_message.Message):
    __slots__ = ["base_resp", "proxy_error"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    proxy_error: ClusterProxyError
    def __init__(self, proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeleteIamRoleReq(_message.Message):
    __slots__ = ["base_req", "role_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    ROLE_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    role_id: int
    def __init__(self, role_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeleteIamRoleResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeleteNetworkPeerReq(_message.Message):
    __slots__ = ["base_req", "cloud_provider", "operator_user_id", "peering_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_USER_ID_FIELD_NUMBER: _ClassVar[int]
    PEERING_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cloud_provider: str
    operator_user_id: int
    peering_id: int
    def __init__(self, peering_id: _Optional[int] = ..., cloud_provider: _Optional[str] = ..., operator_user_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeleteNetworkPeerResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeletePrivateLinkEndpointReq(_message.Message):
    __slots__ = ["cluster_id", "endpoint_id", "org_id", "project_id"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    ENDPOINT_ID_FIELD_NUMBER: _ClassVar[int]
    ORG_ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    endpoint_id: str
    org_id: int
    project_id: int
    def __init__(self, org_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cluster_id: _Optional[int] = ..., endpoint_id: _Optional[str] = ...) -> None: ...

class DeletePrivateLinkEndpointResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeletePrivateLinkServiceReq(_message.Message):
    __slots__ = ["cluster_id", "org_id", "project_id"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    ORG_ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    org_id: int
    project_id: int
    def __init__(self, org_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cluster_id: _Optional[int] = ...) -> None: ...

class DeletePrivateLinkServiceResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class DeleteXAccountDeployReq(_message.Message):
    __slots__ = ["base_req", "xaccount_deploy_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    XACCOUNT_DEPLOY_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    xaccount_deploy_id: int
    def __init__(self, xaccount_deploy_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class DeleteXAccountDeployResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetAwsCmekReq(_message.Message):
    __slots__ = ["base_req", "project_id", "region_name"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    project_id: int
    region_name: str
    def __init__(self, project_id: _Optional[int] = ..., region_name: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class GetAwsCmekResp(_message.Message):
    __slots__ = ["base_resp", "cmeks"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    CMEKS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    cmeks: _containers.RepeatedCompositeFieldContainer[AwsCmek]
    def __init__(self, cmeks: _Optional[_Iterable[_Union[AwsCmek, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetClusterCACertificateReq(_message.Message):
    __slots__ = ["cluster_id", "type"]
    class Type(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    DOWNLOAD_URL: GetClusterCACertificateReq.Type
    PEM: GetClusterCACertificateReq.Type
    TYPE_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    type: GetClusterCACertificateReq.Type
    def __init__(self, cluster_id: _Optional[int] = ..., type: _Optional[_Union[GetClusterCACertificateReq.Type, str]] = ...) -> None: ...

class GetClusterCACertificateResp(_message.Message):
    __slots__ = ["base_resp", "certificate", "download_url"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    CERTIFICATE_FIELD_NUMBER: _ClassVar[int]
    DOWNLOAD_URL_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    certificate: bytes
    download_url: str
    def __init__(self, certificate: _Optional[bytes] = ..., download_url: _Optional[str] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetClusterConfidentialInfoReq(_message.Message):
    __slots__ = ["base_req", "cluster_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    def __init__(self, cluster_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class GetClusterConfidentialInfoResp(_message.Message):
    __slots__ = ["base_resp", "info"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    INFO_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    info: ClusterConfidentialInfo
    def __init__(self, info: _Optional[_Union[ClusterConfidentialInfo, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetClusterNameReq(_message.Message):
    __slots__ = ["base_req", "project_id", "tenant_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    project_id: int
    tenant_id: int
    def __init__(self, tenant_id: _Optional[int] = ..., project_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class GetClusterNameResp(_message.Message):
    __slots__ = ["base_resp", "name"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    name: str
    def __init__(self, name: _Optional[str] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetDBUserReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "operator", "username"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    operator: DBUserOperator
    username: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., username: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class GetDBUserResp(_message.Message):
    __slots__ = ["base_resp", "proxy_error", "user"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    USER_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    proxy_error: ClusterProxyError
    user: DBUser
    def __init__(self, user: _Optional[_Union[DBUser, _Mapping]] = ..., proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetMaintenanceWindowByProjectIDReq(_message.Message):
    __slots__ = ["base_req", "project_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    project_id: int
    def __init__(self, project_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class GetMaintenanceWindowByProjectIDResp(_message.Message):
    __slots__ = ["base_resp", "maintenance_window"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    MAINTENANCE_WINDOW_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    maintenance_window: MaintenanceWindow
    def __init__(self, maintenance_window: _Optional[_Union[MaintenanceWindow, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class GetPrivateLinkServiceReq(_message.Message):
    __slots__ = ["cluster_id", "org_id", "project_id"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    ORG_ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    org_id: int
    project_id: int
    def __init__(self, org_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cluster_id: _Optional[int] = ...) -> None: ...

class GetPrivateLinkServiceResp(_message.Message):
    __slots__ = ["base_resp", "privatelink_service"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PRIVATELINK_SERVICE_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    privatelink_service: PrivateLinkService
    def __init__(self, privatelink_service: _Optional[_Union[PrivateLinkService, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class IamRole(_message.Message):
    __slots__ = ["arn", "created_at", "id", "usages"]
    ARN_FIELD_NUMBER: _ClassVar[int]
    CREATED_AT_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    USAGES_FIELD_NUMBER: _ClassVar[int]
    arn: str
    created_at: int
    id: int
    usages: _containers.RepeatedCompositeFieldContainer[IamRoleUsage]
    def __init__(self, id: _Optional[int] = ..., arn: _Optional[str] = ..., created_at: _Optional[int] = ..., usages: _Optional[_Iterable[_Union[IamRoleUsage, _Mapping]]] = ...) -> None: ...

class IamRoleFilter(_message.Message):
    __slots__ = ["project_ids"]
    PROJECT_IDS_FIELD_NUMBER: _ClassVar[int]
    project_ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, project_ids: _Optional[_Iterable[int]] = ...) -> None: ...

class IamRoleUsage(_message.Message):
    __slots__ = ["provider_name", "region_display_name", "region_name", "service_name"]
    class ServiceName(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    SERVICE_NAME_CROSS_ACCOUNT: IamRoleUsage.ServiceName
    SERVICE_NAME_FIELD_NUMBER: _ClassVar[int]
    SERVICE_NAME_UNSPECIFIED: IamRoleUsage.ServiceName
    provider_name: str
    region_display_name: str
    region_name: str
    service_name: IamRoleUsage.ServiceName
    def __init__(self, service_name: _Optional[_Union[IamRoleUsage.ServiceName, str]] = ..., provider_name: _Optional[str] = ..., region_name: _Optional[str] = ..., region_display_name: _Optional[str] = ...) -> None: ...

class IsClusterJobRegisteredReq(_message.Message):
    __slots__ = ["base_req", "identifier"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    IDENTIFIER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    identifier: ClusterJobIdentifier
    def __init__(self, identifier: _Optional[_Union[ClusterJobIdentifier, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class IsClusterJobRegisteredResp(_message.Message):
    __slots__ = ["base_resp", "is_registered"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    IS_REGISTERED_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    is_registered: bool
    def __init__(self, is_registered: bool = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class IsDBUserExistingReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "operator", "username"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    operator: DBUserOperator
    username: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., username: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class IsDBUserExistingResp(_message.Message):
    __slots__ = ["base_resp", "existing", "proxy_error"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    EXISTING_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    existing: bool
    proxy_error: ClusterProxyError
    def __init__(self, existing: bool = ..., proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListCloudProvidersReq(_message.Message):
    __slots__ = ["base_req", "deploy_type", "filter_out_empty_cloud_provider", "filter_out_empty_region", "filter_out_inactive_provider", "filter_out_inactive_region", "specific_project_id", "specific_tenant_id", "with_xaccount_deploy_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    FILTER_OUT_EMPTY_CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    FILTER_OUT_EMPTY_REGION_FIELD_NUMBER: _ClassVar[int]
    FILTER_OUT_INACTIVE_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    FILTER_OUT_INACTIVE_REGION_FIELD_NUMBER: _ClassVar[int]
    SPECIFIC_PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    SPECIFIC_TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    WITH_XACCOUNT_DEPLOY_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    deploy_type: DeployType
    filter_out_empty_cloud_provider: bool
    filter_out_empty_region: bool
    filter_out_inactive_provider: bool
    filter_out_inactive_region: bool
    specific_project_id: int
    specific_tenant_id: int
    with_xaccount_deploy_id: bool
    def __init__(self, specific_tenant_id: _Optional[int] = ..., filter_out_empty_cloud_provider: bool = ..., filter_out_empty_region: bool = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., filter_out_inactive_region: bool = ..., filter_out_inactive_provider: bool = ..., with_xaccount_deploy_id: bool = ..., specific_project_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListCloudProvidersResp(_message.Message):
    __slots__ = ["base_resp", "name2cloud_provider"]
    class Name2cloudProviderEntry(_message.Message):
        __slots__ = ["key", "value"]
        KEY_FIELD_NUMBER: _ClassVar[int]
        VALUE_FIELD_NUMBER: _ClassVar[int]
        key: str
        value: CloudProvider
        def __init__(self, key: _Optional[str] = ..., value: _Optional[_Union[CloudProvider, _Mapping]] = ...) -> None: ...
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    NAME2CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    name2cloud_provider: _containers.MessageMap[str, CloudProvider]
    def __init__(self, name2cloud_provider: _Optional[_Mapping[str, CloudProvider]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListCloudRegionsReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: CloudRegionFilter
    def __init__(self, filter: _Optional[_Union[CloudRegionFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListCloudRegionsResp(_message.Message):
    __slots__ = ["base_resp", "regions"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    REGIONS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    regions: _containers.RepeatedCompositeFieldContainer[CloudRegion]
    def __init__(self, regions: _Optional[_Iterable[_Union[CloudRegion, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListClusterJobsReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: ClusterJobFilter
    def __init__(self, filter: _Optional[_Union[ClusterJobFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListClusterJobsResp(_message.Message):
    __slots__ = ["base_resp", "jobs"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    JOBS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    jobs: _containers.RepeatedCompositeFieldContainer[ClusterJob]
    def __init__(self, jobs: _Optional[_Iterable[_Union[ClusterJob, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListClusterSnapshotsReq(_message.Message):
    __slots__ = ["base_req", "filter", "pager", "sorters"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    PAGER_FIELD_NUMBER: _ClassVar[int]
    SORTERS_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: ClusterSnapshotFilter
    pager: _base_pb2.Pager
    sorters: _containers.RepeatedCompositeFieldContainer[_base_pb2.Sorter]
    def __init__(self, filter: _Optional[_Union[ClusterSnapshotFilter, _Mapping]] = ..., pager: _Optional[_Union[_base_pb2.Pager, _Mapping]] = ..., sorters: _Optional[_Iterable[_Union[_base_pb2.Sorter, _Mapping]]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListClusterSnapshotsResp(_message.Message):
    __slots__ = ["base_resp", "snapshots"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    SNAPSHOTS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    snapshots: _containers.RepeatedCompositeFieldContainer[ClusterSnapshot]
    def __init__(self, snapshots: _Optional[_Iterable[_Union[ClusterSnapshot, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListClustersReq(_message.Message):
    __slots__ = ["base_req", "filter", "pager", "sorter", "sorters", "with_data_plane_info"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    PAGER_FIELD_NUMBER: _ClassVar[int]
    SORTERS_FIELD_NUMBER: _ClassVar[int]
    SORTER_FIELD_NUMBER: _ClassVar[int]
    WITH_DATA_PLANE_INFO_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: ClusterFilter
    pager: _base_pb2.Pager
    sorter: _base_pb2.Sorter
    sorters: _containers.RepeatedCompositeFieldContainer[_base_pb2.Sorter]
    with_data_plane_info: bool
    def __init__(self, filter: _Optional[_Union[ClusterFilter, _Mapping]] = ..., pager: _Optional[_Union[_base_pb2.Pager, _Mapping]] = ..., sorter: _Optional[_Union[_base_pb2.Sorter, _Mapping]] = ..., sorters: _Optional[_Iterable[_Union[_base_pb2.Sorter, _Mapping]]] = ..., with_data_plane_info: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListClustersResp(_message.Message):
    __slots__ = ["base_resp", "clusters", "ordered_cluster_ids"]
    class ClustersEntry(_message.Message):
        __slots__ = ["key", "value"]
        KEY_FIELD_NUMBER: _ClassVar[int]
        VALUE_FIELD_NUMBER: _ClassVar[int]
        key: int
        value: Cluster
        def __init__(self, key: _Optional[int] = ..., value: _Optional[_Union[Cluster, _Mapping]] = ...) -> None: ...
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    CLUSTERS_FIELD_NUMBER: _ClassVar[int]
    ORDERED_CLUSTER_IDS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    clusters: _containers.MessageMap[int, Cluster]
    ordered_cluster_ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, clusters: _Optional[_Mapping[int, Cluster]] = ..., ordered_cluster_ids: _Optional[_Iterable[int]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListIamRolesReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: IamRoleFilter
    def __init__(self, filter: _Optional[_Union[IamRoleFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListIamRolesResp(_message.Message):
    __slots__ = ["base_resp", "roles"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    ROLES_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    roles: _containers.RepeatedCompositeFieldContainer[IamRole]
    def __init__(self, roles: _Optional[_Iterable[_Union[IamRole, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListNetworkPeerReq(_message.Message):
    __slots__ = ["base_req", "filter", "pager", "sorter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    PAGER_FIELD_NUMBER: _ClassVar[int]
    SORTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: NetworkPeerFilter
    pager: _base_pb2.Pager
    sorter: _base_pb2.Sorter
    def __init__(self, filter: _Optional[_Union[NetworkPeerFilter, _Mapping]] = ..., pager: _Optional[_Union[_base_pb2.Pager, _Mapping]] = ..., sorter: _Optional[_Union[_base_pb2.Sorter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListNetworkPeerResp(_message.Message):
    __slots__ = ["base_resp", "peering_list"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PEERING_LIST_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    peering_list: _containers.RepeatedCompositeFieldContainer[NetworkPeer]
    def __init__(self, peering_list: _Optional[_Iterable[_Union[NetworkPeer, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListNodeProfiles4TenantReq(_message.Message):
    __slots__ = ["base_req", "cloud_provider_name", "deploy_type", "project_id", "region_name", "tenant_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cloud_provider_name: str
    deploy_type: DeployType
    project_id: int
    region_name: str
    tenant_id: int
    def __init__(self, tenant_id: _Optional[int] = ..., cloud_provider_name: _Optional[str] = ..., region_name: _Optional[str] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., project_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListNodeProfiles4TenantResp(_message.Message):
    __slots__ = ["base_resp", "profiles"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROFILES_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    profiles: _containers.RepeatedCompositeFieldContainer[NodeProfile4Tenant]
    def __init__(self, profiles: _Optional[_Iterable[_Union[NodeProfile4Tenant, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListPrivateLinkEndpointsReq(_message.Message):
    __slots__ = ["org_id", "project_id"]
    ORG_ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    org_id: int
    project_id: int
    def __init__(self, org_id: _Optional[int] = ..., project_id: _Optional[int] = ...) -> None: ...

class ListPrivateLinkEndpointsResp(_message.Message):
    __slots__ = ["base_resp", "endpoints"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    ENDPOINTS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    endpoints: _containers.RepeatedCompositeFieldContainer[PrivateLinkEndpoint]
    def __init__(self, endpoints: _Optional[_Iterable[_Union[PrivateLinkEndpoint, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListRegionCIDROfProjectReq(_message.Message):
    __slots__ = ["base_req", "cloud_provider", "project_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cloud_provider: str
    project_id: int
    def __init__(self, project_id: _Optional[int] = ..., cloud_provider: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListRegionCIDROfProjectResp(_message.Message):
    __slots__ = ["base_resp", "project_cidr", "region_cidrs"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROJECT_CIDR_FIELD_NUMBER: _ClassVar[int]
    REGION_CIDRS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    project_cidr: str
    region_cidrs: _containers.RepeatedCompositeFieldContainer[RegionCIDR]
    def __init__(self, project_cidr: _Optional[str] = ..., region_cidrs: _Optional[_Iterable[_Union[RegionCIDR, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ListXAccountDeployReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: XAccountDeployFilter
    def __init__(self, filter: _Optional[_Union[XAccountDeployFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ListXAccountDeployResp(_message.Message):
    __slots__ = ["base_resp", "xaccount_deploys"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    XACCOUNT_DEPLOYS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    xaccount_deploys: _containers.RepeatedCompositeFieldContainer[XAccountDeploy]
    def __init__(self, xaccount_deploys: _Optional[_Iterable[_Union[XAccountDeploy, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class MaintenanceTask(_message.Message):
    __slots__ = ["created_at", "deadline", "description", "id", "project_id", "scheduled_apply_time", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    CREATED_AT_FIELD_NUMBER: _ClassVar[int]
    DEADLINE_FIELD_NUMBER: _ClassVar[int]
    DESCRIPTION_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    SCHEDULED_APPLY_TIME_FIELD_NUMBER: _ClassVar[int]
    STATUS_DONE: MaintenanceTask.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_PENDING: MaintenanceTask.Status
    STATUS_RUNNING: MaintenanceTask.Status
    STATUS_UNSPECIFIED: MaintenanceTask.Status
    created_at: int
    deadline: int
    description: str
    id: int
    project_id: int
    scheduled_apply_time: int
    status: MaintenanceTask.Status
    def __init__(self, id: _Optional[int] = ..., project_id: _Optional[int] = ..., created_at: _Optional[int] = ..., description: _Optional[str] = ..., status: _Optional[_Union[MaintenanceTask.Status, str]] = ..., scheduled_apply_time: _Optional[int] = ..., deadline: _Optional[int] = ...) -> None: ...

class MaintenanceTaskExecution(_message.Message):
    __slots__ = ["cancellation_reason", "cluster_id", "maintenance_task_id", "status"]
    class CancellationReason(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    CANCELLATION_REASON_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    MAINTENANCE_TASK_ID_FIELD_NUMBER: _ClassVar[int]
    REASON_CLUSTER_DELETED: MaintenanceTaskExecution.CancellationReason
    REASON_OPS_CANCELED: MaintenanceTaskExecution.CancellationReason
    REASON_UNSPECIFIED: MaintenanceTaskExecution.CancellationReason
    STATUS_CANCELED: MaintenanceTaskExecution.Status
    STATUS_DONE: MaintenanceTaskExecution.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_PENDING: MaintenanceTaskExecution.Status
    STATUS_RUNNING: MaintenanceTaskExecution.Status
    STATUS_UNSPECIFIED: MaintenanceTaskExecution.Status
    cancellation_reason: MaintenanceTaskExecution.CancellationReason
    cluster_id: int
    maintenance_task_id: int
    status: MaintenanceTaskExecution.Status
    def __init__(self, maintenance_task_id: _Optional[int] = ..., cluster_id: _Optional[int] = ..., status: _Optional[_Union[MaintenanceTaskExecution.Status, str]] = ..., cancellation_reason: _Optional[_Union[MaintenanceTaskExecution.CancellationReason, str]] = ...) -> None: ...

class MaintenanceTaskExecutionFilter(_message.Message):
    __slots__ = ["cluster_ids", "statuses"]
    CLUSTER_IDS_FIELD_NUMBER: _ClassVar[int]
    STATUSES_FIELD_NUMBER: _ClassVar[int]
    cluster_ids: _containers.RepeatedScalarFieldContainer[int]
    statuses: _containers.RepeatedScalarFieldContainer[MaintenanceTaskExecution.Status]
    def __init__(self, cluster_ids: _Optional[_Iterable[int]] = ..., statuses: _Optional[_Iterable[_Union[MaintenanceTaskExecution.Status, str]]] = ...) -> None: ...

class MaintenanceTaskFilter(_message.Message):
    __slots__ = ["project_ids", "statuses"]
    PROJECT_IDS_FIELD_NUMBER: _ClassVar[int]
    STATUSES_FIELD_NUMBER: _ClassVar[int]
    project_ids: _containers.RepeatedScalarFieldContainer[int]
    statuses: _containers.RepeatedScalarFieldContainer[MaintenanceTask.Status]
    def __init__(self, project_ids: _Optional[_Iterable[int]] = ..., statuses: _Optional[_Iterable[_Union[MaintenanceTask.Status, str]]] = ...) -> None: ...

class MaintenanceWindow(_message.Message):
    __slots__ = ["day_of_week", "hour_of_day", "minute_of_hour", "project_id"]
    DAY_OF_WEEK_FIELD_NUMBER: _ClassVar[int]
    HOUR_OF_DAY_FIELD_NUMBER: _ClassVar[int]
    MINUTE_OF_HOUR_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    day_of_week: int
    hour_of_day: int
    minute_of_hour: int
    project_id: int
    def __init__(self, project_id: _Optional[int] = ..., day_of_week: _Optional[int] = ..., hour_of_day: _Optional[int] = ..., minute_of_hour: _Optional[int] = ...) -> None: ...

class MeasureReq(_message.Message):
    __slots__ = ["base_req", "end_time", "measure_cluster", "measure_project", "tenant_ids"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    END_TIME_FIELD_NUMBER: _ClassVar[int]
    MEASURE_CLUSTER_FIELD_NUMBER: _ClassVar[int]
    MEASURE_PROJECT_FIELD_NUMBER: _ClassVar[int]
    TENANT_IDS_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    end_time: int
    measure_cluster: bool
    measure_project: bool
    tenant_ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, tenant_ids: _Optional[_Iterable[int]] = ..., end_time: _Optional[int] = ..., measure_project: bool = ..., measure_cluster: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class MeasureResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class NetworkPeer(_message.Message):
    __slots__ = ["aws", "cloud_provider", "gcp", "id", "network", "peer_network", "peer_region", "peer_vpc_cidr", "project_id", "region", "region_display_name", "status", "tenant_id", "type", "vpc_cidr"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    class Type(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    AWS_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    GCP_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    NETWORK_FIELD_NUMBER: _ClassVar[int]
    PEER_NETWORK_FIELD_NUMBER: _ClassVar[int]
    PEER_REGION_FIELD_NUMBER: _ClassVar[int]
    PEER_VPC_CIDR_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_FIELD_NUMBER: _ClassVar[int]
    STATUS_ACTIVE: NetworkPeer.Status
    STATUS_FAILED: NetworkPeer.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_PENDING: NetworkPeer.Status
    STATUS_UNSPECIFIED: NetworkPeer.Status
    TENANT_ID_FIELD_NUMBER: _ClassVar[int]
    TYPE_CUSTOMER: NetworkPeer.Type
    TYPE_DBAAS: NetworkPeer.Type
    TYPE_FIELD_NUMBER: _ClassVar[int]
    TYPE_UNSPECIFIED: NetworkPeer.Type
    VPC_CIDR_FIELD_NUMBER: _ClassVar[int]
    aws: NetworkPeerInfo4Aws
    cloud_provider: str
    gcp: NetworkPeerInfo4Gcp
    id: int
    network: str
    peer_network: str
    peer_region: str
    peer_vpc_cidr: str
    project_id: int
    region: str
    region_display_name: str
    status: NetworkPeer.Status
    tenant_id: int
    type: NetworkPeer.Type
    vpc_cidr: str
    def __init__(self, id: _Optional[int] = ..., tenant_id: _Optional[int] = ..., project_id: _Optional[int] = ..., cloud_provider: _Optional[str] = ..., region: _Optional[str] = ..., vpc_cidr: _Optional[str] = ..., network: _Optional[str] = ..., peer_region: _Optional[str] = ..., peer_vpc_cidr: _Optional[str] = ..., peer_network: _Optional[str] = ..., type: _Optional[_Union[NetworkPeer.Type, str]] = ..., status: _Optional[_Union[NetworkPeer.Status, str]] = ..., region_display_name: _Optional[str] = ..., aws: _Optional[_Union[NetworkPeerInfo4Aws, _Mapping]] = ..., gcp: _Optional[_Union[NetworkPeerInfo4Gcp, _Mapping]] = ...) -> None: ...

class NetworkPeerFilter(_message.Message):
    __slots__ = ["cloud_provider", "peering_ids", "project_ids", "region_names", "statuses", "types"]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    PEERING_IDS_FIELD_NUMBER: _ClassVar[int]
    PROJECT_IDS_FIELD_NUMBER: _ClassVar[int]
    REGION_NAMES_FIELD_NUMBER: _ClassVar[int]
    STATUSES_FIELD_NUMBER: _ClassVar[int]
    TYPES_FIELD_NUMBER: _ClassVar[int]
    cloud_provider: str
    peering_ids: _containers.RepeatedScalarFieldContainer[int]
    project_ids: _containers.RepeatedScalarFieldContainer[int]
    region_names: _containers.RepeatedScalarFieldContainer[str]
    statuses: _containers.RepeatedScalarFieldContainer[NetworkPeer.Status]
    types: _containers.RepeatedScalarFieldContainer[NetworkPeer.Type]
    def __init__(self, cloud_provider: _Optional[str] = ..., region_names: _Optional[_Iterable[str]] = ..., statuses: _Optional[_Iterable[_Union[NetworkPeer.Status, str]]] = ..., types: _Optional[_Iterable[_Union[NetworkPeer.Type, str]]] = ..., project_ids: _Optional[_Iterable[int]] = ..., peering_ids: _Optional[_Iterable[int]] = ...) -> None: ...

class NetworkPeerInfo4Aws(_message.Message):
    __slots__ = ["peer_account_id", "private_host_zone", "vpc_peering_id"]
    PEER_ACCOUNT_ID_FIELD_NUMBER: _ClassVar[int]
    PRIVATE_HOST_ZONE_FIELD_NUMBER: _ClassVar[int]
    VPC_PEERING_ID_FIELD_NUMBER: _ClassVar[int]
    peer_account_id: str
    private_host_zone: str
    vpc_peering_id: str
    def __init__(self, peer_account_id: _Optional[str] = ..., vpc_peering_id: _Optional[str] = ..., private_host_zone: _Optional[str] = ...) -> None: ...

class NetworkPeerInfo4Gcp(_message.Message):
    __slots__ = ["peer_project_id", "project_id"]
    PEER_PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    peer_project_id: str
    project_id: str
    def __init__(self, peer_project_id: _Optional[str] = ..., project_id: _Optional[str] = ...) -> None: ...

class NodeProfile4Tenant(_message.Message):
    __slots__ = ["cloud_provider", "component_type", "cpu_num", "default_node_num", "default_storage_size_gi", "deploy_type", "display_name", "max_storage_size_gi", "memory_gi", "min_storage_size_gi", "name", "region"]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    COMPONENT_TYPE_FIELD_NUMBER: _ClassVar[int]
    CPU_NUM_FIELD_NUMBER: _ClassVar[int]
    DEFAULT_NODE_NUM_FIELD_NUMBER: _ClassVar[int]
    DEFAULT_STORAGE_SIZE_GI_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    MAX_STORAGE_SIZE_GI_FIELD_NUMBER: _ClassVar[int]
    MEMORY_GI_FIELD_NUMBER: _ClassVar[int]
    MIN_STORAGE_SIZE_GI_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_FIELD_NUMBER: _ClassVar[int]
    cloud_provider: str
    component_type: ComponentType
    cpu_num: int
    default_node_num: int
    default_storage_size_gi: int
    deploy_type: DeployType
    display_name: str
    max_storage_size_gi: int
    memory_gi: int
    min_storage_size_gi: int
    name: str
    region: str
    def __init__(self, name: _Optional[str] = ..., component_type: _Optional[_Union[ComponentType, str]] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., cloud_provider: _Optional[str] = ..., region: _Optional[str] = ..., cpu_num: _Optional[int] = ..., memory_gi: _Optional[int] = ..., display_name: _Optional[str] = ..., default_node_num: _Optional[int] = ..., min_storage_size_gi: _Optional[int] = ..., max_storage_size_gi: _Optional[int] = ..., default_storage_size_gi: _Optional[int] = ...) -> None: ...

class PauseClusterReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "operator_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    operator_id: int
    def __init__(self, cluster_id: _Optional[int] = ..., operator_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class PauseClusterResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class PrivateLinkEndpoint(_message.Message):
    __slots__ = ["cloud_provider", "cluster_id", "cluster_name", "endpoint_id", "message", "region_name", "service_name", "service_status", "status", "type"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    class Type(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    ACTIVE: PrivateLinkEndpoint.Status
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_NAME_FIELD_NUMBER: _ClassVar[int]
    DELETING: PrivateLinkEndpoint.Status
    ENDPOINT_ID_FIELD_NUMBER: _ClassVar[int]
    FAILED: PrivateLinkEndpoint.Status
    MESSAGE_FIELD_NUMBER: _ClassVar[int]
    NOT_CONFIGURE: PrivateLinkEndpoint.Status
    PENDING: PrivateLinkEndpoint.Status
    REGION_NAME_FIELD_NUMBER: _ClassVar[int]
    SERVICE_NAME_FIELD_NUMBER: _ClassVar[int]
    SERVICE_STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_FIELD_NUMBER: _ClassVar[int]
    TYPE_CUSTOMER: PrivateLinkEndpoint.Type
    TYPE_DBAAS: PrivateLinkEndpoint.Type
    TYPE_FIELD_NUMBER: _ClassVar[int]
    TYPE_UNSPECIFIED: PrivateLinkEndpoint.Type
    cloud_provider: str
    cluster_id: int
    cluster_name: str
    endpoint_id: str
    message: str
    region_name: str
    service_name: str
    service_status: PrivateLinkService.Status
    status: PrivateLinkEndpoint.Status
    type: PrivateLinkEndpoint.Type
    def __init__(self, cloud_provider: _Optional[str] = ..., cluster_id: _Optional[int] = ..., cluster_name: _Optional[str] = ..., region_name: _Optional[str] = ..., endpoint_id: _Optional[str] = ..., status: _Optional[_Union[PrivateLinkEndpoint.Status, str]] = ..., message: _Optional[str] = ..., service_name: _Optional[str] = ..., service_status: _Optional[_Union[PrivateLinkService.Status, str]] = ..., type: _Optional[_Union[PrivateLinkEndpoint.Type, str]] = ...) -> None: ...

class PrivateLinkService(_message.Message):
    __slots__ = ["az_ids", "cloud_provider", "dns_name", "name", "port", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    ACTIVE: PrivateLinkService.Status
    AZ_IDS_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    CREATING: PrivateLinkService.Status
    DELETING: PrivateLinkService.Status
    DNS_NAME_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    NOT_CONFIGURE: PrivateLinkService.Status
    PORT_FIELD_NUMBER: _ClassVar[int]
    STATUS_FIELD_NUMBER: _ClassVar[int]
    az_ids: _containers.RepeatedScalarFieldContainer[str]
    cloud_provider: str
    dns_name: str
    name: str
    port: int
    status: PrivateLinkService.Status
    def __init__(self, cloud_provider: _Optional[str] = ..., name: _Optional[str] = ..., status: _Optional[_Union[PrivateLinkService.Status, str]] = ..., dns_name: _Optional[str] = ..., port: _Optional[int] = ..., az_ids: _Optional[_Iterable[str]] = ...) -> None: ...

class ProfileVersion(_message.Message):
    __slots__ = ["commit_id", "id", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    COMMIT_ID_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_OUTDATED: ProfileVersion.Status
    STATUS_SYNCING: ProfileVersion.Status
    STATUS_UNSPECIFIED: ProfileVersion.Status
    STATUS_USING: ProfileVersion.Status
    commit_id: str
    id: int
    status: ProfileVersion.Status
    def __init__(self, id: _Optional[int] = ..., status: _Optional[_Union[ProfileVersion.Status, str]] = ..., commit_id: _Optional[str] = ...) -> None: ...

class QueryCloudProvidersReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: SimplifiedCloudProviderFilter
    def __init__(self, filter: _Optional[_Union[SimplifiedCloudProviderFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class QueryCloudProvidersResp(_message.Message):
    __slots__ = ["base_resp", "cloud_providers"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDERS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    cloud_providers: _containers.RepeatedCompositeFieldContainer[SimplifiedCloudProvider]
    def __init__(self, cloud_providers: _Optional[_Iterable[_Union[SimplifiedCloudProvider, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class QueryMaintenanceTaskExecutionsReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: MaintenanceTaskExecutionFilter
    def __init__(self, filter: _Optional[_Union[MaintenanceTaskExecutionFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class QueryMaintenanceTaskExecutionsResp(_message.Message):
    __slots__ = ["base_resp", "executions"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    EXECUTIONS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    executions: _containers.RepeatedCompositeFieldContainer[MaintenanceTaskExecution]
    def __init__(self, executions: _Optional[_Iterable[_Union[MaintenanceTaskExecution, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class QueryMaintenanceTasksReq(_message.Message):
    __slots__ = ["base_req", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    filter: MaintenanceTaskFilter
    def __init__(self, filter: _Optional[_Union[MaintenanceTaskFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class QueryMaintenanceTasksResp(_message.Message):
    __slots__ = ["base_resp", "tasks"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    TASKS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    tasks: _containers.RepeatedCompositeFieldContainer[MaintenanceTask]
    def __init__(self, tasks: _Optional[_Iterable[_Union[MaintenanceTask, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class Region(_message.Message):
    __slots__ = ["area", "cloud_provider_name", "country_code", "display_name", "name", "opened_tenant_ids", "priority", "status", "xaccount_deploy_id"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    AREA_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_NAME_FIELD_NUMBER: _ClassVar[int]
    COUNTRY_CODE_FIELD_NUMBER: _ClassVar[int]
    DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    OPENED_TENANT_IDS_FIELD_NUMBER: _ClassVar[int]
    PRIORITY_FIELD_NUMBER: _ClassVar[int]
    STATUS_ACTIVE: Region.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_INACTIVE: Region.Status
    STATUS_UNSPECIFIED: Region.Status
    XACCOUNT_DEPLOY_ID_FIELD_NUMBER: _ClassVar[int]
    area: str
    cloud_provider_name: str
    country_code: str
    display_name: str
    name: str
    opened_tenant_ids: _containers.RepeatedScalarFieldContainer[int]
    priority: int
    status: Region.Status
    xaccount_deploy_id: int
    def __init__(self, name: _Optional[str] = ..., display_name: _Optional[str] = ..., cloud_provider_name: _Optional[str] = ..., status: _Optional[_Union[Region.Status, str]] = ..., opened_tenant_ids: _Optional[_Iterable[int]] = ..., xaccount_deploy_id: _Optional[int] = ..., priority: _Optional[int] = ..., area: _Optional[str] = ..., country_code: _Optional[str] = ...) -> None: ...

class RegionCIDR(_message.Message):
    __slots__ = ["active", "cidr", "project_id", "region", "region_display_name"]
    ACTIVE_FIELD_NUMBER: _ClassVar[int]
    CIDR_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_FIELD_NUMBER: _ClassVar[int]
    active: bool
    cidr: str
    project_id: int
    region: str
    region_display_name: str
    def __init__(self, project_id: _Optional[int] = ..., region: _Optional[str] = ..., region_display_name: _Optional[str] = ..., cidr: _Optional[str] = ..., active: bool = ...) -> None: ...

class ResumeClusterReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "operator_id"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_ID_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    operator_id: int
    def __init__(self, cluster_id: _Optional[int] = ..., operator_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ResumeClusterResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class SampleReq(_message.Message):
    __slots__ = ["base_req"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    def __init__(self, base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class SampleResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class ScaleClusterReq(_message.Message):
    __slots__ = ["allow_scale_down", "allow_scale_in", "allow_scale_secondary", "base_req", "cluster_id", "new_components", "operator_id"]
    ALLOW_SCALE_DOWN_FIELD_NUMBER: _ClassVar[int]
    ALLOW_SCALE_IN_FIELD_NUMBER: _ClassVar[int]
    ALLOW_SCALE_SECONDARY_FIELD_NUMBER: _ClassVar[int]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    NEW_COMPONENTS_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_ID_FIELD_NUMBER: _ClassVar[int]
    allow_scale_down: bool
    allow_scale_in: bool
    allow_scale_secondary: bool
    base_req: _base_pb2.BaseReq
    cluster_id: int
    new_components: _containers.RepeatedCompositeFieldContainer[ClusterComponent]
    operator_id: int
    def __init__(self, cluster_id: _Optional[int] = ..., new_components: _Optional[_Iterable[_Union[ClusterComponent, _Mapping]]] = ..., allow_scale_in: bool = ..., allow_scale_secondary: bool = ..., allow_scale_down: bool = ..., operator_id: _Optional[int] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class ScaleClusterResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class SetClusterAuthPubKeyReq(_message.Message):
    __slots__ = ["cluster_id", "jwks"]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    JWKS_FIELD_NUMBER: _ClassVar[int]
    cluster_id: int
    jwks: str
    def __init__(self, cluster_id: _Optional[int] = ..., jwks: _Optional[str] = ...) -> None: ...

class SetClusterAuthPubKeyResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class SetClusterReadonlyReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "readonly"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    READONLY_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    readonly: bool
    def __init__(self, cluster_id: _Optional[int] = ..., readonly: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class SetClusterReadonlyResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class SimplifiedCloudProvider(_message.Message):
    __slots__ = ["id", "name", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    ID_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    STATUS_ACTIVE: SimplifiedCloudProvider.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_INACTIVE: SimplifiedCloudProvider.Status
    STATUS_UNSPECIFIED: SimplifiedCloudProvider.Status
    id: int
    name: str
    status: SimplifiedCloudProvider.Status
    def __init__(self, id: _Optional[int] = ..., name: _Optional[str] = ..., status: _Optional[_Union[SimplifiedCloudProvider.Status, str]] = ...) -> None: ...

class SimplifiedCloudProviderFilter(_message.Message):
    __slots__ = ["ids"]
    IDS_FIELD_NUMBER: _ClassVar[int]
    ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, ids: _Optional[_Iterable[int]] = ...) -> None: ...

class SyncInfraProfileReq(_message.Message):
    __slots__ = ["base_req"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    def __init__(self, base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class SyncInfraProfileResp(_message.Message):
    __slots__ = ["base_resp", "request_id"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    REQUEST_ID_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    request_id: str
    def __init__(self, request_id: _Optional[str] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class Tier(_message.Message):
    __slots__ = ["component_type", "cpu_num", "deploy_type", "display_name", "memory_gi", "name"]
    COMPONENT_TYPE_FIELD_NUMBER: _ClassVar[int]
    CPU_NUM_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    MEMORY_GI_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    component_type: ComponentType
    cpu_num: int
    deploy_type: DeployType
    display_name: str
    memory_gi: int
    name: str
    def __init__(self, name: _Optional[str] = ..., display_name: _Optional[str] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., component_type: _Optional[_Union[ComponentType, str]] = ..., cpu_num: _Optional[int] = ..., memory_gi: _Optional[int] = ...) -> None: ...

class TierIdentifier(_message.Message):
    __slots__ = ["component_type", "deploy_type", "name"]
    COMPONENT_TYPE_FIELD_NUMBER: _ClassVar[int]
    DEPLOY_TYPE_FIELD_NUMBER: _ClassVar[int]
    NAME_FIELD_NUMBER: _ClassVar[int]
    component_type: ComponentType
    deploy_type: DeployType
    name: str
    def __init__(self, name: _Optional[str] = ..., deploy_type: _Optional[_Union[DeployType, str]] = ..., component_type: _Optional[_Union[ComponentType, str]] = ...) -> None: ...

class TrafficFilter(_message.Message):
    __slots__ = ["disable_public_lb", "items"]
    DISABLE_PUBLIC_LB_FIELD_NUMBER: _ClassVar[int]
    ITEMS_FIELD_NUMBER: _ClassVar[int]
    disable_public_lb: bool
    items: _containers.RepeatedCompositeFieldContainer[TrafficFilterItem]
    def __init__(self, items: _Optional[_Iterable[_Union[TrafficFilterItem, _Mapping]]] = ..., disable_public_lb: bool = ...) -> None: ...

class TrafficFilterItem(_message.Message):
    __slots__ = ["cidr", "description"]
    CIDR_FIELD_NUMBER: _ClassVar[int]
    DESCRIPTION_FIELD_NUMBER: _ClassVar[int]
    cidr: str
    description: str
    def __init__(self, cidr: _Optional[str] = ..., description: _Optional[str] = ...) -> None: ...

class UnchangedTask(_message.Message):
    __slots__ = ["description", "id"]
    DESCRIPTION_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    description: str
    id: int
    def __init__(self, id: _Optional[int] = ..., description: _Optional[str] = ...) -> None: ...

class UpdateClusterTrafficFilterReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "filter"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    FILTER_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    filter: TrafficFilter
    def __init__(self, cluster_id: _Optional[int] = ..., filter: _Optional[_Union[TrafficFilter, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class UpdateClusterTrafficFilterResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class UpdateDBRoleReq(_message.Message):
    __slots__ = ["base_req", "cluster_id", "grants", "operator", "revocation", "role_name"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    GRANTS_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    REVOCATION_FIELD_NUMBER: _ClassVar[int]
    ROLE_NAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    cluster_id: int
    grants: str
    operator: DBUserOperator
    revocation: str
    role_name: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., role_name: _Optional[str] = ..., grants: _Optional[str] = ..., revocation: _Optional[str] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class UpdateDBRoleResp(_message.Message):
    __slots__ = ["base_resp", "proxy_error"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    proxy_error: ClusterProxyError
    def __init__(self, proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class UpdateDBUserReq(_message.Message):
    __slots__ = ["base_req", "builtin_role", "cluster_id", "custom_roles", "operator", "username"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    BUILTIN_ROLE_FIELD_NUMBER: _ClassVar[int]
    CLUSTER_ID_FIELD_NUMBER: _ClassVar[int]
    CUSTOM_ROLES_FIELD_NUMBER: _ClassVar[int]
    OPERATOR_FIELD_NUMBER: _ClassVar[int]
    USERNAME_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    builtin_role: DBUser.BuiltinRole
    cluster_id: int
    custom_roles: _containers.RepeatedScalarFieldContainer[str]
    operator: DBUserOperator
    username: str
    def __init__(self, operator: _Optional[_Union[DBUserOperator, _Mapping]] = ..., cluster_id: _Optional[int] = ..., username: _Optional[str] = ..., builtin_role: _Optional[_Union[DBUser.BuiltinRole, str]] = ..., custom_roles: _Optional[_Iterable[str]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class UpdateDBUserResp(_message.Message):
    __slots__ = ["base_resp", "proxy_error"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    PROXY_ERROR_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    proxy_error: ClusterProxyError
    def __init__(self, proxy_error: _Optional[_Union[ClusterProxyError, _Mapping]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class UpdateMaintenanceWindowReq(_message.Message):
    __slots__ = ["base_req", "maintenance_window"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    MAINTENANCE_WINDOW_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    maintenance_window: MaintenanceWindow
    def __init__(self, maintenance_window: _Optional[_Union[MaintenanceWindow, _Mapping]] = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class UpdateMaintenanceWindowResp(_message.Message):
    __slots__ = ["base_resp", "unchanged_tasks"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    UNCHANGED_TASKS_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    unchanged_tasks: _containers.RepeatedCompositeFieldContainer[UnchangedTask]
    def __init__(self, unchanged_tasks: _Optional[_Iterable[_Union[UnchangedTask, _Mapping]]] = ..., base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class UpsertProfileByYamlReq(_message.Message):
    __slots__ = ["base_req", "change_id", "dryrun", "sku_file", "tier_file", "tier_unit_file"]
    BASE_REQ_FIELD_NUMBER: _ClassVar[int]
    CHANGE_ID_FIELD_NUMBER: _ClassVar[int]
    DRYRUN_FIELD_NUMBER: _ClassVar[int]
    SKU_FILE_FIELD_NUMBER: _ClassVar[int]
    TIER_FILE_FIELD_NUMBER: _ClassVar[int]
    TIER_UNIT_FILE_FIELD_NUMBER: _ClassVar[int]
    base_req: _base_pb2.BaseReq
    change_id: str
    dryrun: bool
    sku_file: bytes
    tier_file: bytes
    tier_unit_file: bytes
    def __init__(self, change_id: _Optional[str] = ..., tier_file: _Optional[bytes] = ..., tier_unit_file: _Optional[bytes] = ..., sku_file: _Optional[bytes] = ..., dryrun: bool = ..., base_req: _Optional[_Union[_base_pb2.BaseReq, _Mapping]] = ...) -> None: ...

class UpsertProfileByYamlResp(_message.Message):
    __slots__ = ["base_resp"]
    BASE_RESP_FIELD_NUMBER: _ClassVar[int]
    base_resp: _base_pb2.BaseResp
    def __init__(self, base_resp: _Optional[_Union[_base_pb2.BaseResp, _Mapping]] = ...) -> None: ...

class XAccountDeploy(_message.Message):
    __slots__ = ["aws", "cloud_provider", "created_at", "id", "project_id", "region", "region_display_name", "status"]
    class Status(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
        __slots__ = []
    AWS_FIELD_NUMBER: _ClassVar[int]
    CLOUD_PROVIDER_FIELD_NUMBER: _ClassVar[int]
    CREATED_AT_FIELD_NUMBER: _ClassVar[int]
    ID_FIELD_NUMBER: _ClassVar[int]
    PROJECT_ID_FIELD_NUMBER: _ClassVar[int]
    REGION_DISPLAY_NAME_FIELD_NUMBER: _ClassVar[int]
    REGION_FIELD_NUMBER: _ClassVar[int]
    STATUS_ACTIVE: XAccountDeploy.Status
    STATUS_DELETING: XAccountDeploy.Status
    STATUS_FIELD_NUMBER: _ClassVar[int]
    STATUS_PENDING: XAccountDeploy.Status
    STATUS_UNSPECIFIED: XAccountDeploy.Status
    aws: AwsXAccountDeployParams
    cloud_provider: str
    created_at: int
    id: int
    project_id: int
    region: str
    region_display_name: str
    status: XAccountDeploy.Status
    def __init__(self, id: _Optional[int] = ..., project_id: _Optional[int] = ..., created_at: _Optional[int] = ..., cloud_provider: _Optional[str] = ..., region: _Optional[str] = ..., region_display_name: _Optional[str] = ..., status: _Optional[_Union[XAccountDeploy.Status, str]] = ..., aws: _Optional[_Union[AwsXAccountDeployParams, _Mapping]] = ...) -> None: ...

class XAccountDeployFilter(_message.Message):
    __slots__ = ["project_ids"]
    PROJECT_IDS_FIELD_NUMBER: _ClassVar[int]
    project_ids: _containers.RepeatedScalarFieldContainer[int]
    def __init__(self, project_ids: _Optional[_Iterable[int]] = ...) -> None: ...

class DeployType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class ComponentType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class SKUType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class ProfileStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class ClusterConnectionType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class ClusterStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class UserClusterStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class UserClusterSubStatus(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class DevTierClusterType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class AvailableFeature(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []

class ClusterJobType(int, metaclass=_enum_type_wrapper.EnumTypeWrapper):
    __slots__ = []
