strategies

Documentation

Index

• type Storage
• type WriteBehindCache
  • func NewWriteBehindCache(cache *distributed.RedisClusterCache, storage Storage, ...) *WriteBehindCache
  • func (c *WriteBehindCache) Set(ctx context.Context, key string, value interface{}) error
• type WriteThroughCache
  • func NewWriteThroughCache(cache *distributed.RedisClusterCache, storage Storage, tracer tracing.Tracer, ...) *WriteThroughCache
  • func (c *WriteThroughCache) Get(ctx context.Context, key string) (interface{}, error)
  • func (c *WriteThroughCache) Set(ctx context.Context, key string, value interface{}) error

Types

type Storage

type Storage interface {
	Set(ctx context.Context, key string, value interface{}) error
	Get(ctx context.Context, key string) (interface{}, error)
}

type WriteBehindCache

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

func NewWriteBehindCache

func NewWriteBehindCache(
	cache *distributed.RedisClusterCache,
	storage Storage,
	metrics *metrics.DetailedStorageMetrics,
	tracer tracing.Tracer,
	batchSize int,
	batchDelay time.Duration,
) *WriteBehindCache

func (*WriteBehindCache) Set

func (c *WriteBehindCache) Set(ctx context.Context, key string, value interface{}) error

type WriteThroughCache

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

func NewWriteThroughCache

func NewWriteThroughCache(
	cache *distributed.RedisClusterCache,
	storage Storage,
	tracer tracing.Tracer,
	expiration time.Duration,
) *WriteThroughCache

func (*WriteThroughCache) Get

func (c *WriteThroughCache) Get(ctx context.Context, key string) (interface{}, error)

func (*WriteThroughCache) Set

func (c *WriteThroughCache) Set(ctx context.Context, key string, value interface{}) error