cache

type Driver ¶

type Driver interface {
	Load(ctx context.Context, m *sync.Map, key string, loader ResultLoader, arg OptionArg) (loadType LoadType, result Result, err error)
}

Driver loads value from m, if there is no cached value, call the loader to get value, and then stores it into m.

type HashFunc ¶

type HashFunc func(key string) int

HashFunc returns the hash value of the key.

var (
	SimpleHash HashFunc = func(key string) int {
		const max = 20
		n := len(key)
		if n > max {
			n = max
		}
		c := 0
		for i := 0; i < n; i++ {
			c += int(key[i])
		}
		return c
	}
)

type JSONResult ¶

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

JSONResult stores a JSON string.

func (r *JSONResult) JSON() (string, error)

func (r *JSONResult) Load(v interface{}) error

type LoadType ¶

type LoadType int

const (
	LoadNone LoadType = iota
	LoadOnCtx
	LoadCache
	LoadSource
)

type Loader ¶

type Loader func(ctx context.Context, key string) (interface{}, error)

Loader gets value from a background, such as Redis, MySQL, etc.

type Option ¶

type Option func(*OptionArg)

func ExpireAfterWrite(v time.Duration) Option

type OptionArg ¶

type OptionArg struct {
	ExpireAfterWrite time.Duration
}

type Result ¶

type Result interface {
	JSON() (string, error)
	Load(v interface{}) error
}

Result stores a value.

func NewJSONResult(v string) Result

func NewValueResult(v interface{}) Result

type ResultLoader ¶

type ResultLoader func(ctx context.Context, key string) (Result, error)

ResultLoader returns a wrapper for the source value of the key.

type Shardable ¶

type Shardable interface {
	Sharding(key string) *sync.Map
}

A Shardable cache can improve the performance of concurrency.

type Storage ¶

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

Storage is a Shardable cache implementation.

func NewStorage(size int, hash HashFunc) *Storage

func (s *Storage) Reset()

func (s *Storage) Sharding(key string) *sync.Map

type ValueResult ¶

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

ValueResult stores a `reflect.Value`.

func (r *ValueResult) JSON() (string, error)

func (r *ValueResult) Load(v interface{}) error