gl

Documentation

Index

• Constants
• func BatchGet(keys []interface{}) map[interface{}]interface{}
• func Close()
• func Decr(key interface{}, count int64) int64
• func Del(key interface{})
• func Get(key interface{}) (interface{}, bool)
• func GetCurrentGlData() map[string]interface{}
• func Incr(key interface{}, count int64) int64
• func IncrCost(key interface{}, cost time.Duration) int64
• func IncrCostKey(key string, cost time.Duration) int64
• func IncrCountKey(key string, val int64) int64
• func IncrFailKey(key string, val int64) int64
• func Init()
• func Set(key interface{}, val interface{})
• func SetLogger(l Logger)
• type ConcurrentMap
  • func NewShard(shardCount int) *ConcurrentMap
  • func (m *ConcurrentMap) Get(key string) (interface{}, bool)
  • func (m *ConcurrentMap) GetShard(key string) *Shard
  • func (m *ConcurrentMap) Remove(key string)
  • func (m *ConcurrentMap) Set(key string, value interface{})
• type Logger
• type Shard

Constants

const (
	ClientIp = "glClientIp"
	Tag      = "glTag"
	LogId    = "glLogId"
)

Functions

func BatchGet

func BatchGet(keys []interface{}) map[interface{}]interface{}

func Close

func Close()

func Decr

func Decr(key interface{}, count int64) int64

func Del

func Del(key interface{})

func Get

func Get(key interface{}) (interface{}, bool)

func GetCurrentGlData

func GetCurrentGlData() map[string]interface{}

func Incr

func Incr(key interface{}, count int64) int64

func IncrCost

func IncrCost(key interface{}, cost time.Duration) int64

func IncrCostKey

func IncrCostKey(key string, cost time.Duration) int64

func IncrCountKey

func IncrCountKey(key string, val int64) int64

func IncrFailKey

func IncrFailKey(key string, val int64) int64

func Init

func Init()

func Set

func Set(key interface{}, val interface{})

func SetLogger

func SetLogger(l Logger)

Types

type ConcurrentMap

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

func NewShard

func NewShard(shardCount int) *ConcurrentMap

func (*ConcurrentMap) Get

func (m *ConcurrentMap) Get(key string) (interface{}, bool)

func (*ConcurrentMap) GetShard

func (m *ConcurrentMap) GetShard(key string) *Shard

func (*ConcurrentMap) Remove

func (m *ConcurrentMap) Remove(key string)

func (*ConcurrentMap) Set

func (m *ConcurrentMap) Set(key string, value interface{})

type Logger

type Logger interface {
	Debug(format interface{}, v ...interface{})
	Info(format interface{}, v ...interface{})
	Error(format interface{}, v ...interface{}) error
}

type Shard

type Shard struct {
	sync.RWMutex
	// contains filtered or unexported fields
}