Struct garage_rpc::layout::LayoutHistory

pub struct LayoutHistory {
    pub versions: Vec<LayoutVersion>,
    pub old_versions: Vec<LayoutVersion>,
    pub update_trackers: UpdateTrackers,
    pub staging: Lww<LayoutStaging>,
}

The history of cluster layouts, with trackers to keep a record of which nodes are up-to-date to current cluster data

Fields

versions: Vec<LayoutVersion>

The versions currently in use in the cluster

old_versions: Vec<LayoutVersion>

At most 5 of the previous versions, not used by the garage_table module, but usefull for the garage_block module to find data blocks that have not yet been moved

update_trackers: UpdateTrackers

Update trackers

staging: Lww<LayoutStaging>

Staged changes for the next version

Implementations

impl LayoutHistory

pub fn new(replication_factor: ReplicationFactor) -> Self

pub fn current(&self) -> &LayoutVersion

Returns the layout version with the highest number

pub fn min_stored(&self) -> u64

Returns the version number of the oldest layout version still active

pub fn get_all_nodes(&self) -> Vec<Uuid>

Calculate the set of all nodes that have a role (gateway or storage) in one of the currently active layout versions

pub fn merge(&mut self, other: &LayoutHistory) -> bool

pub fn apply_staged_changes( self, version: Option<u64> ) -> Result<(Self, Message), Error>

pub fn revert_staged_changes(self) -> Result<Self, Error>

pub fn check(&self) -> Result<(), String>

Trait Implementations

impl Clone for LayoutHistory

fn clone(&self) -> LayoutHistory

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for LayoutHistory

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LayoutHistory

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Migrate for LayoutHistory

const VERSION_MARKER: &'static [u8] = b"G010lh"

A sequence of bytes to add at the beginning of the serialized string, to identify that the data is of this version.

type Previous = ClusterLayout

The previous version of this data type, from which items of this version can be migrated.

fn migrate(previous: Self::Previous) -> Self

The migration function that transforms a value decoded in the old format to an up-to-date value.

fn decode(bytes: &[u8]) -> Option<Self>

Decode an encoded version of this type, going through a migration if necessary.

fn encode(&self) -> Result<Vec<u8>, Error>

Encode this type with optional version marker

impl PartialEq for LayoutHistory

fn eq(&self, other: &LayoutHistory) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for LayoutHistory

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for LayoutHistory