gleamunison - v3.23.0

gleamunison/sync

Values

accept_chunk

</> 
pub fn accept_chunk(
  peer: sync_types.PeerId,
  codebase: codebase.Codebase,
  ref: identity.DefinitionRef,
  bytes: BitArray,
) -> Result(codebase.Codebase, sync_types.SyncError)

Verify the content binding even on the first write. Existing refs remain byte-identical and storage errors are failures, never a missing value. Legacy inspect-rendered definitions cannot be verified and fail closed.

connect

</> 
pub fn connect(
  peer: sync_types.PeerId,
) -> Result(Nil, sync_types.SyncError)

Open a connection to a peer. Stays open for subsequent fetch_refs batches — the selective-pull primitive’s session handle.

fetch_refs

</> 
pub fn fetch_refs(
  peer: sync_types.PeerId,
  codebase: codebase.Codebase,
  hexes: List(String),
) -> Result(codebase.Codebase, sync_types.SyncError)

Fetch exactly the given refs from an already-connected peer: request, unsolicited-chunk validation, conflict-checked accept. Returns the codebase with the chunks applied. This is the selective transfer primitive: the caller computes the ref set (e.g. a package manifest closure) and the wire moves nothing else.

new_sync_state

</> 
pub fn new_sync_state() -> sync_types.SyncState

pull_sync

</> 
pub fn pull_sync(
  state: sync_types.SyncState,
  peer: sync_types.PeerId,
  codebase: codebase.Codebase,
) -> Result(
  #(
    sync_types.SyncState,
    codebase.Codebase,
    List(identity.DefinitionRef),
  ),
  sync_types.SyncError,
)

push_sync

</> 
pub fn push_sync(
  state: sync_types.SyncState,
  peer: sync_types.PeerId,
  refs: List(identity.DefinitionRef),
  adapter: storage.StorageAdapter,
) -> Result(#(sync_types.SyncState, Int), sync_types.SyncError)

validate_chunk_set

</> 
pub fn validate_chunk_set(
  requested: List(String),
  received: List(#(String, BitArray)),
) -> Result(Nil, sync_types.SyncError)

Every received chunk must answer a ref we actually asked for. A peer sending unsolicited chunks fails the transfer loudly.

✨ Search Document