Make (syncable_ledger.Syncable

Parameters

module Inputs : Inputs_intf

Signature

include S
  with type merkle_tree := Inputs.MT.t
   and type hash := Inputs.Hash.t
   and type root_hash := Inputs.Root_hash.t
   and type addr := Inputs.Addr.t
   and type merkle_path := Inputs.MT.path
   and type account := Inputs.Account.t
   and type query := Inputs.Addr.t Query.t
   and type answer := ( Inputs.Hash.t, Inputs.Account.t ) Answer.t

type 'a t

include Ppx_sexp_conv_lib.Sexpable.S1 with type 'a t := 'a t

val t_of_sexp : ( Sexplib0__.Sexp.t -> 'a ) -> Sexplib0__.Sexp.t -> 'a t

val sexp_of_t : ( 'a -> Sexplib0__.Sexp.t ) -> 'a t -> Sexplib0__.Sexp.t

type diff

type index = int

module Responder : sig ... end

val create : 
  Inputs.MT.t ->
  logger:Logger.t ->
  trust_system:Trust_system.t ->
  'a t

val answer_writer : 
  'a t ->
  (Inputs.Root_hash.t
   * Inputs.Addr.t Query.t
   * ( Inputs.Hash.t, Inputs.Account.t ) Answer.t
       Network_peer.Envelope.Incoming.t)
    Pipe_lib.Linear_pipe.Writer.t

val query_reader : 
  'a t ->
  (Inputs.Root_hash.t * Inputs.Addr.t Query.t) Pipe_lib.Linear_pipe.Reader.t

val destroy : 'a t -> unit

val new_goal : 
  'a t ->
  Inputs.Root_hash.t ->
  data:'a ->
  equal:( 'a -> 'a -> bool ) ->
  [ `Repeat | `New | `Update_data ]

val peek_valid_tree : 'a t -> Inputs.MT.t option

val valid_tree : 'a t -> (Inputs.MT.t * 'a) Async_kernel.Deferred.t

val wait_until_valid : 
  'a t ->
  Inputs.Root_hash.t ->
  [ `Ok of Inputs.MT.t
  | `Target_changed of Inputs.Root_hash.t option * Inputs.Root_hash.t ]
    Async_kernel.Deferred.t

val fetch : 
  'a t ->
  Inputs.Root_hash.t ->
  data:'a ->
  equal:( 'a -> 'a -> bool ) ->
  [ `Ok of Inputs.MT.t
  | `Target_changed of Inputs.Root_hash.t option * Inputs.Root_hash.t ]
    Async_kernel.Deferred.t

val apply_or_queue_diff : 'a t -> diff -> unit

val merkle_path_at_addr : 
  'a t ->
  Inputs.Addr.t ->
  Inputs.MT.path Core_kernel.Or_error.t

val get_account_at_addr : 
  'a t ->
  Inputs.Addr.t ->
  Inputs.Account.t Core_kernel.Or_error.t