Module `Dream_h2.Server_connection`Source

Sourcemodule Httpaf = Dream_httpaf_.Httpaf

Sourcemodule Hpack = Dream_hpack.Hpack

Sourcemodule AB = Angstrom.Buffered

Sourcemodule Reader = Parse.Reader

Sourcemodule Writer = Serialize.Writer

Sourcemodule Scheduler : sig ... end

Sourcetype request_handler = Reqd.t -> unit

Sourcetype error = [

| `Bad_request
| `Internal_server_error
| `Exn of exn

]

Source

type error_handler =
  ?request:Request.t ->
  error ->
  (Headers.t -> Body.Writer.t) ->
  unit

Sourcetype t = {

mutable settings : Settings.t;
reader : Reader.frame;
writer : Writer.t;
config : Config.t;
request_handler : request_handler;
error_handler : error_handler;
streams : Scheduler.t;
mutable current_client_streams : int;
mutable max_client_stream_id : Stream_identifier.t;
mutable max_pushed_stream_id : Stream_identifier.t;
mutable receiving_headers_for_stream : Stream_identifier.t option;
mutable unacked_settings : int;
mutable did_send_go_away : bool;
hpack_encoder : Hpack.Encoder.t;
hpack_decoder : Hpack.Decoder.t;

}

Sourceval is_closed : t -> bool

Sourceval wakeup_writer : t -> unit

Sourceval shutdown_reader : t -> unit

Sourceval shutdown_writer : t -> unit

Sourceval shutdown : t -> unit

Sourceval was_closed_or_implicitly_closed : t -> Int32.t -> bool

Sourceval report_error : t -> Error.t -> unit

Source

val report_connection_error : 
  t ->
  ?additional_debug_data:string ->
  Error_code.t ->
  unit

Sourceval report_stream_error : t -> Stream_identifier.t -> Error_code.t -> unit

Source

val set_error_and_handle : 
  ?request:'a ->
  t ->
  (((Reqd.request_info, Reqd.request_info) Stream.active_state,
     Reqd.active_stream,
     Reqd.request_info * Reqd.active_stream)
     Stream.state,
    Reqd.error,
    Reqd.error_handler)
    Stream.stream ->
  Reqd.error ->
  Error_code.t ->
  unit

Sourceval report_exn : t -> exn -> unit

Source

val on_close_stream : 
  t ->
  Stream_identifier.t ->
  active:bool ->
  Stream.closed ->
  unit

Source

val send_window_update : 
  'a. t ->
  'a Scheduler.PriorityTreeNode.node ->
  int32 ->
  unit

Source

val create_push_stream : 
  t ->
  Stream_identifier.t ->
  ((((Reqd.request_info, Reqd.request_info) Stream.active_state,
      Reqd.active_stream,
      Reqd.request_info * Reqd.active_stream)
      Stream.state,
     Reqd.error,
     error_handler)
     Stream.stream,
    [> `Push_disabled | `Stream_ids_exhausted ])
    result

Source

val handle_headers : 
  t ->
  end_stream:bool ->
  Scheduler.nonroot Scheduler.node ->
  Reqd.active_stream ->
  Headers.header list ->
  unit

Source

val handle_headers_block : 
  t ->
  ?is_trailers:bool ->
  Scheduler.nonroot Scheduler.node ->
  Reqd.active_stream ->
  Stream.partial_headers ->
  int ->
  Angstrom.bigstring ->
  unit

Source

val handle_trailer_headers : 
  t ->
  Scheduler.nonroot Scheduler.node ->
  Reqd.active_stream ->
  Stream.partial_headers ->
  int ->
  Angstrom.bigstring ->
  unit

Source

val open_stream : 
  t ->
  priority:Priority.t ->
  Int32.t ->
  Scheduler.nonroot Scheduler.node option

Source

val process_first_headers_block : 
  t ->
  Frame.frame_header ->
  Scheduler.nonroot Scheduler.node ->
  Bigstringaf.t ->
  unit

Source

val process_trailer_headers : 
  t ->
  Scheduler.nonroot Scheduler.node ->
  Reqd.active_stream ->
  Frame.frame_header ->
  Angstrom.bigstring ->
  unit

Source

val process_headers_frame : 
  t ->
  Frame.t ->
  priority:Priority.t ->
  Bigstringaf.t ->
  unit

Sourceval process_data_frame : t -> Frame.t -> Bigstringaf.t -> unit

Sourceval process_priority_frame : t -> Frame.t -> Priority.t -> unit

Sourceval process_rst_stream_frame : t -> Frame.t -> Error_code.t -> unit

Sourceval apply_settings_list : t -> Settings.setting list -> unit

Sourceval write_settings_frame : t -> ack:bool -> Settings.setting list -> unit

Sourceval process_settings_frame : t -> Frame.t -> Settings.setting list -> unit

Sourceval process_ping_frame : t -> Frame.t -> Faraday.bigstring -> unit

Sourceval process_goaway_frame : t -> 'a -> ('b * 'c * Bigstringaf.t) -> unit

Source

val add_window_increment : 
  'a. t ->
  'a Scheduler.PriorityTreeNode.node ->
  int32 ->
  unit

Sourceval process_window_update_frame : t -> Frame.t -> int32 -> unit

Sourceval process_continuation_frame : t -> Frame.t -> Angstrom.bigstring -> unit

Source

val default_error_handler : 
  ?request:'a ->
  [< `Bad_gateway
  | `Bad_request
  | `Conflict
  | `Enhance_your_calm
  | `Exn of exn
  | `Expectation_failed
  | `Forbidden
  | `Gateway_timeout
  | `Gone
  | `Http_version_not_supported
  | `I_m_a_teapot
  | `Internal_server_error
  | `Length_required
  | `Method_not_allowed
  | `Misdirected_request
  | `Network_authentication_required
  | `Not_acceptable
  | `Not_found
  | `Not_implemented
  | `Payload_too_large
  | `Payment_required
  | `Precondition_failed
  | `Precondition_required
  | `Proxy_authentication_required
  | `Range_not_satisfiable
  | `Request_header_fields_too_large
  | `Request_timeout
  | `Service_unavailable
  | `Too_many_requests
  | `Unauthorized
  | `Unsupported_media_type
  | `Upgrade_required
  | `Uri_too_long ] ->
  (Headers.t -> Body.Writer.t) ->
  unit

Sourceval write_connection_preface : t -> unit

Source

val create_generic : 
  h2c:bool ->
  config:Config.t ->
  error_handler:error_handler ->
  request_handler ->
  t

Source

val create : 
  ?config:Config.t ->
  ?error_handler:error_handler ->
  request_handler ->
  t

Source

val handle_h2c_request : 
  t ->
  Headers.header list ->
  Faraday.bigstring Httpaf.IOVec.t list ->
  unit

Source

val create_h2c : 
  ?config:Config.t ->
  ?error_handler:error_handler ->
  http_request:Httpaf.Request.t ->
  ?request_body:Faraday.bigstring Httpaf.IOVec.t list ->
  request_handler ->
  (t, string) result

Sourceval next_read_operation : t -> [> `Close | `Read ]

Sourceval read : t -> Bigstringaf.t -> off:int -> len:int -> int

Sourceval read_eof : t -> Bigstringaf.t -> off:int -> len:int -> int

Sourceval yield_reader : 'a -> (unit -> 'b) -> 'b

Source

val next_write_operation : 
  t ->
  [> `Close of int | `Write of Faraday.bigstring Faraday.iovec list | `Yield ]

Sourceval report_write_result : t -> [< `Closed | `Ok of int ] -> unit

Sourceval yield_writer : t -> (unit -> unit) -> unit

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Server_connection/index.html

Module `Dream_h2.Server_connection`Source

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Server_connection/index.html

Module Dream_h2.Server_connectionSource

Module `Dream_h2.Server_connection`Source