package devkit

You can search for identifiers within the package.

in-package search v0.2.0

devkit
- Devkit
devkit.core
- Devkit_core
  - Action
    
    timer
    
    timer_start
  - Async
    
    Internal
    
    Peer
  - Bit_struct_list
    
    Make
    
    S
    
    S
  - Cache
    
    Assoc
    
    Count
    
    Group
    
    LRU
    
    Lists
    
    Lock
    
    NoLock
    
    Reuse
    
    T
    
    TimeLimited2
    
    Lock
    
    cache
  - Control
  - Daemon
  - Devkit_ragel
  - Digest_auth
  - Exn
  - Exn_lwt
  - ExtArg
  - ExtEnum
  - ExtEnum_merge
  - ExtThread
    
    Async_fin
    
    LockMutex
    
    Pool
    
    WorkerT
    
    Workers
    
    T
  - Factor
    
    Float
    
    Int
  - FastBase64
  - Files
  - Gzip_io
  - Gzip_stream
  - HtmlStream
  - HtmlStream_ragel
    
    Raw
  - Httpev
    
    Answer
    
    Args
    
    T
    
    BuffersCache
    
    Hidden
    
    Param
    
    ReqBuffersCache
    
    Tcp
  - Httpev_common
  - Idn
    
    CONV
    
    Make
    
    CONV
  - Log
    
    State
    
    M
    
    Put
    
    logger
  - Logger
    
    Make
    
    T
    
    Put
    
    PutLimited
    
    T
    
    PutSimple
    
    T
    
    Target
  - Logstash
    
    Dyn
  - Lwt_engines
    
    libevent
    
    poll
  - Lwt_flag
  - Lwt_mark
  - Lwt_util
  - MVar
  - Memory
  - Mtq
  - Network
    
    IPv4
  - Nix
  - Parallel
    
    Forks
    
    T
    
    Services
    
    WorkerT
    
    Workers
  - Persist
    
    Marshal
    
    V
    
    Marshal_ext
    
    V
    
    Value
    
    Value_ext
  - Pid
  - Possibly_otel
    
    Traceparent
  - Prelude
    
    Fresh
    
    T
  - Reader
  - Signal
  - Static_config
    
    base
  - Stre
    
    ASCII
  - Systemd
    
    Daemon
  - Time
  - UnsafeBitSet
  - Var
    
    typ
  - Web
    
    CURL
    
    CurlCache
    
    Curl_blocking
    
    Curl_lwt_for_http
    
    HTTP
    
    IO
    
    Http
    
    Curl_IO
    
    IO
    
    Http_blocking
    
    IO
    
    Http_lwt
    
    IO
    
    IO_TYPE
    
    IO_blocking
    
    IO_lwt
devkit.ocamlnet_lite
- Ocamlnet_lite
  - Netaux
    
    ArrayAux
  - Netbuffer
  - Netconversion
  - Netencoding
    
    Html
    
    Url
  - Netstring_str
  - Netstring_tstring
  - Netsys_types

Legend:
Library
Module
Module type
Parameter
Class
Class type

Asynchronous IO helpers

module Ev = Libevent

module Internal : sig ... end

val simple_event : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  Unix.file_descr ->
  Ev.event_flags list ->
  (Ev.event -> Unix.file_descr -> Ev.event_flags -> unit) ->
  Ev.event

Create a new event or use the provided ev and make it persistent with the infinite timeout (or use the provided timeout). Schedule this event with provided callback f. Don't forget del to unschedule.

val setup_simple_event : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  Unix.file_descr ->
  Ev.event_flags list ->
  (Ev.event -> Unix.file_descr -> Ev.event_flags -> unit) ->
  unit

type result =

| End
| Data of int
| Block
| Exn of exn

val read_some : Unix.file_descr -> bytes -> int -> int -> result

val write_some : Unix.file_descr -> string -> int -> int -> int

val read_available : 
  limit:int ->
  Unix.file_descr ->
  [> `Chunk of string * bool | `Limit of string ]

Read out all immediately available input (no blocking)

returns
`Limit when limit is exceeded, `Chunk (data,final) otherwise

val show_error : 
  [< `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] ->
  string

val read_buf : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  bytes ->
  Unix.file_descr ->
  ([> `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] ->
    int ->
    unit) ->
  (bytes -> unit) ->
  unit

read_buf buf fd err k - asynchronously fill buf with data from fd and call k buf when done (buffer is full). fd should be nonblocking. Call err on error (EOF).

val read_n : 
  Ev.event_base ->
  ?ev:Ev.event ->
  ?timeout:float ->
  int ->
  Unix.file_descr ->
  ([> `Eof | `EofImm | `Exn of exn | `ExnImm of exn | `Timeout ] ->
    int ->
    unit) ->
  (string -> unit) ->
  unit

val periodic_timer_0 : 
  Ev.event_base ->
  bool Stdlib.ref ->
  float ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  Ev.event

Call f with delay-second pauses between invocations. Set stop to true to stop the timer. NB do not Ev.del the event inside the f callback.

val periodic_timer_now : 
  Ev.event_base ->
  ?stop:bool Stdlib.ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  Ev.event

val periodic_timer_wait : 
  Ev.event_base ->
  ?stop:bool Stdlib.ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  Ev.event

val setup_periodic_timer_now : 
  Ev.event_base ->
  ?stop:bool Stdlib.ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  unit

val setup_periodic_timer_wait : 
  Ev.event_base ->
  ?stop:bool Stdlib.ref ->
  float ->
  ?name:string ->
  (unit -> unit) ->
  unit

module Peer : sig ... end

val delay : Ev.event_base -> float -> ('a -> unit) -> 'a -> unit

val poll : Ev.event_base -> unit