redis-async v0.16.0 · OCaml Package

Parameters

module Key : Bulk_io.S

module Field : Bulk_io.S

module Value : Bulk_io.S

Signature

module Key = Key

module Field = Field

module Value = Value

type t

val create : 
  ?on_disconnect:(unit -> unit) ->
  ?auth:Auth.t ->
  where_to_connect:[< Async.Socket.Address.t ] Async.Tcp.Where_to_connect.t ->
  unit ->
  t Async.Deferred.Or_error.t

val create_using_sentinel : 
  ?on_disconnect:(unit -> unit) ->
  ?sentinel_auth:Auth.t ->
  ?auth:Auth.t ->
  leader_name:string ->
  where_to_connect:
    [< Async.Socket.Address.t ] Async.Tcp.Where_to_connect.t list ->
  unit ->
  t Async.Deferred.Or_error.t

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

val close_finished : t -> unit Async.Deferred.t

val has_close_started : t -> bool

Redis commands are documented at: https://redis.io/commands

val select : t -> int -> unit Async.Deferred.Or_error.t

val flushall : t -> unit Async.Deferred.Or_error.t

val flushdb : t -> unit Async.Deferred.Or_error.t

val shutdown : t -> unit Async.Deferred.Or_error.t

val echo : t -> Key.t -> Key.t Async.Deferred.Or_error.t

val ping : t -> string -> string Async.Deferred.Or_error.t

val incr : t -> Key.t -> int Async.Deferred.Or_error.t

val del : t -> Key.t list -> int Async.Deferred.Or_error.t

val unlink : t -> Key.t list -> int Async.Deferred.Or_error.t

val dbsize : t -> int Async.Deferred.Or_error.t

val exists : t -> Key.t list -> int Async.Deferred.Or_error.t

val keys : ?pattern:string -> t -> Key.t list Async.Deferred.Or_error.t

val rename : t -> Key.t -> new_key:Key.t -> unit Async.Deferred.Or_error.t

val scan : 
  t ->
  cursor:Cursor.t ->
  ?count:int ->
  ?pattern:string ->
  unit ->
  (Cursor.t * Key.t list) Async.Deferred.Or_error.t

val client_tracking : 
  t ->
  ?bcast:bool ->
  unit ->
  [ `All | `Key of Key.t ] Async.Pipe.Reader.t Async.Deferred.Or_error.t

Turn on Redis client tracking and provide a pipe of invalidation messages received from the server. Closing the pipe turns tracking off.

The NOLOOP option is used, which means that subscribers will not see invalidation messages caused by themselves, unless it is from the flushdb / flushall command.

Read here for more on usage: https://redis.io/commands/client-tracking https://redis.io/topics/client-side-caching

parameter bcast
Whether to use BCAST. Off by default.

val set : 
  t ->
  Key.t ->
  ?expire:Core.Time_ns.Span.t ->
  Value.t ->
  unit Async.Deferred.Or_error.t

val setnx : t -> Key.t -> Value.t -> bool Async.Deferred.Or_error.t

val mset : t -> (Key.t * Value.t) list -> unit Async.Deferred.Or_error.t

val msetnx : t -> (Key.t * Value.t) list -> bool Async.Deferred.Or_error.t

val get : t -> Key.t -> Value.t option Async.Deferred.Or_error.t

val mget : t -> Key.t list -> Value.t option list Async.Deferred.Or_error.t

val smembers : t -> Key.t -> Value.t list Async.Deferred.Or_error.t

val sismember : t -> Key.t -> Value.t -> bool Async.Deferred.Or_error.t

val smismember : 
  t ->
  Key.t ->
  Value.t list ->
  bool list Async.Deferred.Or_error.t

val sadd : t -> Key.t -> Value.t list -> int Async.Deferred.Or_error.t

val srem : t -> Key.t -> Value.t list -> int Async.Deferred.Or_error.t

val zadd : 
  t ->
  Key.t ->
  ([ `Score of float ] * Value.t) list ->
  int Async.Deferred.Or_error.t

val zrem : t -> Key.t -> Value.t list -> int Async.Deferred.Or_error.t

val pttl : 
  t ->
  Key.t ->
  [ `Timeout of Core.Time_ns.Span.t | `No_timeout | `No_key ]
    Async.Deferred.Or_error.t

val pexpire : 
  t ->
  Key.t ->
  ?nx:bool ->
  Core.Time_ns.Span.t ->
  [ `Set | `Not_set ] Async.Deferred.Or_error.t

val pexpireat : 
  t ->
  Key.t ->
  ?nx:bool ->
  Core.Time_ns.t ->
  [ `Set | `Not_set ] Async.Deferred.Or_error.t

val zrange : 
  t ->
  Key.t ->
  min_index:int ->
  max_index:int ->
  Value.t list Async.Deferred.Or_error.t

val zscore : 
  t ->
  Key.t ->
  Value.t ->
  [ `Score of float ] option Async.Deferred.Or_error.t

val zrangebylex : 
  t ->
  Key.t ->
  min:Value.t Core.Maybe_bound.t ->
  max:Value.t Core.Maybe_bound.t ->
  Value.t list Async.Deferred.Or_error.t

val zrangebyscore : 
  t ->
  Key.t ->
  min_score:float Core.Maybe_bound.t ->
  max_score:float Core.Maybe_bound.t ->
  Value.t list Async.Deferred.Or_error.t

val zremrangebyscore : 
  t ->
  Key.t ->
  min_score:float Core.Maybe_bound.t ->
  max_score:float Core.Maybe_bound.t ->
  int Async.Deferred.Or_error.t

val hexists : t -> Key.t -> Field.t -> bool Async.Deferred.Or_error.t

val hset : 
  t ->
  Key.t ->
  (Field.t * Value.t) list ->
  int Async.Deferred.Or_error.t

val hget : t -> Key.t -> Field.t -> Value.t option Async.Deferred.Or_error.t

val hmget : 
  t ->
  Key.t ->
  Field.t list ->
  Value.t option list Async.Deferred.Or_error.t

val hgetall : t -> Key.t -> (Field.t * Value.t) list Async.Deferred.Or_error.t

val hvals : t -> Key.t -> Value.t list Async.Deferred.Or_error.t

val hkeys : t -> Key.t -> Field.t list Async.Deferred.Or_error.t

val hlen : t -> Key.t -> int Async.Deferred.Or_error.t

val hdel : t -> Key.t -> Field.t list -> int Async.Deferred.Or_error.t

val hscan : 
  t ->
  cursor:Cursor.t ->
  ?count:int ->
  Key.t ->
  (Cursor.t * (Field.t * Value.t) list) Async.Deferred.Or_error.t

val keyevent_notifications : 
  t ->
  [< Key_event.t ] as 'a list ->
  ('a * Key.t) Async.Pipe.Reader.t Async.Deferred.Or_error.t

val keyspace_notifications : 
  t ->
  [< Key_event.t ] as 'a list ->
  [ `Patterns of string list | `Keys of Key.t list ] ->
  ('a * Key.t) Async.Pipe.Reader.t Async.Deferred.Or_error.t

val publish : t -> string -> Key.t -> int Async.Deferred.Or_error.t

val subscribe : 
  t ->
  string list ->
  (string * Key.t) Async.Pipe.Reader.t Async.Deferred.Or_error.t

val subscribe_raw : 
  t ->
  [ `Literal of string list | `Pattern of string list ] ->
  consume:((Core.read, Iobuf.seek) Iobuf.t -> subscription:string -> 'a) ->
  'a Async.Pipe.Reader.t Async.Deferred.Or_error.t

val psubscribe : 
  t ->
  string list ->
  (string * Key.t) Async.Pipe.Reader.t Async.Deferred.Or_error.t

val script_load : t -> string -> Redis__.Sha1.t Async.Deferred.Or_error.t

val evalsha : 
  t ->
  Redis__.Sha1.t ->
  Key.t list ->
  Value.t list ->
  Resp3.t Async.Deferred.Or_error.t

val raw_command : t -> string list -> Resp3.t Async.Deferred.Or_error.t

val version : t -> string Async.Deferred.Or_error.t

val role : t -> Role.t Async.Deferred.Or_error.t

val acl_setuser : 
  t ->
  username:string ->
  rules:string list ->
  unit Async.Deferred.Or_error.t

ACL and authentication commands.

Read here for more:

https://redis.io/docs/manual/security/acl/#command-categories https://redis.io/docs/manual/security/acl/#selectors

val acl_deluser : t -> string list -> int Async.Deferred.Or_error.t

val acl_users : t -> string list Async.Deferred.Or_error.t

val acl_list : t -> string list Async.Deferred.Or_error.t

val acl_getuser : t -> username:string -> Resp3.t Async.Deferred.Or_error.t

val auth : t -> auth:Auth.t -> unit -> unit Async.Deferred.Or_error.t

val sentinel_leader : 
  t ->
  string ->
  Core.Host_and_port.t Async.Deferred.Or_error.t

Sentinel specific commands. These will fail if not directly connected to a sentinel.

Read here for more: https://redis.io/docs/manual/sentinel/#sentinel-api

package redis-async

Parameters

Signature