cache

package

v1.14.0 Latest Latest Go to latest Published: Nov 20, 2025 License: MIT Imports: 12 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

gitlab.com/wolfine/libs/app

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type Buffer
type HashBuffer
type Redis
- func Create(rdb rueidis.Client) *Redis
type RedisCache
- func NewRedisMock() RedisCache

Constants ¶

View Source

const DefaultHasherSize = 40

Variables ¶

View Source

var (
	ErrCacheMiss      = errors.New("cache miss")
	ErrNotInitialized = errors.New("cache not initialized")
)

Functions ¶

This section is empty.

Types ¶

type Buffer ¶ added in v1.8.0

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

func (*Buffer) Cap ¶ added in v1.8.0

func (b *Buffer) Cap() int

func (*Buffer) Grow ¶ added in v1.8.0

func (b *Buffer) Grow(n int)

func (*Buffer) Reset ¶ added in v1.8.0

func (b *Buffer) Reset()

func (*Buffer) String ¶ added in v1.8.0

func (b *Buffer) String() string

func (*Buffer) Write ¶ added in v1.8.0

func (b *Buffer) Write(p []byte) (int, error)

func (*Buffer) WriteByte ¶ added in v1.8.0

func (b *Buffer) WriteByte(c byte)

func (*Buffer) WriteDelimiter ¶ added in v1.8.2

func (b *Buffer) WriteDelimiter()

func (*Buffer) WriteHash ¶ added in v1.8.0

func (b *Buffer) WriteHash(data string)

func (*Buffer) WriteMapHash ¶ added in v1.8.0

func (b *Buffer) WriteMapHash(data map[string]string)

func (*Buffer) WriteRune ¶ added in v1.8.0

func (b *Buffer) WriteRune(r rune)

func (*Buffer) WriteString ¶ added in v1.8.0

func (b *Buffer) WriteString(s string)

func (*Buffer) WriteUUID ¶ added in v1.8.0

func (b *Buffer) WriteUUID(id uuid.UUID)

type HashBuffer ¶ added in v1.8.0

type HashBuffer interface {
	WriteUUID(uuid.UUID)
	WriteString(string)
	WriteByte(byte)
	WriteRune(rune)
	Write([]byte) (int, error)
	WriteHash(string)
	WriteMapHash(map[string]string)
	WriteDelimiter()
	String() string
	Cap() int
	Grow(n int)
	Reset()
}

type Redis ¶

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

func Create ¶ added in v1.12.0

func Create(rdb rueidis.Client) *Redis

func (*Redis) B ¶

func (c *Redis) B() rueidis.Builder

func (*Redis) Check ¶ added in v1.12.0

func (c *Redis) Check(ctx context.Context) error

func (*Redis) Close ¶

func (c *Redis) Close(_ context.Context) error

func (*Redis) Delete ¶ added in v1.1.0

func (c *Redis) Delete(ctx context.Context, key string) error

func (*Redis) Do ¶

func (c *Redis) Do(ctx context.Context, cmd rueidis.Completed) rueidis.RedisResult

func (*Redis) DoCache ¶

func (c *Redis) DoCache(ctx context.Context, cmd rueidis.Cacheable, duration time.Duration) rueidis.RedisResult

func (*Redis) DoMulti ¶

func (c *Redis) DoMulti(ctx context.Context, cmds ...rueidis.Completed) []rueidis.RedisResult

func (*Redis) Get ¶ added in v1.1.0

func (c *Redis) Get(
	ctx context.Context,
	key string,
	target msgp.Decodable,
	duration ...time.Duration,
) (err error)

func (*Redis) GetBuffer ¶

func (c *Redis) GetBuffer() HashBuffer

func (*Redis) GetString ¶ added in v1.5.0

func (c *Redis) GetString(ctx context.Context, key string, duration ...time.Duration) (result string, err error)

func (*Redis) PutBuffer ¶

func (c *Redis) PutBuffer(buf HashBuffer)

func (*Redis) Raw ¶

func (c *Redis) Raw() rueidis.Client

func (*Redis) Set ¶ added in v1.1.0

func (c *Redis) Set(ctx context.Context, key string, value msgp.Encodable, duration time.Duration) (err error)

func (*Redis) SetString ¶ added in v1.5.0

func (c *Redis) SetString(ctx context.Context, key string, value string, duration time.Duration) error

func (*Redis) Upstream ¶ added in v1.12.0

func (c *Redis) Upstream(rdb rueidis.Client)

type RedisCache ¶

type RedisCache interface {
	Raw() rueidis.Client
	B() rueidis.Builder
	Do(ctx context.Context, cmd rueidis.Completed) rueidis.RedisResult
	DoCache(ctx context.Context, cmd rueidis.Cacheable, duration time.Duration) rueidis.RedisResult
	DoMulti(ctx context.Context, cmds ...rueidis.Completed) []rueidis.RedisResult
	GetBuffer() HashBuffer
	PutBuffer(buf HashBuffer)
	Get(ctx context.Context, key string, target msgp.Decodable, duration ...time.Duration) error
	GetString(ctx context.Context, key string, duration ...time.Duration) (string, error)
	Delete(ctx context.Context, key string) error
	Set(ctx context.Context, key string, value msgp.Encodable, duration time.Duration) error
	SetString(ctx context.Context, key string, value string, duration time.Duration) error
}

func NewRedisMock ¶ added in v1.14.0

func NewRedisMock() RedisCache

Source Files ¶

View all Source files

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