hybrid

package

v1.0.7 Latest Latest Go to latest Published: Jun 10, 2024 License: MIT Imports: 10 Imported by: 1

Details

This section is empty.

View Source

var (
	ErrLocalCacheIsNotInitialised = errors.New("local cache is not initialised")
)

This section is empty.

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

func NewHybridCacher(config HybridOptions) (*HybridCacher, error)

func (c *HybridCacher) Bytes(
	ctx context.Context,
	key string,
) (bytes []byte, err error)

func (c *HybridCacher) BytesMany(ctx context.Context, keys ...string) (result map[string][]byte, err error)

BytesMany implements cache.Cacher

func (c *HybridCacher) Close() error

Close implements cache.Cacher

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

Delete implements cache.Cacher

func (c *HybridCacher) DeleteMany(ctx context.Context, keys ...string) (err error)

DeleteMany implements cache.Cacher

func (c *HybridCacher) Errors() <-chan error

func (c *HybridCacher) Exists(
	ctx context.Context,
	key string,
) (bool, error)

Exists implements cache.Cacher

func (c *HybridCacher) Identity() uuid.UUID

func (c *HybridCacher) Local() cache.Cacher

func (c *HybridCacher) Redis() *redis.RedisCacher

func (c *HybridCacher) Set(
	ctx context.Context,
	key string,
	bytes []byte,
	duration time.Duration,
) error

Set implements cache.Cacher

func (c *HybridCacher) SetMany(ctx context.Context, items map[string][]byte) (err error)

SetMany implements cache.Cacher

func (c *HybridCacher) SetManyExp(ctx context.Context, items map[string][]byte, duration time.Duration) (err error)

SetManyExp implements cache.Cacher

type HybridEvictCallback func(keys ...string)

type HybridOptions struct {
	Topic         string
	RedisCacher   *redis.RedisCacher
	LocalCache    cache.Cacher
	EvictCallback HybridEvictCallback
}