RedisKit

Redis工具包

Install

npm i @4a/rediskit

Usage

// redis client需支持promise, 推荐使用ioredis
const redis = require('ioredis')()
const { Stock, Increment } = require('@4a/rediskit')(redis)

Stock

基于Redis简单的队列操作

Stock.init('app:stock:apple')
Stock.init('app:stock', apple)
Stock.init('app:stock', apple, 'price', ...)


const stock = Stock.init('app:stock:apple', id)

await stock.get()
await stock.set(arr, time)
await stock.save(arr, time)

await stock.prepend(item)
await stock.append(item)
await stock.pop()
await stock.shift()
await stock.remove(item)
await stock.remove(item => item.type === 1)

await stock.find(callback)
await stock.findIndex(callback)

await stock.map(callback)
await stock.each(callback)
await stock.slice(start, end)

await stock.clear()
await stock.expire()
await stock.expire(60)

Increment API

基于Redis.incr的安全计数

Increment.init('app:incr:apple')
Increment.init('app:stock', apple, 'price', ...)

const increment = Increment.init('app:stock:apple', id)

await increment.isRepeat()
await increment.isNotRepeat()

await increment.isOutRange(10)
await increment.isInRange(10)
await increment.isInRange(10, 3)

await increment.increment()
await increment.decrement()

await increment.clear()
await increment.expire()
await increment.expire(60)

  Example

npm test