package async_rpc_kernel

  1. Overview
  2. Docs
Legend:
Library
Module
Module type
Parameter
Class
Class type
type message_too_big = {
  1. size : int;
  2. max_message_size : int;
}
val bin_shape_message_too_big : Core.Bin_prot.Shape.t
val bin_size_message_too_big : message_too_big Core.Bin_prot.Size.sizer
val bin_write_message_too_big : message_too_big Core.Bin_prot.Write.writer
val bin_writer_message_too_big : message_too_big Core.Bin_prot.Type_class.writer
val __bin_read_message_too_big__ : (int -> message_too_big) Core.Bin_prot.Read.reader
val bin_read_message_too_big : message_too_big Core.Bin_prot.Read.reader
val bin_reader_message_too_big : message_too_big Core.Bin_prot.Type_class.reader
val compare_message_too_big : message_too_big -> message_too_big -> int
val globalize_message_too_big : message_too_big -> message_too_big
val message_too_big_of_sexp : Sexplib0.Sexp.t -> message_too_big
val sexp_of_message_too_big : message_too_big -> Sexplib0.Sexp.t
type 'a t =
  1. | Sent of {
    1. result : 'a;
    2. bytes : int;
      (*

      Bytes should equal the size of the bin_prot rpc message and data. The total bytes written on the network in the standard protocol (which has 8-bytes sizes before each frame) will be sum([8 + x.bytes for each send result x]). Other framing protocols or encryption (e.g. rpc over kerberos) may write more or less bytes.

      *)
    }
  2. | Closed
  3. | Message_too_big of message_too_big
val sexp_of_t : 'a. ('a -> Sexplib0.Sexp.t) -> 'a t -> Sexplib0.Sexp.t
val globalize : 'a. ('a -> 'a) -> 'a t -> 'a t
OCaml

Innovation. Community. Security.