tezos-baking-012-Psithaca 14.0

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

Datatypes

type t

type candidate = {

hash : Tezos_crypto.Block_hash.t;
round_watched : Tezos_protocol_012_Psithaca.Protocol.Alpha_context.Round.t;
payload_hash_watched : Tezos_protocol_012_Psithaca.Protocol.Block_payload_hash.t;

}

val candidate_encoding : candidate Tezos_base.TzPervasives.Data_encoding.t

type voting_power = int

type event =

| Prequorum_reached of candidate * voting_power * Tezos_protocol_012_Psithaca.Protocol.Alpha_context.Kind.preendorsement Tezos_protocol_012_Psithaca.Protocol.Alpha_context.operation list
| Quorum_reached of candidate * voting_power * Tezos_protocol_012_Psithaca.Protocol.Alpha_context.Kind.endorsement Tezos_protocol_012_Psithaca.Protocol.Alpha_context.operation list

Constructors

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

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

Accessors

val get_current_operations : t -> Operation_pool.pool

val get_quorum_event_stream : t -> event Lwt_stream.t

Observers

val monitor_preendorsement_quorum : 
  t ->
  consensus_threshold:int ->
  get_preendorsement_voting_power:
    (slot:Tezos_protocol_012_Psithaca.Protocol.Alpha_context.Slot.t -> int) ->
  candidate ->
  unit Lwt.t

val monitor_endorsement_quorum : 
  t ->
  consensus_threshold:int ->
  get_endorsement_voting_power:
    (slot:Tezos_protocol_012_Psithaca.Protocol.Alpha_context.Slot.t -> int) ->
  candidate ->
  unit Lwt.t

val cancel_monitoring : t -> unit

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