redis

Documentation

Index

• type RedisClient
  • func NewRedisClient(config *config.Config) (*RedisClient, error)
  • func (r *RedisClient) Increment(ctx context.Context, key string, increment int) error
• type RedisIface

Types

type RedisClient

type RedisClient struct {
	Client RedisIface
	Config *config.RedisConfig

	// Sliding Window
	Limit    int
	Excluded []string
	Period   time.Duration
	Window   time.Duration
}

func NewRedisClient

func NewRedisClient(config *config.Config) (*RedisClient, error)

func (*RedisClient) Increment

func (r *RedisClient) Increment(ctx context.Context, key string, increment int) error

type RedisIface

type RedisIface interface {
	HIncrBy(ctx context.Context, key, field string, incr int64) *redis.IntCmd
	HGetAll(ctx context.Context, key string) *redis.StringStringMapCmd
	HDel(ctx context.Context, key string, fields ...string) *redis.IntCmd
	Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
}