redis

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(ctx context.Context, namespace string) (*Client, error)
  • func (m *Client) Close() error
  • func (m *Client) Del(keys ...string) *redis.IntCmd
  • func (m *Client) Get(key string) *redis.StringCmd
  • func (m *Client) Incr(key string) *redis.IntCmd
  • func (m *Client) Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd
  • func (m *Client) SetNX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd
• type Config
• type Configer
  • func NewConfiger(configType int) (Configer, error)
  • func NewEtcdConfiger() Configer
  • func NewSimpleConfiger() Configer
• type EtcdConfig
  • func (m *EtcdConfig) GetConfig(ctx context.Context, namespace string) *Config
• type InstanceManager
  • func NewInstanceManager() *InstanceManager
  • func (m *InstanceManager) Close()
  • func (m *InstanceManager) GetInstance(ctx context.Context, namespace string) *Client
• type SimpleConfig
  • func (m *SimpleConfig) GetConfig(ctx context.Context, namespace string) *Config

Constants

const (
	CONFIG_TYPE_SIMPLE = iota
	CONFIG_TYPE_ETCD
)

Variables

var DefaultConfiger = NewSimpleConfiger()

var DefaultInstanceManager = NewInstanceManager()

var RedisNil = fmt.Sprintf("redis: nil")

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, namespace string) (*Client, error)

func (*Client) Close

func (m *Client) Close() error

func (*Client) Del

func (m *Client) Del(keys ...string) *redis.IntCmd

func (*Client) Get

func (m *Client) Get(key string) *redis.StringCmd

func (*Client) Incr

func (m *Client) Incr(key string) *redis.IntCmd

func (*Client) Set

func (m *Client) Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd

func (*Client) SetNX

func (m *Client) SetNX(key string, value interface{}, expiration time.Duration) *redis.BoolCmd

type Config

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

type Configer

type Configer interface {
	GetConfig(ctx context.Context, namespace string) *Config
}

func NewConfiger

func NewConfiger(configType int) (Configer, error)

func NewEtcdConfiger

func NewEtcdConfiger() Configer

func NewSimpleConfiger

func NewSimpleConfiger() Configer

type EtcdConfig

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

func (*EtcdConfig) GetConfig

func (m *EtcdConfig) GetConfig(ctx context.Context, namespace string) *Config

type InstanceManager

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

func NewInstanceManager

func NewInstanceManager() *InstanceManager

func (*InstanceManager) Close

func (m *InstanceManager) Close()

func (*InstanceManager) GetInstance

func (m *InstanceManager) GetInstance(ctx context.Context, namespace string) *Client

type SimpleConfig

type SimpleConfig struct {
}

func (*SimpleConfig) GetConfig

func (m *SimpleConfig) GetConfig(ctx context.Context, namespace string) *Config