cache

package

v0.0.0-...-8e0263b Latest Latest Go to latest Published: Apr 15, 2023 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/khgame/memstore

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Init(addr string)
func IsRedisNil(err error) bool
type Cache
type H
type Prefix
type SingleFlight
- func SingleFlightAPI() SingleFlight
- func (sf SingleFlight) Get(ctx context.Context, key string) (string, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrShotLimits = errors.New("error shot limits")
	ErrTypeError  = errors.New("wrong type")
)

View Source

var (
	MaxRetries       = 3
	DialTimeout      = 100 * time.Millisecond
	ReadWriteTimeout = 100 * time.Millisecond
	PoolSize         = 200
	PoolTimeout      = 100 * time.Millisecond
	IdleTimeout      = 60 * time.Minute
)

Functions ¶

func Init ¶

func Init(addr string)

func IsRedisNil ¶

func IsRedisNil(err error) bool

Types ¶

type Cache ¶

type Cache struct {
	*redis.Client
}

func Client ¶

func Client() *Cache

func NewClient ¶

func NewClient(addr string) *Cache

func NewClientByRedisCli ¶

func NewClientByRedisCli(cli *redis.Client) *Cache

func NewPrefixedCli ¶

func NewPrefixedCli(prefix string) *Cache

func (*Cache) BatchGet ¶

func (cli *Cache) BatchGet(ctx context.Context, shotLimit int, keys ...string) (valuesHit []string, keysMiss []string, err error)

func (*Cache) BatchSave ¶

func (cli *Cache) BatchSave(ctx context.Context, forEachReceiver func(fn func(key, v string) error) error, expiration time.Duration) error

BatchSave save data to redis in batch

func (*Cache) PipeGet ¶

func (cli *Cache) PipeGet(ctx context.Context, keys ...string) (valuesHit []string, keysMiss []string, err error)

PipeGet get values from redis by pipeline

func (*Cache) SingleFlightAPI ¶

func (cli *Cache) SingleFlightAPI() SingleFlight

SingleFlightAPI

 usage:
 ```go
    sf := cli.SingleFlightAPI()
	for _, k := range keys {
	   go ... sf.Get(ctx, k) ...
	}
 ```

type H ¶

type H map[string]any

type Prefix ¶

type Prefix string

func (Prefix) AssembleCMD ¶

func (p Prefix) AssembleCMD(cmd redis.Cmder) redis.Cmder

func (Prefix) ColonStr ¶

func (p Prefix) ColonStr() string

func (Prefix) DialHook ¶

func (p Prefix) DialHook(next redis.DialHook) redis.DialHook

func (Prefix) MakeKey ¶

func (p Prefix) MakeKey(key string) string

func (Prefix) ProcessHook ¶

func (p Prefix) ProcessHook(next redis.ProcessHook) redis.ProcessHook

func (Prefix) ProcessPipelineHook ¶

func (p Prefix) ProcessPipelineHook(next redis.ProcessPipelineHook) redis.ProcessPipelineHook

func (Prefix) String ¶

func (p Prefix) String() string

type SingleFlight ¶

type SingleFlight struct {
	*Cache
	// contains filtered or unexported fields
}

func SingleFlightAPI ¶

func SingleFlightAPI() SingleFlight

func (SingleFlight) Get ¶

func (sf SingleFlight) Get(ctx context.Context, key string) (string, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL