package tezos-tx-rollup-015-PtLimaPt

  1. Overview
  2. Docs

Module Tezos_tx_rollup_015_PtLimaPt.InjectorSource

Sourcetype tag =
  1. | Commitment
  2. | Submit_batch
  3. | Finalize_commitment
  4. | Remove_commitment
  5. | Rejection
  6. | Dispatch_withdrawals
include Tezos_injector_015_PtLimaPt.Injector_sigs.S with type rollup_node_state := State.t and type tag := tag
Sourceval 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.t

Initializes 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.

Sourceval 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.t

Add 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.

Notify 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.

Sourceval inject : ?tags:tag list -> ?strategy:Tezos_injector_015_PtLimaPt.Injector_sigs.injection_strategy -> unit -> unit Lwt.t

Trigger 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.

Sourceval shutdown : unit -> unit Lwt.t

Shutdown the injectors, waiting for the ongoing request to be processed.