cache

Documentation

Index

• Variables
• func NewRedisClient(logger *zap.Logger) *redis.Client
• type Cache
  • func New[T any]() *Cache[T]
  • func NewWithTimeout[T any](dur time.Duration) *Cache[T]
  • func (ct *Cache[T]) Get(key string) (T, bool)
  • func (ct *Cache[T]) Set(key string, value T)
• type CacheProvider
  • func NewCacheProvider[T any](t time.Duration) CacheProvider[T]
• type RedisConfig
• type RedisProvider
  • func (r *RedisProvider[T]) Get(key string) (T, bool)
  • func (r *RedisProvider[T]) Set(key string, value T)

Variables

var DefaultTimeout time.Duration = 30 * time.Minute

Functions

func NewRedisClient

func NewRedisClient(logger *zap.Logger) *redis.Client

Types

type Cache

type Cache[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any]() *Cache[T]

func NewWithTimeout

func NewWithTimeout[T any](dur time.Duration) *Cache[T]

func (*Cache[T]) Get

func (ct *Cache[T]) Get(key string) (T, bool)

func (*Cache[T]) Set

func (ct *Cache[T]) Set(key string, value T)

type CacheProvider

type CacheProvider[T any] interface {
	Set(key string, value T)
	Get(key string) (T, bool)
}

func NewCacheProvider

func NewCacheProvider[T any](t time.Duration) CacheProvider[T]

type RedisConfig

type RedisConfig struct {
	Host    string
	Port    uint
	Account string
	Passwd  string
	Caroot  string // where is the ca pem file.
	Tls     bool   //TLS enabled ?
	DB      int    // 0: dev, 1: uat, 3: prd
}

type RedisProvider

type RedisProvider[T any] struct {
	// contains filtered or unexported fields
}

func (*RedisProvider[T]) Get

func (r *RedisProvider[T]) Get(key string) (T, bool)

Get implements CacheProvider.

func (*RedisProvider[T]) Set

func (r *RedisProvider[T]) Set(key string, value T)

Set implements CacheProvider.