package devkit

  1. Overview
  2. Docs
Development kit - general purpose library

Install 

dune-project
 Dependency

github.com Readme Edit opam file Versions (8)

Authors

  1. A
    Ahrefs <github@ahrefs.com>

Maintainers

  1. I
    igor@ahrefs.com

Sources

devkit-1.20240429.tbz
sha256=222f8ac131b1d970dab7eeb2714bfd6b9338b88b1082e6e01c136ae19e7eaef4
sha512=c9e6d93e3d21e5530c0f4d5baca51bf1f0a5d19248f8af7678d0665bb5cdf295d7aaaaa3e50eb2e44b8720e55097cc675af4dc8ec45acf9da39feb3eae1405d5

doc/devkit.core/Devkit_core/Httpev/index.html

Module Devkit_core.HttpevSource

Very simple and incomplete HTTP server

module Ev = Libevent
Sourceval buffer_size : int
Sourcemodule Hidden : sig ... end

Server

Sourcetype max_time = {
  1. headers : Time.t;
  2. body : Time.t;
  3. send : Time.t;
}
Sourcetype config = {
  1. connection : Unix.sockaddr;
  2. backlog : int;
  3. log_epipe : bool;
  4. mutable debug : bool;
    (*

    more logging

    *)
  5. events : Ev.event_base;
  6. access_log : out_channel ref;
  7. access_log_enabled : bool;
  8. name : string;
  9. max_request_size : int;
  10. auth : (string * string * string) option;
  11. max_clients : int;
    (*

    limit on total number of requests in processing at any point of time

    *)
  12. max_data_childs : int;
  13. max_data_waiting : int;
  14. yield : bool;
    (*

    do Lwt_unix.yield () after accepting connection to give other lwt threads chance to run (set to true when http requests processing causes other threads to stuck)

    *)
  15. single : bool;
    (*

    only process one request at a time (intended for preforked workers)

    *)
  16. exit_thread : unit Lwt.t option;
    (*

    if set, stop accepting connections as soon as exit_thread terminates (defaults to Daemon.should_exit_lwt)

    *)
  17. reuseport : bool;
  18. nodelay : bool;
  19. strict_args : bool;
    (*

    default false, if enabled - will in particular fail on "/path?arg1&arg2", why would anyone want that?

    *)
  20. max_time : max_time;
  21. cors_allow_all : bool;
  22. on_recv_timeout : [ `Reply_bad_request | `Drop_connection ];
    (*

    what to do on receive timeout, `Reply_bad_request by default

    *)
}

server configuration

Sourceval default_max_time : max_time
Sourceval default : config
include module type of struct include Httpev_common end
Sourcetype encoding = Httpev_common.encoding =
  1. | Gzip
  2. | Identity
Sourcetype meth = [
  1. | `GET
  2. | `POST
  3. | `PUT
  4. | `PATCH
  5. | `DELETE
  6. | `HEAD
  7. | `OPTIONS
]
Sourcetype request = Httpev_common.request = {
  1. addr : Unix.sockaddr;
  2. url : string;
  3. path : string;
  4. args : (string * string) list;
  5. conn : Time.t;
  6. recv : Time.t;
  7. meth : meth;
  8. headers : (string * string) list;
  9. body : string;
  10. version : int * int;
  11. id : int;
  12. socket : Unix.file_descr;
  13. line : string;
    (*

    request line

    *)
  14. mutable blocking : unit IO.output option;
  15. encoding : encoding;
}
Sourcetype reply_status = [
  1. | `Ok
  2. | `Created
  3. | `Accepted
  4. | `No_content
  5. | `Found
  6. | `Moved
  7. | `Bad_request
  8. | `Unauthorized
  9. | `Payment_required
  10. | `Forbidden
  11. | `Not_found
  12. | `Method_not_allowed
  13. | `Not_acceptable
  14. | `Conflict
  15. | `Length_required
  16. | `Request_too_large
  17. | `I'm_a_teapot
  18. | `Unprocessable_content
  19. | `Too_many_requests
  20. | `Internal_server_error
  21. | `Not_implemented
  22. | `Service_unavailable
  23. | `Version_not_supported
  24. | `Custom of string
]
Sourcetype extended_reply_status = [
  1. | reply_status
  2. | `No_reply
]
Sourcetype 'status reply' = 'status * (string * string) list * string
Sourceval show_method : [< `DELETE | `GET | `HEAD | `OPTIONS | `PATCH | `POST | `PUT ] -> string
Sourceval method_of_string : string -> [> `DELETE | `GET | `HEAD | `OPTIONS | `PATCH | `POST | `PUT ]
Sourceval show_client_addr : ?via:Unix.inet_addr list -> request -> string
Sourceval client_addr : request -> Unix.inet_addr * int
Sourceval client_ip : request -> Unix.inet_addr
Sourceval find_header : request -> string -> string
Sourceval header_exn : request -> string -> string
Sourceval header_safe : request -> string -> string
Sourceval header_referer : request -> string
Sourceval show_request : request -> string
Sourceval status_code : reply_status -> int
Sourceval show_http_reply : reply_status -> string
Sourceval cors_preflight_allow_all : [> `No_content ] * (string * string) list * string
Sourcetype partial_body = {
  1. line1 : string;
  2. content_length : int option;
  3. parsed_headers : (string * string) list;
  4. buf : ExtLib.Buffer.t;
}
Sourcetype request_state =
  1. | Headers of ExtLib.Buffer.t
  2. | Body of partial_body
  3. | Body_lwt of int
  4. | Ready of request
Sourcetype client = {
  1. fd : Unix.file_descr;
  2. req_id : int;
  3. time_conn : Time.t;
    (*

    time when client connected

    *)
  4. sockaddr : Unix.sockaddr;
  5. mutable req : request_state;
  6. server : server;
}

client state

Sourceand server = {
  1. listen_socket : Unix.file_descr;
  2. mutable total : int;
  3. mutable active : int;
  4. mutable errors : int;
  5. mutable reject : int;
  6. reqs : (int, request) ExtLib.Hashtbl.t;
  7. clients : (int, client) ExtLib.Hashtbl.t;
  8. config : config;
  9. digest_auth : Digest_auth.t option;
  10. h_childs : (int, unit) ExtLib.Hashtbl.t;
    (*

    currently running forked childs

    *)
  11. q_wait : (unit -> unit) Stack.t;
    (*

    the stack of requests to fork

    *)
}

server state

Sourceval incr_active : server -> unit
Sourceval decr_active : server -> unit
Sourceval incr_total : server -> unit
Sourceval incr_errors : server -> unit
Sourceval incr_reject : server -> unit
Sourceval make_server_state : Unix.file_descr -> config -> server
Sourceval show_socket_error : Unix.file_descr -> string
Sourceval show_peer : client -> string
Sourceval show_client : client -> string
Sourcetype ('a, 'b) result = [
  1. | `Ok of 'a
  2. | `Error of 'b
]
Sourceval space : Pcre.regexp
Sourcetype reason =
  1. | Url
  2. | Version
  3. | Method
  4. | Header
  5. | RequestLine
  6. | Split
  7. | Extra
  8. | NotAcceptable
Sourceexception Parse of reason * string
Sourceval failed : reason -> string -> 'a
Sourceval get_content_length : (string * string) list -> int option
Sourceval decode_args : string -> (string * string) list
Sourceval acceptable_encoding : (string * string) list -> encoding
Sourceval make_request_exn : line1:string -> headers:(string * string) list -> body:string -> client -> request
Sourceval extract_header : string -> string * string
Sourceval extract_headers : string -> string * (string * string) list
Sourceval is_body_ready : partial_body -> bool -> bool
Sourceval teardown : Unix.file_descr -> unit
Sourceval finish : ?shutdown:bool -> client -> unit
Sourceval write_f : client -> (string list ref * int ref) -> Ev.event -> Unix.file_descr -> 'a -> unit
Sourceval log_access_apache : out_channel -> int -> int -> ?background:bool -> request -> unit
Sourceval log_status_apache : out_channel -> [< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported ] -> int -> request -> unit
Sourceval wait : Devkit_core.Async.Ev.event_base -> Unix.file_descr -> (unit -> unit) -> Devkit_core.Async.Ev.event

Wait until fd becomes readable and close it (for eventfd-backed notifications)

Sourceval write_some : Unix.file_descr -> string -> [> `Done | `Some of int ]
Sourceval abort : client -> exn -> string -> unit

close transport connection, count as error

Sourceval write_reply : client -> string list -> unit
Sourceval write_reply_blocking : client -> string -> unit
Sourceval set_blocking : request -> unit IO.output
Sourceval make_request_headers : reply_status -> (string * string) list -> string
Sourceval send_reply_async : client -> encoding -> (reply_status * (string * string) list * string) -> unit
Sourceval send_reply_blocking : client -> (reply_status * (string * string) list) -> unit
Sourceval maybe_allow_cors : client -> (string * string) list -> (string * string) list
Sourceval send_reply_user : client -> request -> ([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported ] * (string * string) list * string) -> unit
Sourceval make_error : exn -> [> `Bad_request | `Not_acceptable | `Not_implemented ] * string
Sourceval send_reply_limit : client -> int -> unit
Sourceval handle_request : client -> partial_body -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit
Sourceval process_chunk : client -> Ev.event -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> string -> bool -> unit
Sourceval handle_client : client -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit
Sourcemodule Tcp : sig ... end
Sourceval check_hung_requests : server -> unit
Sourceval check_waiting_requests : server -> unit
Sourceval finish_child : server -> int -> unit
Sourceval reap_orphans : server -> unit
Sourceval start_listen : config -> Unix.file_descr
Sourceval setup_server_fd : Unix.file_descr -> config -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> server
Sourceval setup_server : config -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> server
Sourceval setup_fd : Unix.file_descr -> config -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit
Sourceval setup : config -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit
Sourceval server : config -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit
Sourceval header : 'a -> 'b -> 'a * 'b
Sourceval forbidden : [> `Forbidden ] * 'a list * string
Sourceval not_found : [> `Not_found ] * 'a list * string
Sourceval found : 'a -> [> `Found ] * (string * 'a) list * string
Sourceval moved : 'a -> [> `Moved ] * (string * 'a) list * string
Sourceval cache_no : (string * string) list
Sourceval cache_yes : float -> (string * string) list

Utilities

Sourcemodule Param : sig ... end

get request params

Sourcemodule type Args = sig ... end
Sourcemodule Args (T : sig ... end) : Args

functor version of Param because somebody thought it is good idea

Sourceval noclose_io : 'a IO.output -> unit IO.output
Sourceval output : (unit IO.output -> unit) -> string

Buffers all output

Sourceval serve : request -> ?status:([> `Ok ] as 'a) -> ?extra:(string * 'b) list -> 'b -> 'c -> 'a * (string * 'b) list * 'c
Sourceval serve_io : request -> ?status:([> `Ok ] as 'a) -> ?extra:(string * 'b) list -> 'b -> (unit IO.output -> unit) -> 'a * (string * 'b) list * string
Sourceval serve_text_io : request -> ?status:([> `Ok ] as 'a) -> (unit IO.output -> unit) -> 'a * (string * string) list * string
Sourceval serve_gzip_io : request -> ?status:([> `Ok ] as 'a) -> (unit IO.output -> unit) -> 'a * (string * string) list * string
Sourceval serve_text : request -> ?status:([> `Ok ] as 'a) -> 'b -> 'a * (string * string) list * 'b
Sourceval run : ?ip:Unix.inet_addr -> int -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit
Sourceval run_unix : string -> (server -> request -> (([< `Accepted | `Bad_request | `Conflict | `Created | `Custom of string | `Forbidden | `Found | `I'm_a_teapot | `Internal_server_error | `Length_required | `Method_not_allowed | `Moved | `No_content | `No_reply | `Not_acceptable | `Not_found | `Not_implemented | `Ok | `Payment_required | `Request_too_large | `Service_unavailable | `Too_many_requests | `Unauthorized | `Unprocessable_content | `Version_not_supported Unauthorized ] * (string * string) list * string) -> unit) -> unit) -> unit

Forked workers

Sourceval check_req : request -> [> `Error of int | `Ok ]
Sourceval check_req_exn : request -> unit
Sourceexception Continue of unit -> unit
Sourceval answer_blocking : ?debug:bool -> server -> request -> (((string * string) list -> unit) -> int64 IO.output -> unit) -> (([> `Ok ] * (string * string) list * string) -> 'a) -> unit
Sourceval stats : Var.typ
Sourceval nr_forked : int ref
Sourceval nr_queued : int ref
Sourceval nr_rejected : int ref
Sourceval answer_forked : ?debug:bool -> server -> request -> (((string * string) list -> unit) -> int64 IO.output -> unit) -> (([> `Internal_server_error | `No_reply | `Ok | `Service_unavailable ] * (string * string) list * string) -> unit) -> unit

Lwt support

Sourceval timeout : float -> 'a Lwt.t -> 'a Lwt.t
Sourceval send_reply : client -> Lwt_io.output_channel -> [< `Body of reply_status * (string * string) list * string | `Chunks of reply_status * (string * string) list * ((string -> unit Lwt.t) -> unit Lwt.t) ] -> unit Lwt.t
Sourceval handle_request_lwt : client -> request -> (server -> request -> ([> `Body of [> `Not_found | `Unauthorized | `Version_not_supported ] * (string * string) list * string ] as 'a) Lwt.t) -> 'a Lwt.t
Sourceval read_buf : Lwt_io.input_channel -> bytes -> string Lwt.t
Sourcemodule ReqBuffersCache : sig ... end
Sourceval read_headers : Lwt_io.input_channel -> int -> (string list * string) Lwt.t
Sourceval handle_client_lwt : client -> Lwt_io.input_channel -> (server -> request -> ([> `Body of [> `Not_found | `Unauthorized | `Version_not_supported ] * (string * string) list * string ] as 'a) Lwt.t) -> 'a Lwt.t
Sourceval accept_hook : (unit -> unit) ref
Sourcemodule BuffersCache : sig ... end
Sourceval setup_fd_lwt : Lwt_unix.file_descr -> config -> (server -> request -> [< `Body of reply_status * (string * string) list * string | `Chunks of reply_status * (string * string) list * ((string -> unit Lwt.t) -> unit Lwt.t) | `No_reply Body No_reply ] Lwt.t) -> unit Lwt.t
Sourceval setup_lwt : config -> (server -> request -> [< `Body of reply_status * (string * string) list * string | `Chunks of reply_status * (string * string) list * ((string -> unit Lwt.t) -> unit Lwt.t) | `No_reply Body No_reply ] Lwt.t) -> unit Lwt.t
Sourceval server_lwt : config -> (server -> request -> [< `Body of reply_status * (string * string) list * string | `Chunks of reply_status * (string * string) list * ((string -> unit Lwt.t) -> unit Lwt.t) | `No_reply Body No_reply ] Lwt.t) -> unit
Sourcemodule Answer : sig ... end