Module `Rpc_parallel__.Utils`

module Worker_id : sig ... end

module Worker_type_id : Core.Unique_id

module Internal_connection_state : sig ... end

val try_within : monitor:Async.Monitor.t -> (unit -> 'a Async.Deferred.t) -> 'a Core.Or_error.t Async.Deferred.t
val try_within_exn : monitor:Async.Monitor.t -> (unit -> 'a Async.Deferred.t) -> 'a Async.Deferred.t
val our_binary : unit -> string
val our_md5 : unit -> string Core.Or_error.t Async.Deferred.t
val whoami : unit -> [ `Worker | `Master ]
val clear_env : unit -> unit
val create_worker_env : extra:(string * string) list -> (string * string) list Core.Or_error.t
val to_daemon_fd_redirection : [ `Dev_null | `File_append of string | `File_truncate of string ] -> Daemon.Fd_redirection.t