cache

Documentation

Index

• func FromExpiration(ctx context.Context) (time.Duration, bool)
• func FromKey(ctx context.Context) (string, bool)
• func FromTag(ctx context.Context) (string, bool)
• func NewExpiration(ctx context.Context, ttl time.Duration) context.Context
• func NewKey(ctx context.Context, key string) context.Context
• func NewTag(ctx context.Context, key string) context.Context
• func QueryDB(tx *gorm.DB)
• type Memory
  • func NewMemory(options ...Option) *Memory
  • func (m *Memory) Decrease(_ context.Context, key string) error
  • func (m *Memory) Del(_ context.Context, key string) error
  • func (m *Memory) Expire(_ context.Context, key string, dur time.Duration) error
  • func (m *Memory) Get(_ context.Context, key string) (string, error)
  • func (m *Memory) HashDel(_ context.Context, hk, key string) error
  • func (m *Memory) HashGet(_ context.Context, hk, key string) (string, error)
  • func (m *Memory) Increase(_ context.Context, key string) error
  • func (m *Memory) Initialize(tx *gorm.DB) error
  • func (*Memory) Name() string
  • func (m *Memory) Query(tx *gorm.DB)
  • func (m *Memory) QueryCache(ctx context.Context, key string, dest any) error
  • func (m *Memory) RemoveFromTag(ctx context.Context, tag string) error
  • func (m *Memory) SaveCache(ctx context.Context, key string, dest any, ttl time.Duration) error
  • func (m *Memory) SaveTagKey(ctx context.Context, tag, key string) error
  • func (m *Memory) Set(_ context.Context, key string, val any, expire time.Duration) error
  • func (*Memory) String() string
• type Message
  • func (m *Message) GetID() string
  • func (m *Message) GetPrefix() (prefix string)
  • func (m *Message) GetStream() string
  • func (m *Message) GetValues() map[string]interface{}
  • func (m *Message) SetID(id string)
  • func (m *Message) SetPrefix(prefix string)
  • func (m *Message) SetStream(stream string)
  • func (m *Message) SetValues(values map[string]interface{})
• type Option
  • func WithQueryCacheDuration(d time.Duration) Option
  • func WithQueryCacheKeys(keys ...string) Option
  • func WithQueryCachePrefix(prefix string) Option
• type Options
  • func DefaultOptions() Options
  • func (o *Options) HasKey(key string) bool
• type Redis
  • func NewRedis(client *redis.Client, options *redis.Options, opts ...Option) (*Redis, error)
  • func (r *Redis) Decrease(ctx context.Context, key string) error
  • func (r *Redis) Del(ctx context.Context, key string) error
  • func (r *Redis) Expire(ctx context.Context, key string, dur time.Duration) error
  • func (r *Redis) Get(ctx context.Context, key string) (string, error)
  • func (r *Redis) GetClient() *redis.Client
  • func (r *Redis) HashDel(ctx context.Context, hk, key string) error
  • func (r *Redis) HashGet(ctx context.Context, hk, key string) (string, error)
  • func (r *Redis) Increase(ctx context.Context, key string) error
  • func (r *Redis) Initialize(tx *gorm.DB) error
  • func (*Redis) Name() string
  • func (r *Redis) Query(tx *gorm.DB)
  • func (r *Redis) QueryCache(ctx context.Context, key string, dest any) error
  • func (r *Redis) RemoveFromTag(ctx context.Context, tag string) error
  • func (r *Redis) SaveCache(ctx context.Context, key string, dest any, ttl time.Duration) error
  • func (r *Redis) SaveTagKey(ctx context.Context, tag, key string) error
  • func (r *Redis) Set(ctx context.Context, key string, val interface{}, expire time.Duration) error
  • func (*Redis) String() string

Functions

func FromExpiration

func FromExpiration(ctx context.Context) (time.Duration, bool)

FromExpiration returns the expiration time from the context

func FromKey

func FromKey(ctx context.Context) (string, bool)

FromKey returns the key from the context

func FromTag

func FromTag(ctx context.Context) (string, bool)

FromTag returns the tag from the context

func NewExpiration

func NewExpiration(ctx context.Context, ttl time.Duration) context.Context

NewExpiration creates a new context with the given expiration time

func NewKey

func NewKey(ctx context.Context, key string) context.Context

NewKey creates a new context with the given key

func NewTag

func NewTag(ctx context.Context, key string) context.Context

NewTag creates a new context with the given tag

func QueryDB

func QueryDB(tx *gorm.DB)

Types

type Memory

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

func NewMemory

func NewMemory(options ...Option) *Memory

NewMemory memory模式

func (*Memory) Decrease

func (m *Memory) Decrease(_ context.Context, key string) error

func (*Memory) Del

func (m *Memory) Del(_ context.Context, key string) error

func (*Memory) Expire

func (m *Memory) Expire(_ context.Context, key string, dur time.Duration) error

func (*Memory) Get

func (m *Memory) Get(_ context.Context, key string) (string, error)

func (*Memory) HashDel

func (m *Memory) HashDel(_ context.Context, hk, key string) error

func (*Memory) HashGet

func (m *Memory) HashGet(_ context.Context, hk, key string) (string, error)

func (*Memory) Increase

func (m *Memory) Increase(_ context.Context, key string) error

func (*Memory) Initialize

func (m *Memory) Initialize(tx *gorm.DB) error

func (*Memory) Name

func (*Memory) Name() string

func (*Memory) Query

func (m *Memory) Query(tx *gorm.DB)

func (*Memory) QueryCache

func (m *Memory) QueryCache(ctx context.Context, key string, dest any) error

func (*Memory) RemoveFromTag

func (m *Memory) RemoveFromTag(ctx context.Context, tag string) error

func (*Memory) SaveCache

func (m *Memory) SaveCache(ctx context.Context, key string, dest any, ttl time.Duration) error

func (*Memory) SaveTagKey

func (m *Memory) SaveTagKey(ctx context.Context, tag, key string) error

func (*Memory) Set

func (m *Memory) Set(_ context.Context, key string, val any, expire time.Duration) error

func (*Memory) String

func (*Memory) String() string

type Message

type Message struct {
	redisqueue.Message
}

func (*Message) GetID

func (m *Message) GetID() string

func (*Message) GetPrefix

func (m *Message) GetPrefix() (prefix string)

func (*Message) GetStream

func (m *Message) GetStream() string

func (*Message) GetValues

func (m *Message) GetValues() map[string]interface{}

func (*Message) SetID

func (m *Message) SetID(id string)

func (*Message) SetPrefix

func (m *Message) SetPrefix(prefix string)

func (*Message) SetStream

func (m *Message) SetStream(stream string)

func (*Message) SetValues

func (m *Message) SetValues(values map[string]interface{})

type Option

type Option func(*Options)

func WithQueryCacheDuration

func WithQueryCacheDuration(d time.Duration) Option

WithQueryCacheDuration 设置缓存时间

func WithQueryCacheKeys

func WithQueryCacheKeys(keys ...string) Option

WithQueryCacheKeys 设置缓存key

func WithQueryCachePrefix

func WithQueryCachePrefix(prefix string) Option

WithQueryCachePrefix 设置缓存前缀

type Options

type Options struct {
	QueryCacheDuration time.Duration
	QueryCacheKeys     []string
	QueryCachePrefix   string
}

func DefaultOptions

func DefaultOptions() Options

func (*Options) HasKey

func (o *Options) HasKey(key string) bool

type Redis

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

Redis cache implement

func NewRedis

func NewRedis(client *redis.Client, options *redis.Options, opts ...Option) (*Redis, error)

NewRedis redis模式

func (*Redis) Decrease

func (r *Redis) Decrease(ctx context.Context, key string) error

func (*Redis) Del

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

Del delete key in redis

func (*Redis) Expire

func (r *Redis) Expire(ctx context.Context, key string, dur time.Duration) error

Expire Set ttl

func (*Redis) Get

func (r *Redis) Get(ctx context.Context, key string) (string, error)

Get from key

func (*Redis) GetClient

func (r *Redis) GetClient() *redis.Client

GetClient 暴露原生client

func (*Redis) HashDel

func (r *Redis) HashDel(ctx context.Context, hk, key string) error

HashDel delete key in specify redis's hashtable

func (*Redis) HashGet

func (r *Redis) HashGet(ctx context.Context, hk, key string) (string, error)

HashGet from key

func (*Redis) Increase

func (r *Redis) Increase(ctx context.Context, key string) error

Increase key's value

func (*Redis) Initialize

func (r *Redis) Initialize(tx *gorm.DB) error

func (*Redis) Name

func (*Redis) Name() string

func (*Redis) Query

func (r *Redis) Query(tx *gorm.DB)

func (*Redis) QueryCache

func (r *Redis) QueryCache(ctx context.Context, key string, dest any) error

func (*Redis) RemoveFromTag

func (r *Redis) RemoveFromTag(ctx context.Context, tag string) error

func (*Redis) SaveCache

func (r *Redis) SaveCache(ctx context.Context, key string, dest any, ttl time.Duration) error

func (*Redis) SaveTagKey

func (r *Redis) SaveTagKey(ctx context.Context, tag, key string) error

func (*Redis) Set

func (r *Redis) Set(ctx context.Context, key string, val interface{}, expire time.Duration) error

Set value with key and expire time

func (*Redis) String

func (*Redis) String() string