module Event : sig ... end
module Job_or_event : sig ... end
type -'rw t = {
id : Id.t; |
mutable advance_errors : Core_kernel.Error.t list; |
mutable am_advancing : bool; |
events : Job_or_event.t Timing_wheel.t; |
mutable fired_events : Event.t; |
mutable most_recently_fired : Event.t; |
handle_fired : Job_or_event.t Alarm.t -> unit; |
is_wall_clock : bool; |
scheduler : Async_kernel__Scheduler0.t; |
}
val scheduler : 'a t -> Async_kernel__Scheduler0.t
val is_wall_clock : 'a t -> bool
val handle_fired : 'a t -> Job_or_event.t Alarm.t -> unit
val events : 'a t -> Job_or_event.t Timing_wheel.t
val am_advancing : 'a t -> bool
val set_am_advancing : 'a t -> bool -> unit
val advance_errors : 'a t -> Core_kernel.Error.t list
val set_advance_errors : 'a t -> Core_kernel.Error.t list -> unit
module Fields : sig ... end
val sexp_of_t : 'a -> 'b t -> Ppx_sexp_conv_lib.Sexp.t
val timing_wheel_now : 'a t -> Core_kernel.Time_ns.t
val invariant_with_jobs : job:((Async_kernel__Types.Execution_context.t, Stdlib.Obj.t -> unit, Stdlib.Obj.t) Tuple_pool.Slots.t3 Tuple_pool.Pointer.t -> unit) -> 'a t -> unit
val invariant : 'a t -> unit