Tezos_bees.Worker
Implementation of workers, with an interface compatible with Octez_workers
. To parallelize efficiently, the handlers must use exclusively Eio
for their IOs and any asynchronous operation. As such, the worker can be started either with Lwt-compatible handlers or Eio handlers, and push_requests
requests are duplicated to either return an Lwt promise or an Eio promise.
module type T = sig ... end
module MakeGroup
(Name : Tezos_base.Worker_intf.NAME)
(Request : Tezos_base.Worker_intf.REQUEST) :
sig ... end
module MakeSingle
(Name : Tezos_base.Worker_intf.NAME)
(Request : Tezos_base.Worker_intf.REQUEST)
(Types : Tezos_base.Worker_intf.TYPES) :
T
with module Name = Name
and module Request = Request
and module Types = Types