store

Documentation

Index

• type Cache
  • func NewCache(cacheType Type, config *RawMessage, log logrus.FieldLogger) (Cache, error)
• type Config
  • func (c *Config) Validate() error
• type RawMessage
  • func (r *RawMessage) Unmarshal(v interface{}) error
  • func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error
• type Type

Types

type Cache

type Cache interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Type() string
	Get(ctx context.Context, key string) (*string, error)
	GetOrSet(ctx context.Context, key, value string, ttl time.Duration) (storedValue *string, retrieved bool, err error)
	GetAndDelete(ctx context.Context, key string) (deletedValue *string, exists bool, err error)
	Set(ctx context.Context, key, value string, ttl time.Duration) error
	Delete(ctx context.Context, key string) error
}

func NewCache

func NewCache(cacheType Type, config *RawMessage, log logrus.FieldLogger) (Cache, error)

type Config

type Config struct {
	Type Type `yaml:"type" default:"memory"`

	Config *RawMessage `yaml:"config"`
}

func (*Config) Validate

func (c *Config) Validate() error

type RawMessage

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

func (*RawMessage) Unmarshal

func (r *RawMessage) Unmarshal(v interface{}) error

func (*RawMessage) UnmarshalYAML

func (r *RawMessage) UnmarshalYAML(unmarshal func(interface{}) error) error

type Type

type Type string

const (
	TypeUnknown      Type = "unknown"
	TypeMemory       Type = memory.Type
	TypeRedisServer  Type = redisServer.Type
	TypeRedisCluster Type = redisCluster.Type
)