services

package

v1.0.0 Latest Latest Go to latest Published: May 6, 2023 License: MIT Imports: 8 Imported by: 0

Details

View Source

const (
	NoneDuration = time.Duration(-1)
)

View Source

var ErrKeyNotFound = errors.New("key not found")

View Source

var ErrTypeNotOk = errors.New("val type not ok")

func NewRedisCache(params ...interface{}) (interface{}, error)

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

func (r *RedisCache) Calc(ctx context.Context, key string, step int64) (int64, error)

func (r *RedisCache) Decrement(ctx context.Context, key string) (int64, error)

func (r *RedisCache) Del(ctx context.Context, key string) error

func (r *RedisCache) DelMany(ctx context.Context, keys []string) error

func (r *RedisCache) GetMany(ctx context.Context, keys []string) (map[string]string, error)

func (r *RedisCache) GetObj(ctx context.Context, key string, model interface{}) error

GetObj 获取某个key对应的对象, 对象必须实现 https://pkg.go.dev/encoding#BinaryUnMarshaler

func (r *RedisCache) GetTTL(ctx context.Context, key string) (time.Duration, error)

func (r *RedisCache) Increment(ctx context.Context, key string) (int64, error)

func (r *RedisCache) Remember(ctx context.Context, key string, timeout time.Duration, rememberFucn contract.RememberFunc, obj interface{}) error

func (r *RedisCache) Set(ctx context.Context, key string, val string, timeout time.Duration) error

func (r *RedisCache) SetForever(ctx context.Context, key string, val string) error

func (r *RedisCache) SetForeverObj(ctx context.Context, key string, val interface{}) error

func (r *RedisCache) SetMany(ctx context.Context, data map[string]string, timeout time.Duration) error

func (r *RedisCache) SetObj(ctx context.Context, key string, val interface{}, timeout time.Duration) error

func (r *RedisCache) SetTTL(ctx context.Context, key string, timeout time.Duration) error