cache

README

Cache

Usage Example

package main

import (
	"context"
	"log"
	"time"

	"github.com/redis/go-redis/v9"

	"github.com/go-kratos-ecosystem/components/v2/cache"
	redisStore "github.com/go-kratos-ecosystem/components/v2/cache/redis"
)

var ctx = context.Background()

type User struct {
	Name string
	Age  int
}

func main() {
	// 创建个 Redis 连接客户端
	rdb := redis.NewClient(&redis.Options{
		Addr: "localhost:6379",
	})
	defer rdb.Close()

	// create a redis store
	store := redisStore.New(rdb, redisStore.Prefix("example:cache"))

	// create a cache repository
	repository := cache.NewRepository(store)

	// set cache
	ok, err := repository.Set(ctx, "key", User{
		Name: "example",
		Age:  18,
	}, time.Second*10)
	if err != nil {
		log.Fatal(err)
	}
	_ = ok

	// get cache
	var user User
	err = repository.Get(ctx, "key", &user)
	if err != nil {
		log.Fatal(err)
	}

	log.Printf("user: %+v", user)
}

Documentation

Index

• type Addable
• type Locker
• type Manager
  • func NewManager(repository Repository) *Manager
  • func (m *Manager) Driver(names ...string) Repository
  • func (m *Manager) Register(name string, repository Repository)
• type NullStore
  • func (n *NullStore) Decrement(context.Context, string, int) (int, error)
  • func (n *NullStore) Flush(context.Context) (bool, error)
  • func (n *NullStore) Forever(context.Context, string, any) (bool, error)
  • func (n *NullStore) Forget(context.Context, string) (bool, error)
  • func (n *NullStore) Get(context.Context, string, any) error
  • func (n *NullStore) GetPrefix() string
  • func (n *NullStore) Has(context.Context, string) (bool, error)
  • func (n *NullStore) Increment(context.Context, string, int) (int, error)
  • func (n *NullStore) Lock(string, time.Duration) locker.Locker
  • func (n *NullStore) Put(context.Context, string, any, time.Duration) (bool, error)
• type Repository
  • func NewRepository(store Store) Repository
• type Store

Types

type Addable

type Addable interface {
	Add(ctx context.Context, key string, value any, ttl time.Duration) (bool, error)
}

type Locker

type Locker interface {
	Lock(key string, ttl time.Duration) locker.Locker
}

type Manager

type Manager struct {
	Repository
	// contains filtered or unexported fields
}

func NewManager

func NewManager(repository Repository) *Manager

func (*Manager) Driver

func (m *Manager) Driver(names ...string) Repository

func (*Manager) Register

func (m *Manager) Register(name string, repository Repository)

type NullStore

type NullStore struct{}

func (*NullStore) Decrement

func (n *NullStore) Decrement(context.Context, string, int) (int, error)

func (*NullStore) Flush

func (n *NullStore) Flush(context.Context) (bool, error)

func (*NullStore) Forever

func (n *NullStore) Forever(context.Context, string, any) (bool, error)

func (*NullStore) Forget

func (n *NullStore) Forget(context.Context, string) (bool, error)

func (*NullStore) Get

func (n *NullStore) Get(context.Context, string, any) error

func (*NullStore) GetPrefix

func (n *NullStore) GetPrefix() string

func (*NullStore) Has

func (n *NullStore) Has(context.Context, string) (bool, error)

func (*NullStore) Increment

func (n *NullStore) Increment(context.Context, string, int) (int, error)

func (*NullStore) Lock

func (n *NullStore) Lock(string, time.Duration) locker.Locker

func (*NullStore) Put

func (n *NullStore) Put(context.Context, string, any, time.Duration) (bool, error)

type Repository

type Repository interface {
	Store
	Addable

	Missing(ctx context.Context, key string) (bool, error)
	Delete(ctx context.Context, key string) (bool, error)
	Set(ctx context.Context, key string, value any, ttl time.Duration) (bool, error)
	Remember(ctx context.Context, key string, dest any, value func() any, ttl time.Duration) error
}

func NewRepository

func NewRepository(store Store) Repository

type Store

type Store interface {
	Locker

	Has(ctx context.Context, key string) (bool, error)

	Get(ctx context.Context, key string, dest any) error

	Put(ctx context.Context, key string, value any, ttl time.Duration) (bool, error)

	Increment(ctx context.Context, key string, value int) (int, error)

	Decrement(ctx context.Context, key string, value int) (int, error)

	Forever(ctx context.Context, key string, value any) (bool, error)

	Forget(ctx context.Context, key string) (bool, error)

	Flush(ctx context.Context) (bool, error)

	GetPrefix() string
}