redis

package

v1.224.0 Latest Latest Go to latest Published: Jun 5, 2024 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func GetObjectByKey[T any](redisClient *ClientWithHelpers, key string, object T) *T

type ClientWithHelpers struct {
	Client    *redis.Client
	Available bool
}

func GetRedisClient(isDebug bool) *ClientWithHelpers

func NewClient(addr string) *ClientWithHelpers

func (r ClientWithHelpers) DeleteByKey(key string) error

func (r ClientWithHelpers) DeleteByKeyPattern(pattern string)

func (r ClientWithHelpers) GetValueByKey(key string) string

func (r ClientWithHelpers) IsConnected() bool

func (r ClientWithHelpers) KeepLockKeyAlive(key string, expiration time.Duration)

func (r ClientWithHelpers) RateLimit(key string, limitFn func(int) redis_rate.Limit, limit int) (bool, error)

func (r ClientWithHelpers) SetLockKey(key string, expiration time.Duration, lockOptions ...SetLockKeyOptions) (success bool, err error)

SetLockKey attempts to set a lock on the specified key.

func (r ClientWithHelpers) SetObjectByKey(key string, object interface{})

func (r ClientWithHelpers) SetObjectByKeyIndefinitely(key string, object interface{})

func (r ClientWithHelpers) SetObjectByKeyWithExpiry(key string, object interface{}, expiration time.Duration)

type SetLockKeyOptions struct {
	Value          *string
	MaxRetries     *int
	RetryInterval  *time.Duration
	FallbackResult *bool
}