Module Sync.Common

Parameters

module G : sig ... end

Signature

module Store = G
type command = [
| `Create of Store.Hash.t * Store.Reference.t
| `Delete of Store.Hash.t * Store.Reference.t
| `Update of Store.Hash.t * Store.Hash.t * Store.Reference.t
]
val pp_command : command Fmt.t
val pp_fetch_one : [ `AlreadySync | `Sync of Store.Hash.t Store.Reference.Map.t ] Fmt.t
val pp_update_and_create : (Store.Reference.t, Store.Reference.t * string) Stdlib.result list Fmt.t
val packer : ?⁠window:[ `Object of int | `Memory of int ] -> ?⁠depth:int -> Store.t -> ofs_delta:bool -> (Store.Hash.t * Store.Reference.t * bool) list -> command list -> (Store.Pack.stream * (Checkseum.Crc32.t * int64) Store.Hash.Map.t Lwt_mvar.t, Store.error) Stdlib.result Lwt.t
val want_handler : Store.t -> (Store.Reference.t -> bool Lwt.t) -> (Store.Hash.t * Store.Reference.t * bool) list -> (Store.Reference.t * Store.Hash.t) list Lwt.t
val update_and_create : Store.t -> references:Store.Reference.t list Store.Reference.Map.t -> (Store.Reference.t * Store.Hash.t) list -> (Store.Hash.t Store.Reference.Map.t * Store.Reference.t list Store.Reference.Map.t * Store.Hash.t Store.Reference.Map.t, Store.error) Stdlib.result Lwt.t
val push_handler : Store.t -> Store.Reference.t list Store.Reference.Map.t -> (Store.Hash.t * Store.Reference.t * bool) list -> command list Lwt.t