redis

Documentation

Index

• type Client
  • func GetClient() *Client
  • func (c *Client) CreateDelayDoubleDelTask(ctx context.Context, key, delKey string)
  • func (c *Client) DLock(ctx context.Context, key string, expire time.Duration, f func())
  • func (c *Client) DelIfEquals(ctx context.Context, key string, value interface{})
  • func (c *Client) DoDelayDoubleDelTask(ctx context.Context, key string)
  • func (c *Client) ReadDataFromQueue(ctx context.Context, f func(queue, msg string), keys ...string)
  • func (c *Client) ReadDelayQueue(ctx context.Context, key string, handleMsg func(data *TaskItem))
  • func (c *Client) WriteDelayQueue(ctx context.Context, key string, dealTime int64, data interface{})
• type TaskItem

Types

type Client

type Client struct {
	redis.UniversalClient
}

func GetClient

func GetClient() *Client

GetClient get redis connection

func (*Client) CreateDelayDoubleDelTask

func (c *Client) CreateDelayDoubleDelTask(ctx context.Context, key, delKey string)

CreateDelayDoubleDelTask 创建延时删除任务，延时3-5s双删

func (*Client) DLock

func (c *Client) DLock(ctx context.Context, key string, expire time.Duration, f func())

DLock 分布式锁

func (*Client) DelIfEquals

func (c *Client) DelIfEquals(ctx context.Context, key string, value interface{})

DelIfEquals 删除key,value都相等的key

func (*Client) DoDelayDoubleDelTask

func (c *Client) DoDelayDoubleDelTask(ctx context.Context, key string)

DelayDoubleDel 执行延时任务延时3-5s双删

func (*Client) ReadDataFromQueue

func (c *Client) ReadDataFromQueue(ctx context.Context, f func(queue, msg string), keys ...string)

ReadDataFromQueue 阻塞读

func (*Client) ReadDelayQueue

func (c *Client) ReadDelayQueue(ctx context.Context, key string, handleMsg func(data *TaskItem))

ReadDelayQueue 读延时队列

func (*Client) WriteDelayQueue

func (c *Client) WriteDelayQueue(ctx context.Context, key string, dealTime int64, data interface{})

WriteDelayQueue 写延时队列

type TaskItem

type TaskItem struct {
	ID  string
	Msg interface{}
}

TaskItem 任务