cache

Documentation

Index

• Variables
• type Cache
  • func NewMemLruCache(_ context.Context, size int) (Cache, error)
  • func NewSingleFlightCache(ctx context.Context, cacheTime time.Duration, fn SingleFlightFunc) (Cache, error)
• type MemLruCache
  • func (m *MemLruCache) Delete(_ context.Context, key string) (bool, error)
  • func (m *MemLruCache) Exist(_ context.Context, key string) (bool, error)
  • func (m *MemLruCache) Get(_ context.Context, key string) (interface{}, error)
  • func (m *MemLruCache) Set(ctx context.Context, key string, value interface{}) error
  • func (m *MemLruCache) SetEx(ctx context.Context, key string, value interface{}, expire time.Duration) error
• type RedisCache
  • func NewRedisCache(client *redis.Client) *RedisCache
  • func (s RedisCache) Delete(ctx context.Context, key string) (bool, error)
  • func (s RedisCache) Exist(ctx context.Context, key string) (bool, error)
  • func (s RedisCache) Get(ctx context.Context, key string) (interface{}, error)
  • func (s RedisCache) Set(ctx context.Context, key string, value interface{}) error
  • func (s RedisCache) SetEx(ctx context.Context, key string, value interface{}, expire time.Duration) error
• type SingleFlightCache
  • func (s *SingleFlightCache) Delete(_ context.Context, _ string) (bool, error)
  • func (s *SingleFlightCache) Exist(_ context.Context, _ string) (bool, error)
  • func (s *SingleFlightCache) Get(ctx context.Context, _ string) (interface{}, error)
  • func (s *SingleFlightCache) Set(_ context.Context, _ string, value interface{}) error
  • func (s *SingleFlightCache) SetEx(_ context.Context, _ string, value interface{}, expire time.Duration) error
• type SingleFlightFunc

Variables

var ErrorValueExpired = errors.New("cached value expired")

var ErrorValueExpiredOrNotExist = errors.New("cached value expired or not exist")

Types

type Cache

type Cache interface {
	Get(ctx context.Context, key string) (interface{}, error)
	Set(ctx context.Context, key string, value interface{}) error
	SetEx(ctx context.Context, key string, value interface{}, expire time.Duration) error
	Delete(ctx context.Context, key string) (bool, error)
	Exist(ctx context.Context, key string) (bool, error)
}

func NewMemLruCache

func NewMemLruCache(_ context.Context, size int) (Cache, error)

func NewSingleFlightCache

func NewSingleFlightCache(ctx context.Context, cacheTime time.Duration, fn SingleFlightFunc) (Cache, error)

type MemLruCache

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

func (*MemLruCache) Delete

func (m *MemLruCache) Delete(_ context.Context, key string) (bool, error)

func (*MemLruCache) Exist

func (m *MemLruCache) Exist(_ context.Context, key string) (bool, error)

func (*MemLruCache) Get

func (m *MemLruCache) Get(_ context.Context, key string) (interface{}, error)

func (*MemLruCache) Set

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

func (*MemLruCache) SetEx

func (m *MemLruCache) SetEx(ctx context.Context, key string, value interface{}, expire time.Duration) error

type RedisCache

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

func NewRedisCache

func NewRedisCache(client *redis.Client) *RedisCache

func (RedisCache) Delete

func (s RedisCache) Delete(ctx context.Context, key string) (bool, error)

func (RedisCache) Exist

func (s RedisCache) Exist(ctx context.Context, key string) (bool, error)

func (RedisCache) Get

func (s RedisCache) Get(ctx context.Context, key string) (interface{}, error)

func (RedisCache) Set

func (s RedisCache) Set(ctx context.Context, key string, value interface{}) error

func (RedisCache) SetEx

func (s RedisCache) SetEx(ctx context.Context, key string, value interface{}, expire time.Duration) error

type SingleFlightCache

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

func (*SingleFlightCache) Delete

func (s *SingleFlightCache) Delete(_ context.Context, _ string) (bool, error)

func (*SingleFlightCache) Exist

func (s *SingleFlightCache) Exist(_ context.Context, _ string) (bool, error)

func (*SingleFlightCache) Get

func (s *SingleFlightCache) Get(ctx context.Context, _ string) (interface{}, error)

func (*SingleFlightCache) Set

func (s *SingleFlightCache) Set(_ context.Context, _ string, value interface{}) error

func (*SingleFlightCache) SetEx

func (s *SingleFlightCache) SetEx(_ context.Context, _ string, value interface{}, expire time.Duration) error

type SingleFlightFunc

type SingleFlightFunc func(ctx context.Context) (data interface{}, err error)