Enum StorageSyncMode 

pub enum StorageSyncMode {
    Auto,
    Syncfs,
    PerFile,
}

How a pipeline makes its files durable when it commits a checkpoint.

A checkpoint can hold tens of thousands of files, so committing them one at a time is the dominant cost of making one. Both alternatives below fix that, but they suit different deployments.

Variants

Auto

Use syncfs when storage has a filesystem to itself, and fsync files in parallel otherwise.

Syncfs

Always syncfs.

One syscall makes the whole filesystem durable, which is the cheapest option by far when storage is a dedicated volume. On a filesystem shared with anything else, it also writes back that other data.

A pipeline falls back to per_file where syncfs cannot report a failed writeback, rather than honoring this setting: off Linux, and before Linux 5.8, where syncfs returned success and discarded the error.

PerFile

Always fsync each file, spread across several threads.

Slower than syncfs on a dedicated volume, but it touches only this pipeline’s files.

Trait Implementations

impl Clone for StorageSyncMode

fn clone(&self) -> StorageSyncMode

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StorageSyncMode

impl Debug for StorageSyncMode

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

Formats the value using the given formatter.

impl Default for StorageSyncMode

fn default() -> StorageSyncMode

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StorageSyncMode

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for StorageSyncMode

impl PartialEq for StorageSyncMode

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for StorageSyncMode

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 StorageSyncMode

impl<'__s> ToSchema<'__s> for StorageSyncMode

fn schema() -> (&'__s str, RefOr<Schema>)

Return a tuple of name and schema or reference to a schema that can be referenced by the name or inlined directly to responses, request bodies or parameters.

fn aliases() -> Vec<(&'__s str, Schema)>

Optional set of alias schemas for the ToSchema::schema.