cache

Documentation

Index

• Constants
• Variables
• func OptionArgs(args *RedisOptions)
• func RedisMutexContext(ctx context.Context) context.Context
• func ToRedis(cache bank.Cache) *redis.Client
• type Lock
  • func LockAccount(ctx context.Context, accountID uint64) (Lock, error)
  • func LockChain(ctx context.Context, chain string) (Lock, error)
  • func LockUser(ctx context.Context, userID uint64) (Lock, error)
• type Mutex
  • func NewRedisMutex(ctx context.Context) Mutex
  • func RedisMutexFromContext(ctx context.Context) Mutex
• type Redis
  • func NewRedis(ctx context.Context, options RedisOptions) *Redis
  • func (r *Redis) RDB() bank.RDB
• type RedisLock
  • func (p *RedisLock) Unlock()
• type RedisMutex
  • func (p *RedisMutex) Lock(ctx context.Context, key string, ttl time.Duration) (Lock, error)
• type RedisOptions

Constants

const (
	DefaultLockTTL = 30 * time.Second

	MinimumLockTTL = 100 * time.Millisecond
	MaximumLockTTL = 5 * time.Minute
)

const (
	RedisLockerKey = "Key.RedisLockerKey"
)

Variables

var (
	ErrRedisMutexNotFound = errors.New("RedisMutex Not Found")
	ErrLockError          = errors.New("Failed to acquire lock")
)

var (
	ErrInternalError = errors.New("InternalError")
)

Functions

func OptionArgs

func OptionArgs(args *RedisOptions)

func RedisMutexContext

func RedisMutexContext(ctx context.Context) context.Context

func ToRedis

func ToRedis(cache bank.Cache) *redis.Client

Types

type Lock

type Lock interface {
	Unlock()
}

func LockAccount

func LockAccount(ctx context.Context, accountID uint64) (Lock, error)

func LockChain

func LockChain(ctx context.Context, chain string) (Lock, error)

func LockUser

func LockUser(ctx context.Context, userID uint64) (Lock, error)

type Mutex

type Mutex interface {
	Lock(ctx context.Context, key string, ttl time.Duration) (Lock, error)
}

func NewRedisMutex

func NewRedisMutex(ctx context.Context) Mutex

func RedisMutexFromContext

func RedisMutexFromContext(ctx context.Context) Mutex

type Redis

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

func NewRedis

func NewRedis(ctx context.Context, options RedisOptions) *Redis

func (*Redis) RDB

func (r *Redis) RDB() bank.RDB

type RedisLock

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

func (*RedisLock) Unlock

func (p *RedisLock) Unlock()

type RedisMutex

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

func (*RedisMutex) Lock

func (p *RedisMutex) Lock(ctx context.Context, key string, ttl time.Duration) (Lock, error)

type RedisOptions

type RedisOptions struct {
	bank.ServerOptions
}