CCE API¶
The Cloud Container Engine Class¶
The cce high-level interface is available through the cce
member of a
Connection
object. The cce
member will only
be added if the otcextensions.sdk.register_otc_extensions(conn)
method is
called.
Cluster Operations¶
- class otcextensions.sdk.cce.v3._proxy.Proxy(session: session.Session, *, service_type: str | None = None, service_name: str | None = None, interface: str | None = None, region_name: str | None = None, endpoint_override: str | None = None, version: str | None = None, auth: plugin.BaseAuthPlugin | None = None, user_agent: str | None = None, connect_retries: int | None = None, logger: logging.Logger | None = None, allow: dict[str, ty.Any] | None = None, additional_headers: collections.abc.MutableMapping[str, str] | None = None, client_name: str | None = None, client_version: str | None = None, allow_version_hack: bool | None = None, global_request_id: str | None = None, min_version: str | None = None, max_version: str | None = None, default_microversion: str | None = None, status_code_retries: int | None = None, retriable_status_codes: list[int] | None = None, raise_exc: bool | None = None, rate_limit: float | None = None, concurrency: int | None = None, connect_retry_delay: float | None = None, status_code_retry_delay: float | None = None, statsd_client: statsd_client.StatsClient | None = None, statsd_prefix: str | None = None, prometheus_counter: prometheus_client.Counter | None = None, prometheus_histogram: prometheus_client.Histogram | None = None, influxdb_config: dict[str, ty.Any] | None = None, influxdb_client: influxdb_client.InfluxDBClient | None = None)¶
-
- get_cluster(cluster)¶
Get the cluster by UUID.
- find_cluster(name_or_id, ignore_missing=True)¶
Find a single cluster.
- Parameters:
name_or_id – The name or ID of a cluster
ignore_missing (bool) – When set to
False
ResourceNotFound
will be raised when the group does not exist. When set toTrue
, no exception will be set when attempting to delete a nonexistent group.
- Returns:
None
- delete_cluster(cluster, ignore_missing=True)¶
Delete a cluster.
- Parameters:
cluster – The value can be the ID of a cluster or a
Cluster
instance.ignore_missing (bool) – When set to
False
ResourceNotFound
will be raised when the group does not exist. When set toTrue
, no exception will be set when attempting to delete a nonexistent cluster.
Cluster Nodes Operations¶
- class otcextensions.sdk.cce.v3._proxy.Proxy(session: session.Session, *, service_type: str | None = None, service_name: str | None = None, interface: str | None = None, region_name: str | None = None, endpoint_override: str | None = None, version: str | None = None, auth: plugin.BaseAuthPlugin | None = None, user_agent: str | None = None, connect_retries: int | None = None, logger: logging.Logger | None = None, allow: dict[str, ty.Any] | None = None, additional_headers: collections.abc.MutableMapping[str, str] | None = None, client_name: str | None = None, client_version: str | None = None, allow_version_hack: bool | None = None, global_request_id: str | None = None, min_version: str | None = None, max_version: str | None = None, default_microversion: str | None = None, status_code_retries: int | None = None, retriable_status_codes: list[int] | None = None, raise_exc: bool | None = None, rate_limit: float | None = None, concurrency: int | None = None, connect_retry_delay: float | None = None, status_code_retry_delay: float | None = None, statsd_client: statsd_client.StatsClient | None = None, statsd_prefix: str | None = None, prometheus_counter: prometheus_client.Counter | None = None, prometheus_histogram: prometheus_client.Histogram | None = None, influxdb_config: dict[str, ty.Any] | None = None, influxdb_client: influxdb_client.InfluxDBClient | None = None)
- cluster_nodes(cluster)
List all Cluster nodes.
- Parameters:
cluster – The value can be the ID of a cluster or a
Cluster
instance.- Returns:
a generator of (
ClusterNode
) instances
- get_cluster_node(cluster, node_id)
Get the cluster node by it’s UUID.
- Parameters:
cluster – key id or an instance of
Cluster
node_id – Cluster node id to be fetched
- Returns:
instance of
ClusterNode
- find_cluster_node(cluster, node)
Find the cluster node by it’s UUID or name.
- Parameters:
cluster – key id or an instance of
Cluster
node – Cluster node id or name to be fetched
- Returns:
instance of
ClusterNode
- delete_cluster_node(cluster, node, ignore_missing=True)
Delete nodes from the cluster.
- Parameters:
cluster – The value can be the ID of a cluster or a
Cluster
instance.node – The value can be the ID of a cluster node or a
ClusterNode
instance.ignore_missing (bool) – When set to
False
ResourceNotFound
will be raised when the node does not exist. When set toTrue
, no exception will be set when attempting to delete a nonexistent cluster node.
- create_cluster_node(cluster, **attrs)
Add a new node to the cluster.
- Parameters:
cluster – The value can be the ID of a cluster or a
Cluster
instance.attrs (dict) – Keyword arguments which will be used to create a
ClusterNode
, comprised of the properties on the ClusterNode class.
- Returns:
The results of config creation
- Return type:
Node Pool Operations¶
- class otcextensions.sdk.cce.v3._proxy.Proxy(session: session.Session, *, service_type: str | None = None, service_name: str | None = None, interface: str | None = None, region_name: str | None = None, endpoint_override: str | None = None, version: str | None = None, auth: plugin.BaseAuthPlugin | None = None, user_agent: str | None = None, connect_retries: int | None = None, logger: logging.Logger | None = None, allow: dict[str, ty.Any] | None = None, additional_headers: collections.abc.MutableMapping[str, str] | None = None, client_name: str | None = None, client_version: str | None = None, allow_version_hack: bool | None = None, global_request_id: str | None = None, min_version: str | None = None, max_version: str | None = None, default_microversion: str | None = None, status_code_retries: int | None = None, retriable_status_codes: list[int] | None = None, raise_exc: bool | None = None, rate_limit: float | None = None, concurrency: int | None = None, connect_retry_delay: float | None = None, status_code_retry_delay: float | None = None, statsd_client: statsd_client.StatsClient | None = None, statsd_prefix: str | None = None, prometheus_counter: prometheus_client.Counter | None = None, prometheus_histogram: prometheus_client.Histogram | None = None, influxdb_config: dict[str, ty.Any] | None = None, influxdb_client: influxdb_client.InfluxDBClient | None = None)
- node_pools(cluster)
List all CCE node pools.
- get_node_pool(cluster, node_pool_id)
Get the CCE node pool by it’s UUID.
- find_node_pool(cluster, node_pool)
Find the cluster node by it’s UUID or name.
- delete_node_pool(cluster, node_pool, ignore_missing=True)
Delete node pool from the cluster.
- Parameters:
cluster – The value can be the ID of a cluster or a
Cluster
instance.node_pool – The value can be the ID of a CCE node pool or a
NodePool
instance.ignore_missing (bool) – When set to
False
ResourceNotFound
will be raised when the node does not exist. When set toTrue
, no exception will be set when attempting to delete a nonexistent cluster node pool.
- create_node_pool(cluster, **attrs)
Add a new node pool to the cluster.
Job Operations¶
- class otcextensions.sdk.cce.v3._proxy.Proxy(session: session.Session, *, service_type: str | None = None, service_name: str | None = None, interface: str | None = None, region_name: str | None = None, endpoint_override: str | None = None, version: str | None = None, auth: plugin.BaseAuthPlugin | None = None, user_agent: str | None = None, connect_retries: int | None = None, logger: logging.Logger | None = None, allow: dict[str, ty.Any] | None = None, additional_headers: collections.abc.MutableMapping[str, str] | None = None, client_name: str | None = None, client_version: str | None = None, allow_version_hack: bool | None = None, global_request_id: str | None = None, min_version: str | None = None, max_version: str | None = None, default_microversion: str | None = None, status_code_retries: int | None = None, retriable_status_codes: list[int] | None = None, raise_exc: bool | None = None, rate_limit: float | None = None, concurrency: int | None = None, connect_retry_delay: float | None = None, status_code_retry_delay: float | None = None, statsd_client: statsd_client.StatsClient | None = None, statsd_prefix: str | None = None, prometheus_counter: prometheus_client.Counter | None = None, prometheus_histogram: prometheus_client.Histogram | None = None, influxdb_config: dict[str, ty.Any] | None = None, influxdb_client: influxdb_client.InfluxDBClient | None = None)
- get_job(job)
Get the job by UUID.
- Parameters:
job – key id or an instance of
Job
- Returns:
instance of
Job