Module `Kinetic.Make`Source

Parameters

module I : INTEGRATION

Signature

Sourcemodule Entry : sig ... end

Sourcetype session

Sourceval get_connection_id : session -> int64

Sourcetype batch

Sourceval get_batch_id : batch -> int32

Sourcetype client

Sourceval get_session : client -> session

Sourcetype synchronization =

| WRITETHROUGH
| WRITEBACK
| FLUSH

Sourceval get_config : session -> Config.t

Sourceval make_sha1 : I.value slice -> Tag.t

Sourceval make_crc32 : I.value slice -> Tag.t

Sourcetype 'a result = ('a, Error.t) Lwt_result.t

Source

val handshake : 
  string ->
  int64 ->
  ?trace:bool ->
  ?timeout:float ->
  ?max_operation_count_per_batch:int ->
  I.socket ->
  session result

The initial contact with the device, which will send some information that is needed in the session

Sourceval tracing : session -> bool -> unit

turn on or of the trace logging of the raw messages

Source

val put : 
  ?timeout:timeout_ms ->
  ?priority:priority ->
  client ->
  key ->
  I.value slice ->
  db_version:version ->
  new_version:version ->
  forced:bool option ->
  synchronization:synchronization option ->
  tag:Tag.t option ->
  unit result

insert a key value pair. db_version is the version that's supposed to be the current version in the database. new_version is the version of the key value pair _after_ the update. forced updates happen regardless the db_version

Source

val delete_forced : 
  ?timeout:timeout_ms ->
  ?priority:priority ->
  client ->
  key ->
  unit result

Source

val get : 
  ?timeout:timeout_ms ->
  ?priority:priority ->
  client ->
  key ->
  (I.value * version) option result

Sourceval noop : ?timeout:timeout_ms -> ?priority:priority -> client -> unit result

Sourceval instant_secure_erase : ?pin:bytes -> client -> unit result

Sourceval download_firmware : client -> I.value slice -> unit result

Source

val get_key_range : 
  ?timeout:timeout_ms ->
  ?priority:priority ->
  client ->
  key ->
  bool ->
  (key * bool) option ->
  bool ->
  int ->
  key list result

Source

val get_capacities : 
  ?timeout:timeout_ms ->
  ?priority:priority ->
  client ->
  (int64 * float) result

returns capacity of the drive and portion full

Sourcetype forced = bool option

Sourcetype batch_operation =

| BPut of Entry.t * forced
| BDel of Entry.t * forced

Source

val do_batch : 
  ?timeout:timeout_ms ->
  ?priority:priority ->
  client ->
  batch_operation list ->
  unit result

Source

val wrap_socket : 
  ?trace:bool ->
  ?timeout:float ->
  ?secret:string ->
  ?cluster_version:int64 ->
  ?max_operation_count_per_batch:int ->
  I.socket ->
  (unit -> unit Lwt.t) ->
  client result

Sourceval dispose : client -> unit Lwt.t

package kinetic-client

Module Kinetic.MakeSource

Parameters

Signature

Module `Kinetic.Make`Source