cache

Documentation

Index

• func Register(key string, impl ICache)
• type Configure
• type FactoryBean
  • func NewStarter() *FactoryBean
  • func (r *FactoryBean) GetBean() (bean.Bean, error)
  • func (r *FactoryBean) GetBeanType() reflect.Type
• type ICache
  • func GetCacheImplByName(key string) ICache
• type MapCache
  • func (r *MapCache) Conn() (ICache, error)
  • func (r *MapCache) Del(key string) (int64, error)
  • func (r *MapCache) Get(key string) (string, error)
  • func (r *MapCache) Set(key string, value interface{}) (string, error)
• type RedisCache
  • func (r *RedisCache) Conn() (cache ICache, err error)
  • func (r *RedisCache) Del(key string) (int64, error)
  • func (r *RedisCache) Get(key string) (string, error)
  • func (r *RedisCache) Set(key string, value interface{}) (string, error)
• type RedisConfigure
  • func (r *RedisConfigure) Adapter() *redis.Options

Functions

func Register

func Register(key string, impl ICache)

Register TODO: need refactor

Types

type Configure

type Configure struct {
	types.AutoConfigure `prefix:"application.cache"`
	Instance            string `yaml:"instance"`
}

type FactoryBean

type FactoryBean struct {
	types.FactoryBean `singleton:"true"`
	Cache             *Configure
}

func NewStarter

func NewStarter() *FactoryBean

func (*FactoryBean) GetBean

func (r *FactoryBean) GetBean() (bean.Bean, error)

func (*FactoryBean) GetBeanType

func (r *FactoryBean) GetBeanType() reflect.Type

type ICache

type ICache interface {
	bean.Bean
	Conn() (ICache, error)
	Set(key string, value interface{}) (string, error)
	Del(key string) (int64, error)
	Get(key string) (string, error)
}

func GetCacheImplByName

func GetCacheImplByName(key string) ICache

type MapCache

type MapCache struct {
	types.Component
	// contains filtered or unexported fields
}

func (*MapCache) Conn

func (r *MapCache) Conn() (ICache, error)

func (*MapCache) Del

func (r *MapCache) Del(key string) (int64, error)

func (*MapCache) Get

func (r *MapCache) Get(key string) (string, error)

func (*MapCache) Set

func (r *MapCache) Set(key string, value interface{}) (string, error)

type RedisCache

type RedisCache struct {
	types.Component

	Log log.Logger `wire:""`

	Conf *RedisConfigure
	// contains filtered or unexported fields
}

func (*RedisCache) Conn

func (r *RedisCache) Conn() (cache ICache, err error)

func (*RedisCache) Del

func (r *RedisCache) Del(key string) (int64, error)

func (*RedisCache) Get

func (r *RedisCache) Get(key string) (string, error)

func (*RedisCache) Set

func (r *RedisCache) Set(key string, value interface{}) (string, error)

type RedisConfigure

type RedisConfigure struct {
	types.AutoConfigure `prefix:"application.redis"`
	Network             string        `yaml:"network"`
	Host                string        `yaml:"host"`
	Username            string        `yaml:"username"`
	Password            string        `yaml:"password"`
	DB                  int           `yaml:"db"`
	MaxRetries          int           `yaml:"max_retries"`
	MinRetryBackoff     time.Duration `yaml:"min_retry_backoff"`
	MaxRetryBackoff     time.Duration `yaml:"max_retry_backoff"`
	DialTimeout         time.Duration `yaml:"dial_timeout"`
	ReadTimeout         time.Duration `yaml:"read_timeout"`
	WriteTimeout        time.Duration `yaml:"write_timeout"`
	PoolSize            int           `yaml:"pool_size"`
	MinIdleConns        int           `yaml:"min_idle_conns"`
	MaxConnAge          time.Duration `yaml:"max_conn_age"`
	PoolTimeout         time.Duration `yaml:"pool_timeout"`
	IdleTimeout         time.Duration `yaml:"idle_timeout"`
	IdleCheckFrequency  time.Duration `yaml:"idle_check_frequency"`
}

func (*RedisConfigure) Adapter

func (r *RedisConfigure) Adapter() *redis.Options