Documentation ¶
Index ¶
- Constants
- Variables
- func CallWithRetry(context *RequestContext, fn func() (interface{}, error)) (interface{}, error)
- func CheckKeySize(key []byte) error
- func CheckValueSize(value []byte) error
- type RequestContext
- type TxTikvHandler
- func (h *TxTikvHandler) AUTH(pwd string) error
- func (h *TxTikvHandler) CheckExpireAndDel(keys [][]byte) (bool, error)
- func (h *TxTikvHandler) DEL(keys [][]byte) (int, error)
- func (h *TxTikvHandler) EXPIRE(key []byte, btime []byte) (int, error)
- func (h *TxTikvHandler) EXPIREAT(key []byte, btime []byte) (int, error)
- func (h *TxTikvHandler) GET(key []byte) ([]byte, error)
- func (h *TxTikvHandler) HDEL(key []byte, args [][]byte) (int, error)
- func (h *TxTikvHandler) HGET(key []byte, field []byte) ([]byte, error)
- func (h *TxTikvHandler) HGETALL(key []byte) ([][]byte, error)
- func (h *TxTikvHandler) HINCRBY(key []byte, field []byte, step int) (int64, error)
- func (h *TxTikvHandler) HKEYS(key []byte) ([][]byte, error)
- func (h *TxTikvHandler) HLEN(key []byte) (int, error)
- func (h *TxTikvHandler) HMGET(key []byte, fields [][]byte) ([][]byte, error)
- func (h *TxTikvHandler) HMSET(args [][]byte) ([]byte, error)
- func (h *TxTikvHandler) HSET(key []byte, field []byte, value []byte) (int, error)
- func (h *TxTikvHandler) INCR(key []byte) (int64, error)
- func (h *TxTikvHandler) INCRBY(key []byte, step int) (int64, error)
- func (h *TxTikvHandler) INFO() ([]byte, error)
- func (h *TxTikvHandler) MGET(args [][]byte) ([][]byte, error)
- func (h *TxTikvHandler) MSET(args [][]byte) ([]byte, error)
- func (h *TxTikvHandler) NOAUTH() error
- func (h *TxTikvHandler) PING() ([]byte, error)
- func (h *TxTikvHandler) QUIT() ([]byte, error)
- func (h *TxTikvHandler) SET(key []byte, value []byte) ([]byte, error)
- func (h *TxTikvHandler) SETWITHTTL(key []byte, value []byte, ttl []byte) ([]byte, error)
- func (h *TxTikvHandler) TTL(key []byte) (int, error)
- type TxTikvInterface
Constants ¶
View Source
const ( MaxRetryCount int = 5 //max key size MaxKeySize int = 1024 * 3 //max value size MaxValueSize int = 1024 * 1024 * 5 )
Variables ¶
Functions ¶
func CallWithRetry ¶
func CallWithRetry(context *RequestContext, fn func() (interface{}, error)) (interface{}, error)
func CheckKeySize ¶
func CheckValueSize ¶
Types ¶
type RequestContext ¶
type RequestContext struct {
// contains filtered or unexported fields
}
type TxTikvHandler ¶
func (*TxTikvHandler) AUTH ¶
func (h *TxTikvHandler) AUTH(pwd string) error
func (*TxTikvHandler) CheckExpireAndDel ¶
func (h *TxTikvHandler) CheckExpireAndDel(keys [][]byte) (bool, error)
func (*TxTikvHandler) EXPIRE ¶
func (h *TxTikvHandler) EXPIRE(key []byte, btime []byte) (int, error)
func (*TxTikvHandler) EXPIREAT ¶
func (h *TxTikvHandler) EXPIREAT(key []byte, btime []byte) (int, error)
func (*TxTikvHandler) HMGET ¶
func (h *TxTikvHandler) HMGET(key []byte, fields [][]byte) ([][]byte, error)
func (*TxTikvHandler) INFO ¶
func (h *TxTikvHandler) INFO() ([]byte, error)
func (*TxTikvHandler) NOAUTH ¶
func (h *TxTikvHandler) NOAUTH() error
func (*TxTikvHandler) PING ¶
func (h *TxTikvHandler) PING() ([]byte, error)
func (*TxTikvHandler) QUIT ¶
func (h *TxTikvHandler) QUIT() ([]byte, error)
func (*TxTikvHandler) SETWITHTTL ¶
type TxTikvInterface ¶
Click to show internal directories.
Click to hide internal directories.