kinetic-client

Client API for Seagate's Kinetic drives
IN THIS PACKAGE
val _decode_fixed32 : Bytes.t -> int -> int
val _encode_fixed32 : bytes -> int -> int -> unit
val read_exact_generic : ( 'b -> 'a -> int -> int -> int Lwt.t ) -> 'c -> 'a0 -> int -> int -> unit Lwt.t
val write_exact_generic : ( 'b -> 'a -> int -> int -> int Lwt.t ) -> 'c -> 'a0 -> int -> int -> unit Lwt.t
val maybe_read_generic : ( int -> 'a ) -> ( 'b -> 'c -> int -> int -> int Lwt.t ) -> 'd -> int -> 'e option Lwt.t
val network_receive_generic : timeout:float -> ( int -> 'a ) -> ( 'b -> 'a -> int -> int -> int Lwt.t ) -> ( 'c -> bytes -> int -> int -> int Lwt.t ) -> 'd -> ( 'e -> string ) -> bool -> ( Kinetic_types.message * 'a option * bytes, Kinetic_error.Error.t ) result Lwt.t
val network_send_generic : ( 'a -> 'b -> int -> int -> int Lwt.t ) -> ( 'c -> bytes -> int -> int -> int Lwt.t ) -> 'd -> Bytes.t -> ('e * int * int) option -> ( 'f -> string ) -> bool -> unit Lwt.t