This file is automatically generated by a target in the build system. Do not modify it by hand.
val sexp_of_t : _ ‑> _ ‑> (_, _) t ‑> Core.Sexp.tval sexp_of_t_no_exn : _ ‑> _ ‑> (_, _) t_no_exn ‑> Core.Sexp.tval to_iobuf : (_, 'rw) t ‑> ('rw, Core.Iobuf.no_seek) Core.Iobuf.tmodule R : sig ... endmodule Message_type_and_errors : sig ... endval get_message_type : ([> Core.read ], _) Core.Iobuf.t ‑> Message_type_and_errors.packedval of_iobuf : ('rw, _) Core.Iobuf.t ‑> trusted:'ty Message_type_and_errors.t ‑> ('ty, 'rw) tof_iobuf must be fed a message type that comes from a call to
get_message_type on the same window, otherwise it may cause segfaults
or nonsensical reads.
val of_iobuf_exn : ('rw, _) Core.Iobuf.t ‑> 'ty Message_type_and_errors.t ‑> ('ty, 'rw) tmodule New_single : sig ... endmodule New_group : sig ... endmodule New_group_point : sig ... endmodule End_of_header : sig ... endmodule Epoch : sig ... endmodule Unpacked : sig ... endval num_bytes_in_message : ([> Core.read ], _) Core.Iobuf.t ‑> intAssuming the iobuf starts at a message, returns its length or raise if
the window doesn't contain num_bytes_needed_for_message_length bytes.
val skip_message : ([> Core.read ], Core.Iobuf.seek) Core.Iobuf.t ‑> unitEquivalent to Iobuf.advance buf (num_bytes_in_message buf)
val buffer_contains_full_message : ([> Core.read ], _) Core.Iobuf.t ‑> boolval of_unpacked : Unpacked.t ‑> (_, _) Core.Iobuf.tval to_unpacked : ([> Core.read ], _) Core.Iobuf.t ‑> Unpacked.t R.tval to_unpacked_exn : ([> Core.read ], _) Core.Iobuf.t ‑> Unpacked.t