Module materialize.checks.scenarios_backup_restore
Expand source code Browse git
# Copyright Materialize, Inc. and contributors. All rights reserved.
#
# Use of this software is governed by the Business Source License
# included in the LICENSE file at the root of this repository.
#
# As of the Change Date specified in that file, in accordance with
# the Business Source License, use of this software will be governed
# by the Apache License, Version 2.0.
from materialize.checks.actions import Action, Initialize, Manipulate, Validate
from materialize.checks.backup_actions import (
Backup,
Restore,
)
from materialize.checks.mzcompose_actions import (
KillMz,
StartMz,
)
from materialize.checks.scenarios import Scenario
class BackupAndRestoreAfterManipulate(Scenario):
"""Backup and Restore Materialize after manipulate(phase=2) has run.
Only validate() is run post-restore.
"""
def actions(self) -> list[Action]:
return [
StartMz(self),
Initialize(self),
Manipulate(self, phase=1),
Manipulate(self, phase=2),
Backup(),
KillMz(),
Restore(),
Validate(self),
]
class BackupAndRestoreBeforeManipulate(Scenario):
"""Backup and Restore Materialize before manipulate(phase=2) has run."""
def actions(self) -> list[Action]:
return [
StartMz(self),
Initialize(self),
Manipulate(self, phase=1),
Backup(),
KillMz(),
Restore(),
Manipulate(self, phase=2),
Validate(self),
]
class BackupAndRestoreToPreviousState(Scenario):
"""Backup, run more workloads, and then Restore to a previous state."""
def requires_external_idempotence(self) -> bool:
# This scenario will run manipulate(#2) twice, so only compatible
# Checks are allowed to participate
return True
def actions(self) -> list[Action]:
return [
StartMz(self),
Initialize(self),
Manipulate(self, phase=1),
Backup(),
Manipulate(self, phase=2), # Those updates will be lost here ..
KillMz(),
Restore(),
Manipulate(self, phase=2), # ... and redone here
Validate(self),
]
class BackupAndRestoreMulti(Scenario):
"""Repeated Backup and Restore operations."""
def actions(self) -> list[Action]:
return [
StartMz(self),
Initialize(self),
Backup(),
KillMz(),
Restore(),
Manipulate(self, phase=1),
Backup(),
KillMz(),
Restore(),
Manipulate(self, phase=2),
Backup(),
KillMz(),
Restore(),
Validate(self),
Backup(),
KillMz(),
Restore(),
Validate(self),
]Classes
class BackupAndRestoreAfterManipulate (checks: list[type[Check]], executor: Executor, seed: str | None = None)-
Backup and Restore Materialize after manipulate(phase=2) has run. Only validate() is run post-restore.
Expand source code Browse git
class BackupAndRestoreAfterManipulate(Scenario): """Backup and Restore Materialize after manipulate(phase=2) has run. Only validate() is run post-restore. """ def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Manipulate(self, phase=1), Manipulate(self, phase=2), Backup(), KillMz(), Restore(), Validate(self), ]Ancestors
Methods
def actions(self) ‑> list[Action]-
Expand source code Browse git
def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Manipulate(self, phase=1), Manipulate(self, phase=2), Backup(), KillMz(), Restore(), Validate(self), ]
class BackupAndRestoreBeforeManipulate (checks: list[type[Check]], executor: Executor, seed: str | None = None)-
Backup and Restore Materialize before manipulate(phase=2) has run.
Expand source code Browse git
class BackupAndRestoreBeforeManipulate(Scenario): """Backup and Restore Materialize before manipulate(phase=2) has run.""" def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Manipulate(self, phase=1), Backup(), KillMz(), Restore(), Manipulate(self, phase=2), Validate(self), ]Ancestors
Methods
def actions(self) ‑> list[Action]-
Expand source code Browse git
def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Manipulate(self, phase=1), Backup(), KillMz(), Restore(), Manipulate(self, phase=2), Validate(self), ]
class BackupAndRestoreMulti (checks: list[type[Check]], executor: Executor, seed: str | None = None)-
Repeated Backup and Restore operations.
Expand source code Browse git
class BackupAndRestoreMulti(Scenario): """Repeated Backup and Restore operations.""" def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Backup(), KillMz(), Restore(), Manipulate(self, phase=1), Backup(), KillMz(), Restore(), Manipulate(self, phase=2), Backup(), KillMz(), Restore(), Validate(self), Backup(), KillMz(), Restore(), Validate(self), ]Ancestors
Methods
def actions(self) ‑> list[Action]-
Expand source code Browse git
def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Backup(), KillMz(), Restore(), Manipulate(self, phase=1), Backup(), KillMz(), Restore(), Manipulate(self, phase=2), Backup(), KillMz(), Restore(), Validate(self), Backup(), KillMz(), Restore(), Validate(self), ]
class BackupAndRestoreToPreviousState (checks: list[type[Check]], executor: Executor, seed: str | None = None)-
Backup, run more workloads, and then Restore to a previous state.
Expand source code Browse git
class BackupAndRestoreToPreviousState(Scenario): """Backup, run more workloads, and then Restore to a previous state.""" def requires_external_idempotence(self) -> bool: # This scenario will run manipulate(#2) twice, so only compatible # Checks are allowed to participate return True def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Manipulate(self, phase=1), Backup(), Manipulate(self, phase=2), # Those updates will be lost here .. KillMz(), Restore(), Manipulate(self, phase=2), # ... and redone here Validate(self), ]Ancestors
Methods
def actions(self) ‑> list[Action]-
Expand source code Browse git
def actions(self) -> list[Action]: return [ StartMz(self), Initialize(self), Manipulate(self, phase=1), Backup(), Manipulate(self, phase=2), # Those updates will be lost here .. KillMz(), Restore(), Manipulate(self, phase=2), # ... and redone here Validate(self), ] def requires_external_idempotence(self) ‑> bool-
Expand source code Browse git
def requires_external_idempotence(self) -> bool: # This scenario will run manipulate(#2) twice, so only compatible # Checks are allowed to participate return True