cache

package

v0.0.0-...-9941648 Latest Latest Go to latest Published: Jan 28, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func NewRedisCli(r RedisOptions) *redis.Client

func NewRedisClusterCli(r RedisClusterOptions) *redis.ClusterClient

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

func NewBloomFilter(client *redis.Client, key string, errorRate float64, capacity int) *BloomFilter

尽量选大质数（素数）（如 10007、100003）

func (bf *BloomFilter) Add(ctx context.Context, value string) error

func (bf *BloomFilter) Exists(ctx context.Context, value string) error

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

func NewDistributedLock(client *redis.Client, key string, value string, expiration time.Duration) *DistributedLock

func (dl *DistributedLock) TryLock(ctx context.Context) error

func (dl *DistributedLock) Unlock(ctx context.Context) error

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

TODO

type RedisClusterOptions struct {
	Addrs []string
}

type RedisOptions struct {
	Addr     string
	Password string
	DB       int
}

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

func NewTokenBucket(client *redis.Client, key string, capacity int64, rate float64) *TokenBucket

func (tb *TokenBucket) Decrease(ctx context.Context, tokens int64) error