crate.operator.main module

crate.operator.main.annotation_filter()

If running in parallel testing mode, filter the cratedbs to only match those that have the “testing” annotation set to the current PID.

This allows running several operators in parallel in each xdist worker.

async crate.operator.main.cluster_create(namespace, meta, spec, patch, status, logger, **_kwargs)

Handles creation of CrateDB Clusters.

Parameters

• namespace (str) –

• meta (Meta) –

• spec (Spec) –

• patch (Patch) –

• status (Status) –

• logger (Logger) –

async crate.operator.main.cluster_restore(namespace, name, diff, new, patch, status, started, logger, **_kwargs)

Handles field changes which trigger restoring data from a backup.

Parameters

• namespace (str) –

• name (str) –

• diff (Diff) –

• new (Body) –

• patch (Patch) –

• status (Status) –

• started (datetime) –

• logger (Logger) –

async crate.operator.main.cluster_update(namespace, name, patch, status, diff, started, **_kwargs)

Handles updates to the CrateDB resource.

Parameters

• namespace (str) –

• name (str) –

• patch (Patch) –

• status (Status) –

• diff (Diff) –

• started (datetime) –

async crate.operator.main.enable_cronjob_after_delay(namespace, name, spec, patch, status, logger, **_kwargs)

Parameters

• namespace (str) –

• name (str) –

• spec (Spec) –

• patch (Patch) –

• status (Status) –

• logger (Logger) –

async crate.operator.main.grand_central_create(namespace, name, old, new, logger, **_kwargs)

Handles deployments of grand central backend.

Parameters

• namespace (str) –

• name (str) –

• old (Body) –

• new (Body) –

• logger (Logger) –

async crate.operator.main.grand_central_upgrade(namespace, name, diff, logger, **_kwargs)

Handles updates to the backend image of grand central.

Parameters

• namespace (str) –

• name (str) –

• diff (Diff) –

• logger (Logger) –

async crate.operator.main.login(**kwargs)

async crate.operator.main.ping_cratedb(namespace, name, spec, patch, logger, **_kwargs)

Parameters

• namespace (str) –

• name (str) –

• spec (Spec) –

• patch (Patch) –

• logger (Logger) –

async crate.operator.main.raise_on_namespace_terminating(namespace)

Parameters

namespace (str) –

async crate.operator.main.secret_update(namespace, name, diff, logger, **_kwargs)

Handles changes to the password for a CrateDB cluster.

Parameters

• namespace (str) –

• name (str) –

• diff (Diff) –

• logger (Logger) –

async crate.operator.main.service_backup_schedule_update(namespace, name, diff, logger, **_kwargs)

Handles updates to the backup schedule for AWS s3 backups.

Parameters

• namespace (str) –

• name (str) –

• diff (Diff) –

• logger (Logger) –

async crate.operator.main.service_cidr_changes(namespace, name, diff, logger, **_kwargs)

Handles updates to the list of allowed CIDRs, and updates the relevant k8s Service.

Parameters

• namespace (str) –

• name (str) –

• diff (Diff) –

• logger (Logger) –

async crate.operator.main.service_external_ip_update(name, namespace, diff, meta, logger, **_kwargs)

Handle new IP addresses being assigned to LoadBalancer-type services.

This gets posted to the backend for further handling as a webhook (if webhooks are enabled).

Parameters

• name (str) –

• namespace (str) –

• diff (Diff) –

• meta (dict) –

• logger (Logger) –

async crate.operator.main.startup(settings, **_kwargs)

Parameters

settings (OperatorSettings) –