package async_kernel

  1. Overview
  2. Docs

Module Scheduler.Synchronous_time_sourceSource

Sourcemodule Time_ns : sig ... end
Sourcemodule Alarm : sig ... end
Sourcemodule Alarm_precision = Timing_wheel.Alarm_precision
Sourceval default_timing_wheel_config : Timing_wheel.Config.t
Sourcetype callback = unit -> unit
module Id : sig ... end
Sourcemodule T1 : sig ... end
Sourceval sexp_of_t : t -> Sexplib0.Sexp.t
Sourceval invariant : 'a T1.t -> unit
Sourceval invariant_with_jobs : job: ((Async_kernel__.Types.Execution_context.t, Obj.t -> unit, Obj.t) Tuple_pool.Slots.t3 Tuple_pool.Pointer.t -> unit) -> 'a T1.t -> unit
Sourcemodule Read_write : sig ... end
Sourceval id : 'a T1.t -> Id.t
Sourceval is_wall_clock : 'a T1.t -> bool
Sourceval length : 'a T1.t -> int
Sourceval max_allowed_alarm_time : 'a T1.t -> Core.Time_ns.t
Sourceval read_only : [> Core.read ] T1.t -> t
Sourceval fire : 'a T1.t -> T1.Event.t -> unit
Sourceval alarm_precision : 'a T1.t -> Core.Time_ns.Span.t
Sourceval next_alarm_fires_at : 'a T1.t -> Core.Time_ns.t option
Sourceval next_alarm_runs_at : 'a T1.t -> Core.Time_ns.t option
Sourceval now : 'a T1.t -> Core.Time_ns.t
Sourceval timing_wheel_now : 'a T1.t -> Core.Time_ns.t
Sourceval schedule : 'a T1.t -> T1.Event.t -> unit
Sourceval remove_from_fired : 'a T1.t -> T1.Event.t -> new_status:T1.Event.Status.t -> unit
Sourcemodule Event : sig ... end
Sourceval run_after : 'a T1.t -> Time_ns.Span.t -> (unit -> unit) -> unit
Sourceval run_at : 'a T1.t -> Time_ns.t -> (unit -> unit) -> unit
Sourceval run_at_intervals : 'a T1.t -> Time_ns.Span.t -> (unit -> unit) -> unit
Sourcetype send_exn = Async_kernel__.Types.Monitor.t -> ?backtrace:[ `Get | `This of Core.Backtrace.t ] -> exn -> unit
Sourceval run_fired_events : 'a T1.t -> send_exn:send_exn option -> unit
Sourceval any_fired_events_to_run : 'a T1.t -> bool
Sourceval advance_clock : 'a T1.t -> to_:Core.Time_ns.t -> send_exn:send_exn option -> unit
Sourceval fire_past_alarms : 'a T1.t -> send_exn:send_exn option -> unit
Sourceval advance_internal : 'a T1.t -> to_:Core.Time_ns.t -> send_exn:send_exn option -> unit
Sourceval prepare_to_advance : 'a T1.t -> send_exn:send_exn option -> unit
Sourceval finish_advancing : 'a T1.t -> (unit, Core.Error.t) Core._result
Sourceval advance_by_alarms : 'a T1.t -> to_:Time_ns.t -> (unit, Core.Error.t) Core._result
Sourceval advance_by_alarms_by : 'a T1.t -> Time_ns.Span.t -> (unit, Core.Error.t) Core._result
Sourceval advance_by_max_alarms_in_each_timing_wheel_interval : 'a T1.t -> to_:Time_ns.t -> (unit, Core.Error.t) Core._result
Sourceval advance_directly : 'a T1.t -> to_:Core.Time_ns.t -> (unit, Core.Error.t) Core._result
Sourceval advance_directly_by : 'a T1.t -> Time_ns.Span.t -> (unit, Core.Error.t) Core._result
Sourceval duration_of : 'a T1.t -> (unit -> 'b) -> 'b * Time_ns.Span.t
Sourceval max_alarm_time_in_min_timing_wheel_interval : 'a T1.t -> Core.Time_ns.t option
Sourceval has_events_to_run : 'a T1.t -> bool