package async_kernel

  1. Overview
  2. Docs
package async_kernel
Legend:
Library
Module
Module type
Parameter
Class
Class type
module Time_ns : sig ... end
module Alarm : sig ... end
module Alarm_precision = Timing_wheel.Alarm_precision
val default_timing_wheel_config : Timing_wheel.Config.t
type callback = unit -> unit
module Id : sig ... end
module T1 : sig ... end
type t = Core.read T1.t
val sexp_of_t : t -> Sexplib0.Sexp.t
val invariant : 'a T1.t -> unit
val 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
module Read_write : sig ... end
val id : 'a T1.t -> Id.t
val is_wall_clock : 'a T1.t -> bool
val length : 'a T1.t -> int
val max_allowed_alarm_time : 'a T1.t -> Core.Time_ns.t
val read_only : [> Core.read ] T1.t -> t
val fire : 'a T1.t -> T1.Event.t -> unit
val alarm_precision : 'a T1.t -> Core.Time_ns.Span.t
val next_alarm_fires_at : 'a T1.t -> Core.Time_ns.t option
val next_alarm_runs_at : 'a T1.t -> Core.Time_ns.t option
val now : 'a T1.t -> Core.Time_ns.t
val timing_wheel_now : 'a T1.t -> Core.Time_ns.t
val schedule : 'a T1.t -> T1.Event.t -> unit
val remove_from_fired : 'a T1.t -> T1.Event.t -> new_status:T1.Event.Status.t -> unit
module Event : sig ... end
val run_after : 'a T1.t -> Time_ns.Span.t -> (unit -> unit) -> unit
val run_at : 'a T1.t -> Time_ns.t -> (unit -> unit) -> unit
val run_at_intervals : 'a T1.t -> Time_ns.Span.t -> (unit -> unit) -> unit
type send_exn = Async_kernel__.Types.Monitor.t -> ?backtrace:[ `Get | `This of Core.Backtrace.t ] -> exn -> unit
val run_fired_events : 'a T1.t -> send_exn:send_exn option -> unit
val any_fired_events_to_run : 'a T1.t -> bool
val advance_clock : 'a T1.t -> to_:Core.Time_ns.t -> send_exn:send_exn option -> unit
val fire_past_alarms : 'a T1.t -> send_exn:send_exn option -> unit
val advance_internal : 'a T1.t -> to_:Core.Time_ns.t -> send_exn:send_exn option -> unit
val prepare_to_advance : 'a T1.t -> send_exn:send_exn option -> unit
val finish_advancing : 'a T1.t -> (unit, Core.Error.t) Core._result
val advance_by_alarms : 'a T1.t -> to_:Time_ns.t -> (unit, Core.Error.t) Core._result
val advance_by_alarms_by : 'a T1.t -> Time_ns.Span.t -> (unit, Core.Error.t) Core._result
val advance_by_max_alarms_in_each_timing_wheel_interval : 'a T1.t -> to_:Time_ns.t -> (unit, Core.Error.t) Core._result
val advance_directly : 'a T1.t -> to_:Core.Time_ns.t -> (unit, Core.Error.t) Core._result
val advance_directly_by : 'a T1.t -> Time_ns.Span.t -> (unit, Core.Error.t) Core._result
val duration_of : 'a T1.t -> (unit -> 'b) -> 'b * Time_ns.Span.t
val max_alarm_time_in_min_timing_wheel_interval : 'a T1.t -> Core.Time_ns.t option
val has_events_to_run : 'a T1.t -> bool
OCaml

Innovation. Community. Security.

GitHub Discord Twitter Peertube RSS
About
Changelog Releases Industrial Users Academic Users Why OCaml
Ecosystem
Packages Community Events OCaml Planet Jobs
Resources
Install OCaml Get Started Platform Tools Language Manual Standard Library API Books Exercises Papers OCaml Playground Logo
Policies
Carbon Footprint Governance Privacy Code of Conduct