Struct SyncConfig 

pub struct SyncConfig {
    pub direction: SyncDirection,
    pub conflict_resolution: ConflictResolution,
    pub batch_size: usize,
    pub push_interval_ms: u64,
    pub pull_interval_ms: u64,
    pub retry: RetryConfig,
    pub collectives: Option<Vec<CollectiveId>>,
    pub sync_relations: bool,
    pub sync_insights: bool,
}

Available on crate feature sync only.

Configuration for the sync protocol.

Controls direction, conflict resolution, batch sizes, polling intervals, and which collectives to sync.

Example

use pulsedb::sync::config::{SyncConfig, SyncDirection};

let config = SyncConfig {
    direction: SyncDirection::PushOnly,
    batch_size: 200,
    ..Default::default()
};
assert!(config.validate().is_ok());

Fields

direction: SyncDirection

Direction of sync data flow.

conflict_resolution: ConflictResolution

Strategy for resolving conflicts.

batch_size: usize

Maximum number of changes per sync batch.

Larger batches reduce round trips but increase memory usage. Default: 500

push_interval_ms: u64

Interval between push cycles in milliseconds.

Default: 1000 (1 second)

pull_interval_ms: u64

Interval between pull cycles in milliseconds.

Default: 1000 (1 second)

retry: RetryConfig

Retry configuration for transient failures.

collectives: Option<Vec<CollectiveId>>

Optional filter: only sync these collectives.

None means sync all collectives.

sync_relations: bool

Whether to sync experience relations.

Default: true

sync_insights: bool

Whether to sync derived insights.

Default: true

Implementations

impl SyncConfig

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

Validates the sync configuration.

Errors

Returns ValidationError if:

• batch_size is 0
• push_interval_ms is 0
• pull_interval_ms is 0

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 Default for SyncConfig

fn default() -> Self

Returns the “default value” for a type.

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.