Struct StorageConfig

pub struct StorageConfig {
    pub path: String,
    pub cache: StorageCacheConfig,
}

Configuration for persistent storage in a PipelineConfig.

Fields

path: String

The location where the pipeline state is stored or will be stored.

It should point to a path on the file-system of the machine/container where the pipeline will run. If that path doesn’t exist yet, or if it does not contain any checkpoints, then the pipeline creates it and starts from an initial state in which no data has yet been received. If it does exist, then the pipeline starts from the most recent checkpoint that already exists there. In either case, (further) checkpoints will be written there.

cache: StorageCacheConfig

How to cache access to storage in this pipeline.

Implementations

impl StorageConfig

pub fn path(&self) -> &Path

Trait Implementations

impl Clone for StorageConfig

fn clone(&self) -> StorageConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StorageConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StorageConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StorageConfig

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for StorageConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<'__s> ToSchema<'__s> for StorageConfig

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.

impl Eq for StorageConfig

impl StructuralPartialEq for StorageConfig