Struct SyncConfig 

pub struct SyncConfig {
    pub agent_id: String,
    pub tenant_id: String,
    pub store_id: String,
    pub buffer_capacity: usize,
    pub batch_size: usize,
    pub outbox_capacity: usize,
    pub outbox_path: Option<String>,
}

Configuration for the sync engine.

Maps to the JS SyncConfig (agent_id, tenant_id, store_id) plus tuning knobs for buffer capacity and batch sizes.

Examples

use stateset_sync::SyncConfig;

let config = SyncConfig::new("agent-1", "tenant-1", "store-1");
assert_eq!(config.agent_id, "agent-1");
assert_eq!(config.buffer_capacity, 1000);

Fields

agent_id: String

Unique identifier for this agent.

tenant_id: String

Tenant identifier for multi-tenancy.

store_id: String

Store identifier within the tenant.

buffer_capacity: usize

Maximum number of events the in-memory buffer can hold.

batch_size: usize

Maximum events per push/pull batch.

outbox_capacity: usize

Maximum pending local events in the outbox.

outbox_path: Option<String>

Optional durable outbox snapshot path.

Implementations

impl SyncConfig

pub fn new( agent_id: impl Into<String>, tenant_id: impl Into<String>, store_id: impl Into<String>, ) -> Self

Create a new SyncConfig with sensible defaults.

pub const fn with_buffer_capacity(self, capacity: usize) -> Self

Set the buffer capacity.

pub const fn with_batch_size(self, batch_size: usize) -> Self

Set the batch size.

pub const fn with_outbox_capacity(self, capacity: usize) -> Self

Set the outbox capacity.

pub fn with_outbox_path(self, path: impl Into<String>) -> Self

Set the durable outbox path.

pub fn resolved_buffer_capacity(&self) -> usize

Resolve a valid buffer capacity.

pub fn resolved_batch_size(&self) -> usize

Resolve a valid batch size.

pub fn resolved_outbox_capacity(&self) -> usize

Resolve a valid outbox capacity.

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

Validate the configuration.

Errors

Returns crate::SyncError::InvalidConfig when required fields are invalid.

Trait Implementations

impl Clone for SyncConfig

fn clone(&self) -> SyncConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SyncConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SyncConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SyncConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.