package kinetic-client

You can search for identifiers within the package.

in-package search v0.2.0

kinetic-client
- Library kinetic-client
  - Kinetic
    
    Config
    
    Tag
    
    INTEGRATION
    
    BytesIntegration
    
    Error
    
    Make
    
    Entry
  - Kinetic_config
    
    Config
  - Kinetic_error
    
    Error
  - Kinetic_integration
    
    INTEGRATION
    
    BytesIntegration
  - Kinetic_network
  - Kinetic_pb
  - Kinetic_session
    
    Session
  - Kinetic_tag
    
    Tag
  - Kinetic_types
  - Kinetic_util
- Sources
  - kinetic-client
    
    kinetic.ml
    
    kinetic_config.ml
    
    kinetic_error.ml
    
    kinetic_integration.ml
    
    kinetic_network.ml
    
    kinetic_pb.ml
    
    kinetic_session.ml
    
    kinetic_tag.ml
    
    kinetic_types.ml
    
    kinetic_util.ml

Legend:
Page
Library
Module
Module type
Parameter
Class
Class type
Source

Module `Kinetic_network`Source

Sourceval _decode_fixed32 : Bytes.t -> int -> int

Sourceval _encode_fixed32 : bytes -> int -> int -> unit

Source

val read_exact_generic : 
  ('b -> 'a -> int -> int -> int Lwt.t) ->
  'b ->
  'a ->
  int ->
  int ->
  unit Lwt.t

Source

val write_exact_generic : 
  ('b -> 'a -> int -> int -> int Lwt.t) ->
  'b ->
  'a ->
  int ->
  int ->
  unit Lwt.t

Source

val maybe_read_generic : 
  (int -> 'a) ->
  ('b -> 'a -> int -> int -> int Lwt.t) ->
  'b ->
  int ->
  'a option Lwt.t

Source

val network_receive_generic : 
  timeout:float ->
  (int -> 'a) ->
  ('b -> 'a -> int -> int -> int Lwt.t) ->
  ('b -> bytes -> int -> int -> int Lwt.t) ->
  'b ->
  ('b -> string) ->
  bool ->
  (Kinetic_types.message * 'a option * bytes, Kinetic_error.Error.t) result
    Lwt.t

Source

val network_send_generic : 
  ('a -> 'b -> int -> int -> int Lwt.t) ->
  ('a -> bytes -> int -> int -> int Lwt.t) ->
  'a ->
  Bytes.t ->
  ('b * int * int) option ->
  ('a -> string) ->
  bool ->
  unit Lwt.t

package kinetic-client

Module Kinetic_networkSource

Module `Kinetic_network`Source