ssdb

type Client interface {
	Set(key string, value string) error
	Get(key string) (result string, err error)
	Del(key string) (bool, error)
	Exists(key string) (bool, error)
	//  key_start<key<=key_end
	Keys(key_start, key_end string, limit int) ([]string, error)
	// key_start<key<=key_end
	Scan(key_start, key_end string, limit int) (map[string]string, error)
	// key_end<=key<key_start
	RScan(key_start, key_end string, limit int) (map[string]string, error)
	Incr(key string, by int64) (value int64, err error)
	MultiSet(kvs []string) (bool, error)
	MultiGet(keys []string) (map[string]string, error)
	MultiDel(keys []string) (bool, error)

	ZSet(setname, key string, score int64) error
	ZGet(setname, key string) (int64, error)
	ZIncr(setname, key string, by int64) (value int64, err error)
	ZDel(sentname, key string) (bool, error)
	ZSize(setname string) (int64, error)
	ZScan(setname, keystart string, score_start, score_end int64, limit int) (map[string]int64, error)
	// name_start<name<=name_end
	ZList(name_start, name_end string, limit int) ([]string, error)
	ZClear(setname string) error
	ZCount(setname string, score_start, score_end int64) (int, error)
	ZExists(setname, key string) (bool, error)
	// key_start<key   score_start<=score<=score_end
	ZKeys(setname, key_start string, score_start, score_end int64, limit int) ([]string, error)
	MultiZGet(setname string, keys []string) (map[string]int64, error)
	MultiZset(setname string, kvs map[string]int64) error

	HSet(name, key, value string) (bool, error)
	HGet(name, key string) (string, error)
	HDel(name, key string) (bool, error)
	HIncr(name, key string, by int64) (int64, error)
	HExists(name, key string) (bool, error)
	HSize(name string) (int64, error)
	//      name_start<name<=name_end
	HList(name_start, name_end string, limit int) ([]string, error)
	HRlist(name_start, name_end string, limit int) ([]string, error)
	HKeys(name, key_start, key_end string, limit int) ([]string, error)
	HGetAll(name string) (map[string]string, error)
	HScan(name, key_start, key_end string, limit int) (map[string]string, error)
	HRscan(name, key_start, key_end string, limit int) (map[string]string, error)
	HClear(name string) (bool, error)
	MultiHSet(name string, kvs []string) (bool, error)
	MultiHGet(name string, keys []string) (map[string]string, error)
	MultiHDel(name string, keys []string) (bool, error)

	QPushFront(name, value string) (int64, error)
	QPushBack(name, value string) (int64, error)
	QPopFront(name string) (string, error)
	QPopBack(name string) (string, error)
	QSize(name string) (int64, error)
	QList(name_start, name_end string, limit int) ([]string, error)
	QRlist(name_start, name_end string, limit int) ([]string, error)
	QClear(name string) (bool, error)
	QFront(name string) (string, error)
	QBack(name string) (string, error)
	QGet(name string, index int64) (string, error)
	//  begin< index <=end
	QSlice(name string, begin, end int64) ([]string, error)
}

type Conn interface {
	//close the tcp connection
	Close() error
	//return non-nil value if the connection is broken
	Err() error
	//sends a command to the server and returns the received response
	Do(cmd string, args []interface{}) (rsp []bytes.Buffer, err error)
	//sends a command to the server
	Send(cmd string, args []interface{}) error
	//flushes the output buffer to the server
	Flush() error
	//receives a single reply from server
	Receive() (rsp []bytes.Buffer, err error)
}

type DBWrapper struct {
	*SSDB
	// contains filtered or unexported fields
}

type Error string

type PoolConfig struct {
	Host               string
	Port               int
	Initial_conn_count int
	Max_idle_count     int
	Max_conn_count     int
	CheckOnGet         bool
}

type SSDB struct {
	// contains filtered or unexported fields
}

type SSDBPool struct {
	// contains filtered or unexported fields
}