Module `Orewa`Source

Sourcetype t

Sourcetype common_error = [

| `Connection_closed
| `Eof
| `Unexpected

]

val pp_common_error : 
  Ppx_deriving_runtime.Format.formatter ->
  common_error ->
  Ppx_deriving_runtime.unit

Sourceval show_common_error : common_error -> Ppx_deriving_runtime.string

Source

val equal_common_error : 
  common_error ->
  common_error ->
  Ppx_deriving_runtime.bool

Sourceval echo : t -> string -> (string, [> common_error ]) Async.Deferred.Result.t

Sourcetype exist =

| Not_if_exists
| Only_if_exists

Source

val set : 
  t ->
  key:string ->
  ?expire:Core.Time.Span.t ->
  ?exist:exist ->
  string ->
  (unit, [> common_error ]) Async.Deferred.Result.t

Source

val get : 
  t ->
  string ->
  (string option, [> common_error ]) Async.Deferred.Result.t

Source

val getrange : 
  t ->
  start:int ->
  end':int ->
  string ->
  (string, [> common_error ]) Async.Deferred.Result.t

Source

val getset : 
  t ->
  key:string ->
  string ->
  (string option, [> common_error ]) Async.Deferred.Result.t

Sourceval strlen : t -> string -> (int, [> common_error ]) Async.Deferred.Result.t

Source

val mget : 
  t ->
  string list ->
  (string option list, [> common_error ]) Async.Deferred.Result.t

Source

val mset : 
  t ->
  (string * string) list ->
  (unit, [> common_error ]) Async.Deferred.Result.t

Source

val msetnx : 
  t ->
  (string * string) list ->
  (bool, [> common_error ]) Async.Deferred.Result.t

Source

val lpush : 
  t ->
  key:string ->
  string ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val lrange : 
  t ->
  key:string ->
  start:int ->
  stop:int ->
  (string list, [> common_error ]) Async.Deferred.Result.t

Source

val append : 
  t ->
  key:string ->
  string ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val auth : 
  t ->
  string ->
  (unit, [> `Redis_error of string | common_error ]) Async.Deferred.Result.t

Sourceval bgrewriteaof : t -> (string, [> common_error ]) Async.Deferred.Result.t

Sourceval bgsave : t -> (string, [> common_error ]) Async.Deferred.Result.t

Source

val bitcount : 
  t ->
  ?range:(int * int) ->
  string ->
  (int, [> common_error ]) Async.Deferred.Result.t

Sourcetype overflow =

| Wrap
| Sat
| Fail

Sourcetype intsize =

| Signed of int
| Unsigned of int

Sourcetype offset =

| Absolute of int
| Relative of int

Sourcetype fieldop =

| Get of intsize * offset
| Set of intsize * offset * int
| Incrby of intsize * offset * int

Source

val bitfield : 
  t ->
  ?overflow:overflow ->
  string ->
  fieldop list ->
  (int option list, [> common_error ]) Async.Deferred.Result.t

Sourcetype bitop =

| AND
| OR
| XOR
| NOT

Source

val bitop : 
  t ->
  destkey:string ->
  ?keys:string list ->
  key:string ->
  bitop ->
  (int, [> common_error ]) Async.Deferred.Result.t

Sourcetype bit =

| Zero
| One

Source

val pp_bit : 
  Ppx_deriving_runtime.Format.formatter ->
  bit ->
  Ppx_deriving_runtime.unit

Sourceval show_bit : bit -> Ppx_deriving_runtime.string

Sourceval equal_bit : bit -> bit -> Ppx_deriving_runtime.bool

Source

val bitpos : 
  t ->
  ?start:int ->
  ?end':int ->
  string ->
  bit ->
  (int option, [> common_error ]) Async.Deferred.Result.t

Source

val getbit : 
  t ->
  string ->
  int ->
  (bit, [> common_error ]) Async.Deferred.Result.t

Source

val setbit : 
  t ->
  string ->
  int ->
  bit ->
  (bit, [> common_error ]) Async.Deferred.Result.t

Sourceval decr : t -> string -> (int, [> common_error ]) Async.Deferred.Result.t

Source

val decrby : 
  t ->
  string ->
  int ->
  (int, [> common_error ]) Async.Deferred.Result.t

Sourceval incr : t -> string -> (int, [> common_error ]) Async.Deferred.Result.t

Source

val incrby : 
  t ->
  string ->
  int ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val incrbyfloat : 
  t ->
  string ->
  float ->
  (float, [> common_error ]) Async.Deferred.Result.t

Sourceval select : t -> int -> (unit, [> common_error ]) Async.Deferred.Result.t

Source

val del : 
  t ->
  ?keys:string list ->
  string ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val exists : 
  t ->
  ?keys:string list ->
  string ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val expire : 
  t ->
  string ->
  Core.Time.Span.t ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val expireat : 
  t ->
  string ->
  Core.Time.t ->
  (int, [> common_error ]) Async.Deferred.Result.t

Source

val keys : 
  t ->
  string ->
  (string list, [> common_error ]) Async.Deferred.Result.t

Sourceval scan : ?pattern:string -> ?count:int -> t -> string Async.Pipe.Reader.t

Source

val move : 
  t ->
  string ->
  int ->
  (bool, [> common_error ]) Async.Deferred.Result.t

Sourceval persist : t -> string -> (bool, [> common_error ]) Async.Deferred.Result.t

Sourceval randomkey : t -> (string, [> common_error ]) Async.Deferred.Result.t

Source

val rename : 
  t ->
  string ->
  string ->
  (unit, [> common_error ]) Async.Deferred.Result.t

Source

val renamenx : 
  t ->
  key:string ->
  string ->
  (bool, [> common_error ]) Async.Deferred.Result.t

Sourcetype order =

| Asc
| Desc

Source

val sort : 
  t ->
  ?by:string ->
  ?limit:(int * int) ->
  ?get:string list ->
  ?order:order ->
  ?alpha:bool ->
  ?store:string ->
  string ->
  ([> `Count of int | `Sorted of string list ], [> common_error ])
    Async.Deferred.Result.t

Source

val ttl : 
  t ->
  string ->
  (Core.Time.Span.t,
    [> `No_such_key of string | `Not_expiring of string | common_error ])
    Async.Deferred.Result.t

Source

val type' : 
  t ->
  string ->
  (string option, [> common_error ]) Async.Deferred.Result.t

Source

val dump : 
  t ->
  string ->
  (string option, [> common_error ]) Async.Deferred.Result.t

Source

val restore : 
  t ->
  key:string ->
  ?ttl:Core.Time.Span.t ->
  ?replace:bool ->
  string ->
  (unit, [> common_error ]) Async.Deferred.Result.t

Sourceval connect : ?port:int -> host:string -> t Async.Deferred.t

Sourceval close : t -> unit Async.Deferred.t

Source

val with_connection : 
  ?port:int ->
  host:string ->
  (t -> 'a Async.Deferred.t) ->
  'a Async.Deferred.t

package orewa

Module OrewaSource

Module `Orewa`Source