redis

README

Redis Cache (preview)

This plugin designed to support Redis cache.

How to use

Build

./answer build --with github.com/apache/incubator-answer-plugins/cache-redis

Configuration

• Endpoint - Redis connection address

Documentation

Index

• Variables
• type Cache
  • func (c *Cache) ConfigFields() []plugin.ConfigField
  • func (c *Cache) ConfigReceiver(config []byte) error
  • func (c *Cache) Decrease(ctx context.Context, key string, value int64) (data int64, err error)
  • func (c *Cache) Del(ctx context.Context, key string) error
  • func (c *Cache) Flush(ctx context.Context) error
  • func (c *Cache) GetInt64(ctx context.Context, key string) (data int64, exist bool, err error)
  • func (c *Cache) GetString(ctx context.Context, key string) (data string, exist bool, err error)
  • func (c *Cache) Increase(ctx context.Context, key string, value int64) (data int64, err error)
  • func (c *Cache) Info() plugin.Info
  • func (c *Cache) SetInt64(ctx context.Context, key string, value int64, ttl time.Duration) error
  • func (c *Cache) SetString(ctx context.Context, key, value string, ttl time.Duration) error
• type CacheConfig

Variables

var (

	//go:embed  info.yaml
	Info embed.FS
)

Types

type Cache

type Cache struct {
	Config      *CacheConfig
	RedisClient *redis.Client
}

func (*Cache) ConfigFields

func (c *Cache) ConfigFields() []plugin.ConfigField

func (*Cache) ConfigReceiver

func (c *Cache) ConfigReceiver(config []byte) error

func (*Cache) Decrease

func (c *Cache) Decrease(ctx context.Context, key string, value int64) (data int64, err error)

func (*Cache) Del

func (c *Cache) Del(ctx context.Context, key string) error

func (*Cache) Flush

func (c *Cache) Flush(ctx context.Context) error

func (*Cache) GetInt64

func (c *Cache) GetInt64(ctx context.Context, key string) (data int64, exist bool, err error)

func (*Cache) GetString

func (c *Cache) GetString(ctx context.Context, key string) (data string, exist bool, err error)

func (*Cache) Increase

func (c *Cache) Increase(ctx context.Context, key string, value int64) (data int64, err error)

func (*Cache) Info

func (c *Cache) Info() plugin.Info

func (*Cache) SetInt64

func (c *Cache) SetInt64(ctx context.Context, key string, value int64, ttl time.Duration) error

func (*Cache) SetString

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

type CacheConfig

type CacheConfig struct {
	Endpoint string `json:"endpoint"`
	Username string `json:"username"`
	Password string `json:"password"`
}