package async_unix

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
val names : string list
val too_old : ([< `Read | `Set_and_create ], 'a t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm
val bytes_seen : ([< `Read | `Set_and_create ], 'a t, Core.Int63.t) Fieldslib.Field.t_with_perm
val times_received_queue : ([< `Read | `Set_and_create ], 'a t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm
val bytes_received_queue : ([< `Read | `Set_and_create ], 'a t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm
val bytes_received_at_now_minus_maximum_age : ([< `Read | `Set_and_create ], 'a t, Core.Int63.t) Fieldslib.Field.t_with_perm
val maximum_age : ([< `Read | `Set_and_create ], 'a t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm
val writer : ([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm
val make_creator : writer: (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm -> 'b -> ('c -> 'd) * 'e) -> maximum_age: (([< `Read | `Set_and_create ], 'f t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> 'e -> ('c -> Core.Time_ns.Span.t) * 'g) -> bytes_received_at_now_minus_maximum_age: (([< `Read | `Set_and_create ], 'h t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'g -> ('c -> Core.Int63.t) * 'i) -> bytes_received_queue: (([< `Read | `Set_and_create ], 'j t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> 'i -> ('c -> Core.Int63.t Core.Queue.t) * 'k) -> times_received_queue: (([< `Read | `Set_and_create ], 'l t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> 'k -> ('c -> Core.Time_ns.t Core.Queue.t) * 'm) -> bytes_seen: (([< `Read | `Set_and_create ], 'n t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'm -> ('c -> Core.Int63.t) * 'o) -> too_old: (([< `Read | `Set_and_create ], 'p t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'o -> ('c -> unit Async_unix.Import.Ivar.t) * 'q) -> 'b -> ('c -> 'd t) * 'q
val create : writer:'a -> maximum_age:Core.Time_ns.Span.t -> bytes_received_at_now_minus_maximum_age:Core.Int63.t -> bytes_received_queue:Core.Int63.t Core.Queue.t -> times_received_queue:Core.Time_ns.t Core.Queue.t -> bytes_seen:Core.Int63.t -> too_old:unit Async_unix.Import.Ivar.t -> 'a t
val map : writer: (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm -> 'b) -> maximum_age: (([< `Read | `Set_and_create ], 'c t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> Core.Time_ns.Span.t) -> bytes_received_at_now_minus_maximum_age: (([< `Read | `Set_and_create ], 'd t, Core.Int63.t) Fieldslib.Field.t_with_perm -> Core.Int63.t) -> bytes_received_queue: (([< `Read | `Set_and_create ], 'e t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> Core.Int63.t Core.Queue.t) -> times_received_queue: (([< `Read | `Set_and_create ], 'f t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> Core.Time_ns.t Core.Queue.t) -> bytes_seen: (([< `Read | `Set_and_create ], 'g t, Core.Int63.t) Fieldslib.Field.t_with_perm -> Core.Int63.t) -> too_old: (([< `Read | `Set_and_create ], 'h t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit Async_unix.Import.Ivar.t) -> 'b t
val iter : writer: (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm -> unit) -> maximum_age: (([< `Read | `Set_and_create ], 'b t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> unit) -> bytes_received_at_now_minus_maximum_age: (([< `Read | `Set_and_create ], 'c t, Core.Int63.t) Fieldslib.Field.t_with_perm -> unit) -> bytes_received_queue: (([< `Read | `Set_and_create ], 'd t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> unit) -> times_received_queue: (([< `Read | `Set_and_create ], 'e t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> unit) -> bytes_seen: (([< `Read | `Set_and_create ], 'f t, Core.Int63.t) Fieldslib.Field.t_with_perm -> unit) -> too_old: (([< `Read | `Set_and_create ], 'g t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> unit) -> unit
val fold : init:'a -> writer: ('a -> ([< `Read | `Set_and_create ], 'b t, 'b) Fieldslib.Field.t_with_perm -> 'c) -> maximum_age: ('c -> ([< `Read | `Set_and_create ], 'd t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> 'e) -> bytes_received_at_now_minus_maximum_age: ('e -> ([< `Read | `Set_and_create ], 'f t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'g) -> bytes_received_queue: ('g -> ([< `Read | `Set_and_create ], 'h t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> 'i) -> times_received_queue: ('i -> ([< `Read | `Set_and_create ], 'j t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> 'k) -> bytes_seen: ('k -> ([< `Read | `Set_and_create ], 'l t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'm) -> too_old: ('m -> ([< `Read | `Set_and_create ], 'n t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'o) -> 'o
val map_poly : ([< `Read | `Set_and_create ], 'a t, 'b) Fieldslib.Field.user -> 'b list
val for_all : writer: (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm -> bool) -> maximum_age: (([< `Read | `Set_and_create ], 'b t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_received_at_now_minus_maximum_age: (([< `Read | `Set_and_create ], 'c t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_received_queue: (([< `Read | `Set_and_create ], 'd t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> bool) -> times_received_queue: (([< `Read | `Set_and_create ], 'e t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_seen: (([< `Read | `Set_and_create ], 'f t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> too_old: (([< `Read | `Set_and_create ], 'g t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> bool
val exists : writer: (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm -> bool) -> maximum_age: (([< `Read | `Set_and_create ], 'b t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_received_at_now_minus_maximum_age: (([< `Read | `Set_and_create ], 'c t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_received_queue: (([< `Read | `Set_and_create ], 'd t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> bool) -> times_received_queue: (([< `Read | `Set_and_create ], 'e t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> bool) -> bytes_seen: (([< `Read | `Set_and_create ], 'f t, Core.Int63.t) Fieldslib.Field.t_with_perm -> bool) -> too_old: (([< `Read | `Set_and_create ], 'g t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> bool) -> bool
val to_list : writer: (([< `Read | `Set_and_create ], 'a t, 'a) Fieldslib.Field.t_with_perm -> 'b) -> maximum_age: (([< `Read | `Set_and_create ], 'c t, Core.Time_ns.Span.t) Fieldslib.Field.t_with_perm -> 'b) -> bytes_received_at_now_minus_maximum_age: (([< `Read | `Set_and_create ], 'd t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'b) -> bytes_received_queue: (([< `Read | `Set_and_create ], 'e t, Core.Int63.t Core.Queue.t) Fieldslib.Field.t_with_perm -> 'b) -> times_received_queue: (([< `Read | `Set_and_create ], 'f t, Core.Time_ns.t Core.Queue.t) Fieldslib.Field.t_with_perm -> 'b) -> bytes_seen: (([< `Read | `Set_and_create ], 'g t, Core.Int63.t) Fieldslib.Field.t_with_perm -> 'b) -> too_old: (([< `Read | `Set_and_create ], 'h t, unit Async_unix.Import.Ivar.t) Fieldslib.Field.t_with_perm -> 'b) -> 'b list
module Direct : sig ... end
OCaml

Innovation. Community. Security.