Used for exceptions that are already handled and should end up as a user error. Or, as a replacement for cherrypy.HTTPError(...) Typical

Component to be copied into the new container image.

Tuple containing the result of `handle_command()` Only write to stderr if there is an error, or in extraordinary circumstances Avoid ha

Helper class to declare options for MODULE_OPTIONS list. TODO: Replace with typing.TypedDict when in python_version >= 3.8

* Use this struct to pretty print values that should be formatted with a * binary unit prefix (IEC units). Since binary unit prefixes are to be used

General orchestrator specific error. Used for deployment, configuration or user errors. It's not intended for programming errors or orc

For APIs that need to specify a host subset

Defining an exception here is a bit problematic, cause you cannot properly catch it, if it was raised in a different mgr module.

* osd request identifier * * caller name + incarnation# + tid to unique identify this request. */

pextent: physical extent

This module contains functions that are executed in the serve() thread. Thus they don't block the CLI. Please see the `Note regarding ne

Details of service creation. Request to the orchestrator for a cluster of daemons such as MDS, RGW, iscsi gateway, nvmeof gateway, MONs,

class to set/list/get/delete a topic POST ?Action=CreateTopic&Name=<topic name>[&OpaqueData=<data>[&push-endpoint=<endpoint>&[<arg1>=<value1>...]]

Used within :class:`ceph.deployment.drive_group.DriveGroupSpec` to specify the devices used by the Drive Group. Any attributes (even non

Information about hosts. Like e.g. ``kubectl get nodes``

represents an immutable range of split string parts ranged-for loop example: for (std::string_view s : split(input)) { ... container initialization

For responding to queries about the status of a particular daemon, stateful or stateless. This is not about health or performance monito

Describe a drive group in the same form that ceph-volume understands.

Raised when an orchestrator doesn't support a specific feature.

class to set/get/delete an S3 notification PUT /<bucket>?notification GET /<bucket>?notification[=<notification>] DELETE /<bucket>?notific

>>> APIVersion(1,0) APIVersion(major=1, minor=0) >>> APIVersion._make([1,0]) APIVersion(major=1, minor=0) >>> f'{APIVersion(1,

a light-weight "range_seg_t", which only used as the key when searching in range_tree and range_size_tree

for composing data processors into a pipeline

Setting representation that allows to set a default value and a list of allowed data types. :param default_value: The name of the bucket.

This is actually a useful builder, since otherwise we end up with four uint64_ts in a row and only care about a subset at a time.

Settings to configure a (multisite) Ceph RGW .. code-block:: yaml service_type: rgw service_id: myrealm.myzone spec

Test MON caps as well as MDS caps. For usage see docstrings of class MDSCapTester. USAGE: Create object of this class at the beginning o