Operation_worker (p.octez-protocol-020-PsParisC-libs.20.1.doc.octez-protocol-020-PsParisC-libs.baking.Tezos_baking_020_PsParisC.Operation

Datatypes

Sourcetype t

Sourcetype candidate = {

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

}

Sourceval candidate_encoding : candidate Tezos_base.TzPervasives.Data_encoding.t

Sourcetype event =

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

Constructors

Source

val create : 
  ?monitor_node_operations:bool ->
  Tezos_client_020_PsParisC.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_020_PsParisC.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_020_PsParisC.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_020_PsParisC.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