Module Tezos_base.Worker_types

The error used when a worker has terminated

type worker_status =
| Launching of Time.System.t
| Running of Time.System.t
| Closing of Time.System.t * Time.System.t
| Closed of Time.System.t * Time.System.t * Tezos_error_monad.Error_monad.error list option

The running status of an individual worker.

val worker_status_encoding : Tezos_error_monad.Error_monad.error list Data_encoding.t -> worker_status Data_encoding.t

Worker status serializer for RPCs.

type worker_information = {
instances_number : int;
wstatus : worker_status;
queue_length : int;
}
val worker_information_encoding : Tezos_error_monad.Error_monad.error list Data_encoding.t -> worker_information Data_encoding.t
type request_status = {
pushed : Time.System.t;
treated : Time.System.t;
completed : Time.System.t;
}

The running status of an individual request.

val request_status_encoding : request_status Data_encoding.t

Request status serializer for RPCs.

type 'req full_status = {
status : worker_status;
pending_requests : (Time.System.t * 'req) list;
current_request : (Time.System.t * Time.System.t * 'req) option;
}

The full status of an individual worker.

val full_status_encoding : 'req Data_encoding.t -> Tezos_error_monad.Error_monad.error list Data_encoding.t -> 'req full_status Data_encoding.t

Full worker status serializer for RPCs.

val pp_status : Stdlib.Format.formatter -> request_status -> unit

Exhaustive status pretty printer

val pp_status_completed : Stdlib.Format.formatter -> request_status -> unit

Pretty-prints the completion time