Skip to main content

Kubernetes manifests for Operators

Project description

ops-lib-manifests

Rationale for this library

Most kubernetes projects deploy with manifest files which promote suggested deployment parameters, but those manifests aren't consistent about which options are requirements and which options are variable. In some cases the project's distribution uses different means of indicating a need for replacement.

For example, the following reference from vsphere-cloud-controller-manager gives the consumer of this yaml an indication there should be usernames and passwords set in the Secret object.

apiVersion: v1
kind: Secret
metadata:
  name: vsphere-cloud-secret
  labels:
    vsphere-cpi-infra: secret
    component: cloud-controller-manager
  namespace: kube-system
  # NOTE: this is just an example configuration, update with real values based on your environment
stringData:
  10.0.0.1.username: "<ENTER_YOUR_VCENTER_USERNAME>"
  10.0.0.1.password: "<ENTER_YOUR_VCENTER_PASSWORD>"
  1.2.3.4.username: "<ENTER_YOUR_VCENTER_USERNAME>"
  1.2.3.4.password: "<ENTER_YOUR_VCENTER_PASSWORD>"

Automation tools like a juju charm will need to read these yaml manifest files, manipulate its content, and deploy those manifests when any of the configurable data is changed.

Supporting Multiple Releases

Likewise, the projects which release reference manifest files, will also release versions of manifests. It's possible for a charm to load all the supported manifest files into a folder structure such the charm supports multiple releases. This library supports this requirements by having the charm store upstream manifest files unchanged in a folder structure like this:

<base_path>
├── version                  - a file containing the default version
├── manifests                - a folder containing all the releases
│   ├── v1.1.10              - a folder matching a configurable version
│   │   ├── manifest-1.yaml  - any file with a `.yaml` file type
│   │   └── manifest-2.yaml
│   ├── v1.1.11
│   │   ├── manifest-1.yaml
│   │   └── manifest-2.yaml
│   │   └── manifest-3.yaml

Key file-heirarchy requirements

$base_path A single charm can support multiple manifest releases
version A text file indicating to the library which manifest version is the default when the 'release' config is unspecified
manifests A folder containing the individual release manifest folders
$release A folder containing the yaml files of the specific release

Sample Usage

Once your charm includes the above manifest file hierarchy, your charm will need to define the mutations the library should make to the manifests.

from ops.manifests import Collector, Manifests, ManifestLabel, ConfigRegistry

class ExampleApp(Manifests):
    def __init__(self, charm, charm_config):
        manipulations = [
            ManifestLabel(self),
            ConfigRegistry(self),
            UpdateSecret(self),
        ]
        super().__init__("example", charm.model, "upstream/example", manipulations)
        self.charm_config = charm_config

    @property
    def config(self) -> Dict:
        """Returns config mapped from charm config and joined relations."""
        config = dict(**self.charm_config)

        for key, value in dict(**config).items():
            if value == "" or value is None:
                del config[key]  # blank out keys not currently set to something

        config["release"] = config.pop("example-release", None)
        return config

    def is_ready(self, obj, condition) -> bool:
        """Filter conditions by object and condition."""
        if (
            obj.kind == "Deployment" and
            obj.name == "MyDeployment" and
            condition.type == "Ignored"
        ):
            return None  # ignore this condition
        return super().is_ready(obj, condition)


class ExampleCharm(CharmBase):
    def __init__(self, *args):
        super().__init__(*args)

        # collection of ManifestImpls
        self.collector = Collector(ExampleApp(self, self.config))

        # Register actions callbacks
        self.framework.observe(self.on.list_versions_action, self._list_versions)
        
        # Register update status callbacks
        self.framework.observe(self.on.update_status, self._update_status)
    
    def _list_versions(self, event):
        self.collector.list_versions(event)

    def _update_status(self, _):
        unready = self.collector.unready
        if unready:
            self.unit.status = WaitingStatus(", ".join(unready))
        else:
            self.unit.status = ActiveStatus("Ready")
            self.unit.set_workload_version(self.collector.short_version)
            self.app.status = ActiveStatus(self.collector.long_version)
        

Manifests

This class provides the following functions:

  1. Integration with lightkube to create/read/update/delete resources into the cluster
  2. Provides a means to select a manifest release
  3. Loads manifest files from a known file hierarchy specific to a release
  4. Manipulates resource objects of a specific release
  5. Provides comparisons between the installed resources and expected resources
  6. Provides user listing of available releases

Creating a Manifest Impl

It's expected that the developer create a Manifest impl -- a derived class -- that implements one property -- config. This property provides some basic requirements to the Manifest parent class and gives context for each custom Manipulation to act on relation or config data.

    @property
    def config(self) -> Dict:
        """Returns config mapped from charm config and joined relations."""

Expected config key mappings

  • release
    • optional str which identifies which release of the manifest to choose.
    • defaults to None which will select the default_release if available.
    • if default_release isn't found, the latest release is chosen.
  • image-registry
    • optional str which will be used by the ConfigRegistry manipulation
    • defaults to None which uses the resources built-in registry location
    • if specified, will replace the text up to the first / with its contents

Cluster CRUD methods

  • status()
    • queries all in cluster resources associated with the current release which has a .status.conditions attribute.
  • installed_resources()
    • queries all in cluster resources associated with the current release which is installed.
  • labelled_resources()
    • queries all in cluster resources associated with the charm and manifest in general which is installed.
    • this can be compared with the resources property to look for extra resources installed which are no longer necessary.
  • apply_manifests()
    • applies all resources from the current release into the cluster.
    • resources are force applied, overwriting existing resources.
  • apply_resources(*resources) and apply_resource(...)
    • applies itemized resources into the cluster.
    • resources are force applied, overwriting existing resources.
  • delete_manifests(...)
    • will delete all current release resources from the cluster
    • see delete_resources for keyword arguments
  • delete_resources(...)
    • delete a specified set of resources from the cluster with options to seamlessly handle certain failures.
  • delete_resource(...)
    • alias to delete_resources for when reading clarity demands only deleting one resource.

Collector

This class provides a native collection for operating collectively on the manifests within a single charm. It provides methods for responding to

  • action list-versions
  • action scrub-resources
  • action list-resources
  • action apply-missing-resources
  • querying the collective versions (short and long types)
  • listing which resources have a non-active status

To integrate into an ops charm, for each released application the charm manages, create a new Manifests impl, and add an instance of it to a Collector.

class AlternateApp(Manifests):
    def __init__(self, charm, charm_config):
        super().__init__("alternate", charm.model, "upstream/example")
        self.charm_config = charm_config


    @property
    def config(self) -> Dict:
        """Returns config mapped from charm config and joined relations."""
        config = dict(**self.charm_config)

        for key, value in dict(**config).items():
            if value == "" or value is None:
                del config[key]  # blank out keys not currently set to something

        config["release"] = config.pop("alternate-release", None)
        return config


class ExampleCharm(CharmBase):
    def __init__(self, *args):
        ...
        # collection of ManifestImpls
        self.collector = Collector(
            ExampleApp(self, self.config), 
            AlternateApp(self, self.config),
        )

Manipulations

Patching a manifest resource

Some resources already exist within the manifest, and just need to be updated.

Built in Patchers

  • ManifestLabel

    • adds to each resource's metadata.labels the following:
      1. juju.io/application: manifests.app_name
      2. juju.io/manifest: manifests.name
      3. juju.io/manifest-version: <manifests.name>-<version>
  • ConfigRegistry

    • updates the image registry of every Pod, DaemonSet, Deployment, and StatefulSet from the image-registry config item in the config properties Dict.
    • If the charm doesn't wish to alter the config, ensure nothing exists in the image-registry.
  • update_toleration

    • not officially a patcher, but can be used by a custom Patcher to adjust tolerations on Pod, DaemonSet, Deployment, and StatefulSet resources.

Adding a manifest resource

Some resources do not exist in the release manifest and must be added. The Addition manipulations are added before the rest of the Patch manipulations are applied.

Built in Adders

  • CreateNamespace - Creates a namespace resource using either the manifest's default namespace or an argument passed in to the constructor of this class.

Subtracting a manifest resource

Some manifest resources are not needed and must be removed. The Subtraction manipulations are added before the rest of the Patch manipulations are applied.

Built in Subtractors

  • SubtractEq - Subtracts a manifest resource equal to the resource passed in as an argument. Resources are considered equal if they have the same kind, name, and namespace.

Custom Manipulations

Of course the built-ins will not be enough, so your charm may extend its own manipulations by defining new objects which inherit from either Patch or Addition.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

ops_manifest-1.6.0.tar.gz (21.6 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

ops.manifest-1.6.0-py3-none-any.whl (20.4 kB view details)

Uploaded Python 3

File details

Details for the file ops_manifest-1.6.0.tar.gz.

File metadata

  • Download URL: ops_manifest-1.6.0.tar.gz
  • Upload date:
  • Size: 21.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.10.15

File hashes

Hashes for ops_manifest-1.6.0.tar.gz
Algorithm Hash digest
SHA256 ceb6ac9b4cf175eb526a0b1d09992a964d1080eb3b14b4bfbb1e1339cfc26f19
MD5 403cfe9a29a78025a8b2583275c9c80b
BLAKE2b-256 95ea13b63f315844d7f53ec91b875d23a65bffbd4393a893738ab87a1ad036a6

See more details on using hashes here.

File details

Details for the file ops.manifest-1.6.0-py3-none-any.whl.

File metadata

  • Download URL: ops.manifest-1.6.0-py3-none-any.whl
  • Upload date:
  • Size: 20.4 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.10.15

File hashes

Hashes for ops.manifest-1.6.0-py3-none-any.whl
Algorithm Hash digest
SHA256 3ad002cef5d4d1ebc90a911fcfedb4b65e770bf3db71a0978fa2b96f80feac35
MD5 223d80c7e4c07a010596ebb6b1e91377
BLAKE2b-256 3b1e0b1b48eb26f990c295179d4a9cc77dc1ec8dd661900be81f68f7e78bb83b

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page