crate namespace

Subpackages

• crate.operator package
  • Subpackages
    • crate.operator.handlers package
      • Submodules
      • Module contents
    • crate.operator.utils package
      • Subpackages
      • Submodules
      • Module contents
  • Submodules
    • crate.operator.backup module
      • CreateBackupsSubHandler
      • create_backups()
      • get_aws_backup_cronjob()
      • get_aws_backup_env()
      • get_aws_backup_metrics_exporter()
      • get_azure_backup_cronjob()
      • get_azure_backup_env()
      • get_azure_backup_metrics_exporter()
      • get_webhook_env()
      • update_backup_schedule_in_cronjob()
    • crate.operator.bootstrap module
      • CreateUsersSubHandler
      • bootstrap_gc_admin_user()
      • bootstrap_system_user()
      • bootstrap_users()
      • create_users()
    • crate.operator.change_compute module
      • AfterChangeComputeSubHandler
      • ChangeComputeSubHandler
      • change_cluster_compute()
      • generate_body_patch()
      • generate_change_compute_payload()
      • update_cprocessor_crate_settings()
    • crate.operator.config module
      • Config
      • config
    • crate.operator.constants module
      • BackupStorageProvider
      • CloudProvider
      • Nodepool
      • OperationType
      • Port
      • SnapshotRestoreType
    • crate.operator.cratedb module
      • are_snapshots_in_progress()
      • connection_factory()
      • create_user()
      • get_cluster_admin_username()
      • get_cluster_settings()
      • get_connection()
      • get_healthiness()
      • get_number_of_nodes()
      • is_cluster_healthy()
      • reset_cluster_setting()
      • set_cluster_setting()
      • update_user()
    • crate.operator.create module
      • CreateCrateControlSubHandler
      • CreateCrateSCCSubHandler
      • CreateCrateServiceAccountSubHandler
      • CreateServicesSubHandler
      • CreateSqlExporterConfigSubHandler
      • CreateStatefulsetSubHandler
      • CreateSystemUserSubHandler
      • build_cratedb_labels()
      • create_crate_control_secret()
      • create_crate_scc()
      • create_crate_service_account()
      • create_services()
      • create_sql_exporter_config()
      • create_statefulset()
      • create_system_user()
      • get_cluster_resource_limits()
      • get_cluster_resource_requests()
      • get_crate_control_secret()
      • get_crate_control_service()
      • get_data_service()
      • get_discovery_service()
      • get_gc_user_secret()
      • get_owner_references()
      • get_sql_exporter_config()
      • get_statefulset()
      • get_statefulset_affinity()
      • get_statefulset_containers()
      • get_statefulset_crate_command()
      • get_statefulset_crate_env()
      • get_statefulset_crate_env_java_opts()
      • get_statefulset_crate_volume_mounts()
      • get_statefulset_env_crate_heap()
      • get_statefulset_init_containers()
      • get_statefulset_pvc()
      • get_statefulset_volumes()
      • get_system_user_secret()
      • get_tolerations()
      • get_topology_spread()
      • is_shared_resources_cluster()
      • recreate_services()
    • crate.operator.edge module
      • notify_service_ip()
    • crate.operator.exceptions module
      • ConfigurationError
      • SubHandlerFailedDependencyError
    • crate.operator.expand_volume module
      • ExpandVolumeSubHandler
      • expand_volume()
    • crate.operator.exposure module
      • ChangeExposureSubHandler
      • CreateTraefikResourcesSubHandler
      • create_traefik_resources()
      • delete_ingress_route_tcps()
      • delete_middleware_tcp()
      • delete_service()
      • delete_traefik_resources()
      • patch_service_exposure()
      • update_traefik_ip_restriction()
    • crate.operator.grand_central module
      • create_grand_central_backend()
      • create_grand_central_user()
      • get_grand_central_deployment()
      • get_grand_central_ingress()
      • get_grand_central_labels()
      • get_grand_central_service()
      • read_grand_central_deployment()
      • read_grand_central_ingress()
      • update_grand_central_deployment_image()
    • crate.operator.kube_auth module
      • login_via_kubernetes_asyncio()
    • crate.operator.main module
      • annotation_filter()
      • cluster_create()
      • cluster_delete()
      • cluster_restore()
      • cluster_update()
      • enable_cronjob_after_delay()
      • grand_central_create()
      • grand_central_upgrade()
      • login()
      • ping_cratedb()
      • raise_on_namespace_terminating()
      • secret_update()
      • service_backup_schedule_update()
      • service_cidr_changes()
      • service_external_ip_update()
      • startup()
    • crate.operator.operations module
      • AfterClusterUpdateSubHandler
      • BeforeClusterUpdateSubHandler
      • RestartSubHandler
      • RestoreUserJWTAuthSubHandler
      • StartClusterSubHandler
      • SuspendClusterSubHandler
      • add_sql_exporter_collectors_to_configmap()
      • are_traefik_resources_present()
      • check_all_data_nodes_gone()
      • check_all_data_nodes_present()
      • check_backup_metrics_pod_gone()
      • check_cluster_healthy()
      • delete_lb_service()
      • ensure_cronjob_reenabled()
      • get_crash_pod_name()
      • get_crash_scheme()
      • get_lb_service()
      • get_master_nodes_names()
      • get_namespace_resource()
      • get_pods_in_cluster()
      • get_pods_in_deployment()
      • get_pods_in_statefulset()
      • get_pvcs_in_namespace()
      • get_sql_exporter_collectors()
      • get_total_nodes_count()
      • is_lb_service_present()
      • is_lb_service_ready()
      • is_namespace_terminating()
      • is_service_present()
      • restart_cluster()
      • scale_backup_metrics_deployment()
      • set_cronjob_delay()
      • set_user_jwt()
      • suspend_or_start_cluster()
      • suspend_or_start_grand_central()
      • update_deployment_replicas()
      • update_statefulset_replicas()
    • crate.operator.prometheus module
      • ClusterCollector
      • ClusterMetrics
      • PrometheusClusterStatus
      • report_cluster_status()
    • crate.operator.restore_backup module
      • AfterRestoreBackupSubHandler
      • BeforeRestoreBackupSubHandler
      • ResetSnapshotSubHandler
      • RestoreAll
      • RestoreBackupSubHandler
      • RestoreDataSections
      • RestoreInternalTables
      • RestoreInternalTablesSubHandler
      • RestoreInternalUsersPasswordSubHandler
      • RestoreMetadata
      • RestorePartitions
      • RestoreTables
      • RestoreType
      • SendSuccessNotificationSubHandler
      • ValidateRestoreCompleteSubHandler
      • drop_repository()
      • ensure_no_restore_in_progress()
      • get_snapshot_tables()
      • get_source_backup_repository_data()
      • is_valid_snapshot()
      • quote_table()
      • restore_internal_tables_context()
      • shards_recovery_in_progress()
      • table_without_schema()
      • update_cratedb_admin_username_in_cratedb()
    • crate.operator.restore_backup_repository_data module
      • AwsBackupRepositoryData
      • AzureBackupRepositoryData
      • BackupRepositoryData
    • crate.operator.rollback module
      • FinalRollbackSubHandler
      • RollbackHandler
      • RollbackUpgradeSubHandler
    • crate.operator.scale module
      • ScaleSubHandler
      • check_for_deallocation()
      • check_nodes_present_or_gone()
      • deallocate_nodes()
      • get_container()
      • parse_replicas()
      • patch_command()
      • reset_allocation()
      • scale_cluster()
      • scale_cluster_patch_total_nodes()
      • update_statefulset()
    • crate.operator.sql module
      • SQLResult
      • execute_sql()
      • execute_sql_via_crate_control()
      • normalize_crash()
      • normalize_crate_control()
      • parse_crash_table()
      • run_crash_command()
    • crate.operator.update_user_password module
      • update_user_password()
    • crate.operator.upgrade module
      • AfterUpgradeSubHandler
      • BeforeUpgradeSubHandler
      • UpgradeSubHandler
      • check_reindexing_tables()
      • check_unsafe_upgrade_paths()
      • recreate_internal_tables()
      • update_statefulset()
      • upgrade_cluster()
      • upgrade_command_data_nodes()
      • upgrade_command_global_jwt_config()
      • upgrade_command_hostname_and_zone()
      • upgrade_command_jwt_auth()
    • crate.operator.webhooks module
      • WebhookAction
      • WebhookAdminUsernameChangedPayload
      • WebhookBackupScheduleUpdatePayload
      • WebhookChangeComputePayload
      • WebhookClient
      • WebhookClusterHealthPayload
      • WebhookEvent
      • WebhookFeedbackPayload
      • WebhookInfoChangedPayload
      • WebhookOperation
      • WebhookPayload
      • WebhookScaleNodePayload
      • WebhookScalePayload
      • WebhookStatus
      • WebhookSubPayload
      • WebhookTemporaryFailurePayload
      • WebhookUpgradePayload
      • should_retry()
  • Module contents