cluster

Documentation

Index

• Constants
• type Cluster
  • func New(config *Config, log logrus.FieldLogger) (*Cluster, error)
  • func (c *Cluster) Delete(ctx context.Context, key string) error
  • func (c *Cluster) Get(ctx context.Context, key string) (*string, error)
  • func (c *Cluster) GetAndDelete(ctx context.Context, key string) (deletedValue *string, exists bool, err error)
  • func (c *Cluster) GetOrSet(ctx context.Context, key, value string, ttl time.Duration) (storedValue *string, retrieved bool, err error)
  • func (c *Cluster) Set(ctx context.Context, key, value string, ttl time.Duration) error
  • func (c *Cluster) Start(ctx context.Context) error
  • func (c *Cluster) Stop(ctx context.Context) error
  • func (c *Cluster) Type() string
• type Config
  • func (c *Config) Validate() error
• type Metrics
  • func NewMetrics(namespace string) *Metrics
  • func (m *Metrics) AddDelete(count int, cacheType, status string)
  • func (m *Metrics) AddGet(count int, cacheType, status string)
  • func (m *Metrics) AddSet(count int, cacheType, status string)

Constants

const Type = "redis-cluster"

Types

type Cluster

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

func New

func New(config *Config, log logrus.FieldLogger) (*Cluster, error)

func (*Cluster) Delete

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

func (*Cluster) Get

func (c *Cluster) Get(ctx context.Context, key string) (*string, error)

func (*Cluster) GetAndDelete

func (c *Cluster) GetAndDelete(ctx context.Context, key string) (deletedValue *string, exists bool, err error)

func (*Cluster) GetOrSet

func (c *Cluster) GetOrSet(ctx context.Context, key, value string, ttl time.Duration) (storedValue *string, retrieved bool, err error)

func (*Cluster) Set

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

func (*Cluster) Start

func (c *Cluster) Start(ctx context.Context) error

func (*Cluster) Stop

func (c *Cluster) Stop(ctx context.Context) error

func (*Cluster) Type

func (c *Cluster) Type() string

type Config

type Config struct {
	Address string `yaml:"address" default:"redis://localhost:6379/0"`
	Prefix  string `yaml:"prefix" default:"xatu"`
}

func (*Config) Validate

func (c *Config) Validate() error

type Metrics

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

func NewMetrics

func NewMetrics(namespace string) *Metrics

func (*Metrics) AddDelete

func (m *Metrics) AddDelete(count int, cacheType, status string)

func (*Metrics) AddGet

func (m *Metrics) AddGet(count int, cacheType, status string)

func (*Metrics) AddSet

func (m *Metrics) AddSet(count int, cacheType, status string)