Module `Tezos_baking_019_PtParisB.Operation_worker`Source

Launch processes to gather operations from the mempool and make them available for the baker.

Datatypes

Sourcetype t

Sourcetype candidate = {

hash : Tezos_base.TzPervasives.Block_hash.t;
round_watched : Tezos_protocol_019_PtParisB.Protocol.Alpha_context.Round.t;
payload_hash_watched : Tezos_protocol_019_PtParisB.Protocol.Block_payload_hash.t;

}

Sourceval candidate_encoding : candidate Tezos_base.TzPervasives.Data_encoding.t

Sourcetype event =

| Prequorum_reached of candidate * Tezos_protocol_019_PtParisB.Protocol.Alpha_context.Kind.preattestation Tezos_protocol_019_PtParisB.Protocol.Alpha_context.operation list
| Quorum_reached of candidate * Tezos_protocol_019_PtParisB.Protocol.Alpha_context.Kind.attestation Tezos_protocol_019_PtParisB.Protocol.Alpha_context.operation list

Constructors

Source

val create : 
  ?monitor_node_operations:bool ->
  Tezos_client_019_PtParisB.Protocol_client_context.full ->
  t Lwt.t

create ?monitor_node_operations cctxt creates a monitoring process to fetch operations for the baker to process.

parameter monitor_node_operations
monitor operations on the node (defaults: true). Set monitor_node_operations to false to only consider externally provided (non-node) operations.

Utilities

Source

val retrieve_pending_operations : 
  Tezos_client_019_PtParisB.Protocol_client_context.full ->
  t ->
  unit Tezos_base.TzPervasives.tzresult Lwt.t

Accessors

Sourceval get_current_operations : t -> Operation_pool.pool

Sourceval get_quorum_event_stream : t -> event Lwt_stream.t

Observers

Source

val monitor_preattestation_quorum : 
  t ->
  consensus_threshold:int ->
  get_slot_voting_power:
    (slot:Tezos_protocol_019_PtParisB.Protocol.Alpha_context.Slot.t ->
      int option) ->
  candidate ->
  unit Lwt.t

Source

val monitor_attestation_quorum : 
  t ->
  consensus_threshold:int ->
  get_slot_voting_power:
    (slot:Tezos_protocol_019_PtParisB.Protocol.Alpha_context.Slot.t ->
      int option) ->
  candidate ->
  unit Lwt.t

Sourceval cancel_monitoring : t -> unit

Sourceval shutdown_worker : t -> (unit, exn list) result Lwt.t

Install

Dune Dependency

Authors

Maintainers

Sources

doc/octez-protocol-019-PtParisB-libs.baking/Tezos_baking_019_PtParisB/Operation_worker/index.html

Module `Tezos_baking_019_PtParisB.Operation_worker`Source

Datatypes

Constructors

Utilities

Accessors

Observers

package octez-protocol-019-PtParisB-libs

Install

Dune Dependency

Authors

Maintainers

Sources

doc/octez-protocol-019-PtParisB-libs.baking/Tezos_baking_019_PtParisB/Operation_worker/index.html

Module Tezos_baking_019_PtParisB.Operation_workerSource

Datatypes

Constructors

Utilities

Accessors

Observers

Module `Tezos_baking_019_PtParisB.Operation_worker`Source