include Tezos_injector_015_PtLimaPt.Injector_sigs.S
with type rollup_node_state := State.t
and type tag := tagval init :
Tezos_client_015_PtLimaPt.Protocol_client_context.full ->
data_dir:string ->
State.t ->
signers:
(Tezos_protocol_015_PtLimaPt.Protocol.Alpha_context.public_key_hash
* Tezos_injector_015_PtLimaPt.Injector_sigs.injection_strategy
* tag list)
list ->
unit Tezos_base.TzPervasives.tzresult Lwt.tInitializes the injector with the rollup node state, for a list of signers, and start the workers. Each signer has its own worker with a queue of operations to inject.
val add_pending_operation :
?source:Tezos_protocol_015_PtLimaPt.Protocol.Alpha_context.public_key_hash ->
'a Tezos_protocol_015_PtLimaPt.Protocol.Alpha_context.manager_operation ->
unit Tezos_base.TzPervasives.tzresult Lwt.tAdd an operation as pending injection in the injector. If the source is not provided, the operation is queued to the worker which handles the corresponding tag.
val new_tezos_head :
Tezos_client_015_PtLimaPt.Protocol_client_context.Alpha_block_services.block_info ->
Tezos_client_015_PtLimaPt.Protocol_client_context.Alpha_block_services.block_info
Tezos_injector_015_PtLimaPt.Injector_common.reorg ->
unit Lwt.tNotify the injector of a new Tezos head. The injector marks the operations appropriately (for instance reverted operations that are part of a reorganization are put back in the pending queue). When an operation is considered as confirmed, it disappears from the injector.
val inject :
?tags:tag list ->
?strategy:Tezos_injector_015_PtLimaPt.Injector_sigs.injection_strategy ->
unit ->
unit Lwt.tTrigger an injection of the pending operations for all workers. If tags is given, only the workers which have a tag in tags inject their pending operations. If strategy is given, only workers which have this strategy inject their pending operations.
val shutdown : unit -> unit Lwt.tShutdown the injectors, waiting for the ongoing request to be processed.