Head_daemon (octez-rpc-process.Octez_rpc_process.Head

module Daemon : sig ... end

val init_store : 
  allow_testchains:bool ->
  readonly:bool ->
  Parameters.t ->
  Tezos_store.Store.store Tezos_base.TzPervasives.tzresult Lwt.t

val sync_store : 
  Tezos_store.Store.t option Stdlib.ref ->
  Tezos_store_shared.Store_types.Block_store_status.t Stdlib.ref ->
  Parameters.t ->
  (Tezos_base.TzPervasives.Block_hash.t * Tezos_base.Block_header.t) ->
  (Tezos_store.Store.t, Tezos_base.TzPervasives.tztrace) Stdlib.result Lwt.t

val handle_new_head : 
  Tezos_store.Store.t option Stdlib.ref ->
  Tezos_store_shared.Store_types.Block_store_status.t Stdlib.ref ->
  Parameters.t ->
  (Tezos_base.TzPervasives.Block_hash.t * Tezos_base.Block_header.t)
    Lwt_watcher.input ->
  (Tezos_base.TzPervasives.Block_hash.t * Tezos_base.Block_header.t) ->
  (unit, Tezos_base.TzPervasives.tztrace) Stdlib.result Lwt.t

val handle_new_applied_block : 
  Tezos_store.Store.t option Stdlib.ref ->
  Tezos_store_shared.Store_types.Block_store_status.t Stdlib.ref ->
  Parameters.t ->
  Directory.applied_watcher_kind Stdlib.ref ->
  (Tezos_base.TzPervasives.Block_hash.t * Tezos_base.Block_header.t) ->
  (unit, Tezos_base.TzPervasives.tztrace) Stdlib.result Lwt.t

val init : 
  Tezos_store.Store.t option Stdlib.ref ->
  Parameters.t ->
  (Tezos_base.TzPervasives.Block_hash.t * Tezos_base.Block_header.t)
    Lwt_watcher.input ->
  Directory.applied_watcher_kind Stdlib.ref ->
  (Daemon.t, Tezos_error_monad.Error_monad.tztrace) Stdlib.result Lwt.t