redis

Documentation

Index

• Constants
• func Init()
• type Client
  • func NewClient(address string, password string, db int) (Client, error)
  • func (client *Client) Del(ctx context.Context, key string)
  • func (client *Client) Get(ctx context.Context, key string) *redis.StringCmd
  • func (client *Client) ObtainLock(key string, expiration time.Duration) error
  • func (client *Client) Publish(ctx context.Context, channel string, message interface{}) error
  • func (client *Client) ReleaseLock(key string)
  • func (client *Client) Set(ctx context.Context, key string, value interface{}, expiration time.Duration)
  • func (client *Client) Subscribe(ctx context.Context, channels ...string) *redis.PubSub

Constants

const (
	// user session key, param is sid
	KEY_USER_SESSION = "app:session:%s"
	// key for insert user lock to prevent concurrent insert, first param is email, second is username
	KEY_INSERT_USER_LOCK = "app:i:u:lock:%s:%s"
)

Functions

func Init

func Init()

Types

type Client

type Client redis.Client

var Cli Client

func NewClient

func NewClient(address string, password string, db int) (Client, error)

func (*Client) Del

func (client *Client) Del(ctx context.Context, key string)

func (*Client) Get

func (client *Client) Get(ctx context.Context, key string) *redis.StringCmd

func (*Client) ObtainLock

func (client *Client) ObtainLock(key string, expiration time.Duration) error

func (*Client) Publish

func (client *Client) Publish(ctx context.Context, channel string, message interface{}) error

func (*Client) ReleaseLock

func (client *Client) ReleaseLock(key string)

func (*Client) Set

func (client *Client) Set(ctx context.Context, key string, value interface{}, expiration time.Duration)

func (*Client) Subscribe

func (client *Client) Subscribe(ctx context.Context, channels ...string) *redis.PubSub