crate.operator.backup module

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

Bases: StateBasedSubHandler

Parameters:

• namespace (str)

• name (str)

• ref (str)

• context (dict)

• operation (Optional[OperationType])

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_aws_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_aws_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_aws_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_azure_backup_cronjob(owner_references, name, labels, http_port, backup_azure, image_pull_secrets, has_ssl)

Parameters:

• owner_references (Optional[List[V1OwnerReference]])

• name (str)

• labels (Dict[str, str])

• http_port (int)

• backup_azure (Dict[str, Any])

• image_pull_secrets (Optional[List[V1LocalObjectReference]])

• has_ssl (bool)

Return type:

V1CronJob

crate.operator.backup.get_azure_backup_env(name, http_port, backup_azure, has_ssl)

Parameters:

• name (str)

• http_port (int)

• backup_azure (Dict[str, Any])

• has_ssl (bool)

Return type:

List[V1EnvVar]

crate.operator.backup.get_azure_backup_metrics_exporter(owner_references, name, labels, http_port, prometheus_port, backup_azure, image_pull_secrets, has_ssl)

Parameters:

• owner_references (Optional[List[V1OwnerReference]])

• name (str)

• labels (Dict[str, str])

• http_port (int)

• prometheus_port (int)

• backup_azure (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)