Struct LanceStateStoreConfig 

pub struct LanceStateStoreConfig { /* private fields */ }

Configuration for the embedded Lance StateStore.

The timeout bounds admission and observation. An admitted commit retains authority after its observer times out or is dropped. Native filesystem calls may delay the final owner’s joining cleanup beyond that timeout.

Examples

use storage_kit::state::config::{LanceStateStoreConfig, StateStoreConfig};
let config = StateStoreConfig::Lance(LanceStateStoreConfig::memory());
config.validate()?;

Implementations

impl LanceStateStoreConfig

pub fn memory() -> Self

Selects process-local memory with a 30-second observation timeout.

Examples

use storage_kit::state::config::LanceStateStoreConfig;
assert_eq!(LanceStateStoreConfig::memory().operation_timeout(),
    std::time::Duration::from_secs(30));

pub fn directory(path: impl Into<PathBuf>) -> Self

Selects a local directory. No filesystem I/O occurs until connection.

Examples

use storage_kit::state::config::LanceStateStoreConfig;
let config = LanceStateStoreConfig::directory("application-data");
config.validate()?;

pub fn with_operation_timeout( self, timeout: Duration, ) -> Result<Self, StateStoreError>

Sets the admission and observation timeout, without expiring transactions.

Errors

Rejects sub-millisecond, zero, overflowing, or unrepresentable deadlines.

Examples

use storage_kit::state::config::LanceStateStoreConfig;
let config = LanceStateStoreConfig::memory()
    .with_operation_timeout(std::time::Duration::from_secs(2))?;
assert_eq!(config.operation_timeout(), std::time::Duration::from_secs(2));

pub fn location(&self) -> &LanceStateStoreLocation

Borrows the selected storage location.

Examples

use storage_kit::state::config::{LanceStateStoreConfig, LanceStateStoreLocation};
assert_eq!(LanceStateStoreConfig::memory().location(), &LanceStateStoreLocation::Memory);

pub fn operation_timeout(&self) -> Duration

Returns the admission and observation timeout.

Examples

use storage_kit::state::config::LanceStateStoreConfig;
assert_eq!(LanceStateStoreConfig::memory().operation_timeout().as_secs(), 30);

pub fn validate(&self) -> Result<(), StateStoreError>

Checks local configuration without opening storage.

Errors

Rejects empty, NUL-containing, non-UTF-8, or URI directory paths, and zero or unrepresentable observation timeouts. External URIs are outside this embedded backend’s supported scope.

Examples

use storage_kit::state::config::LanceStateStoreConfig;
assert!(LanceStateStoreConfig::directory("").validate().is_err());
LanceStateStoreConfig::memory().validate()?;

Trait Implementations

impl Clone for LanceStateStoreConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LanceStateStoreConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for LanceStateStoreConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for LanceStateStoreConfig

impl From<LanceStateStoreConfig> for StateStoreConfig

fn from(config: LanceStateStoreConfig) -> Self

Converts to this type from the input type.

impl PartialEq for LanceStateStoreConfig

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for LanceStateStoreConfig

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 LanceStateStoreConfig