crate.operator.backup module

class crate.operator.backup.CreateBackupsSubHandler(namespace, name, ref, context, depends_on=None, run_on_dep_failures=False)

Bases: StateBasedSubHandler

Parameters

• namespace (str) –

• name (str) –

• ref (str) –

• context (dict) –

async handle(namespace, name, owner_references, backup_metrics_labels, http_port, prometheus_port, backups, image_pull_secrets, has_ssl, logger, **kwargs)

Parameters

• namespace (str) –

• name (str) –

• owner_references (Optional[List[V1OwnerReference]]) –

• backup_metrics_labels (Dict[str, str]) –

• http_port (int) –

• prometheus_port (int) –

• backups (Dict[str, Any]) –

• image_pull_secrets (Optional[List[V1LocalObjectReference]]) –

• has_ssl (bool) –

• logger (Logger) –

• kwargs (Any) –

async crate.operator.backup.create_backups(owner_references, namespace, name, labels, http_port, prometheus_port, backups, image_pull_secrets, has_ssl, logger)

Parameters

• owner_references (Optional[List[V1OwnerReference]]) –

• namespace (str) –

• name (str) –

• labels (Dict[str, str]) –

• http_port (int) –

• prometheus_port (int) –

• backups (Dict[str, Any]) –

• image_pull_secrets (Optional[List[V1LocalObjectReference]]) –

• has_ssl (bool) –

• logger (Logger) –

Return type

None

crate.operator.backup.get_backup_cronjob(owner_references, name, labels, http_port, backup_aws, image_pull_secrets, has_ssl)

Parameters

• owner_references (Optional[List[V1OwnerReference]]) –

• name (str) –

• labels (Dict[str, str]) –

• http_port (int) –

• backup_aws (Dict[str, Any]) –

• image_pull_secrets (Optional[List[V1LocalObjectReference]]) –

• has_ssl (bool) –

Return type

V1CronJob

crate.operator.backup.get_backup_env(name, http_port, backup_aws, has_ssl)

Parameters

• name (str) –

• http_port (int) –

• backup_aws (Dict[str, Any]) –

• has_ssl (bool) –

Return type

List[V1EnvVar]

crate.operator.backup.get_backup_metrics_exporter(owner_references, name, labels, http_port, prometheus_port, backup_aws, image_pull_secrets, has_ssl)

Parameters

• owner_references (Optional[List[V1OwnerReference]]) –

• name (str) –

• labels (Dict[str, str]) –

• http_port (int) –

• prometheus_port (int) –

• backup_aws (Dict[str, Any]) –

• image_pull_secrets (Optional[List[V1LocalObjectReference]]) –

• has_ssl (bool) –

Return type

V1Deployment

crate.operator.backup.get_webhook_env()

async crate.operator.backup.update_backup_schedule_in_cronjob(namespace, name, new_value)