Versions in this module Expand all Collapse all v1 v1.2.1 Mar 15, 2020 Changes in this version + const CODE62 + const CODE_LENTH + var EDOC = map[string]int64 + var SHARD_COUNT = 32 + func Base62ToInt(str string) int64 + func BoolToBytes(v bool) []byte + func BytesToBool(buf []byte) bool + func BytesToFloat32(bytes []byte) float32 + func BytesToFloat64(bytes []byte) float64 + func BytesToInt32(buf []byte) int32 + func BytesToInt64(buf []byte) int64 + func BytesToMap(bytes []byte) (map[string]interface{}, error) + func BytesToMapString(bytes []byte) (map[string]string, error) + func Float32ToBytes(float float32) []byte + func Float64ToBytes(float float64) []byte + func Int32ToBytes(i int32) []byte + func Int64ToBytes(i int64) []byte + func IntToBase62(number int64) string + func MapToBytes(jmap map[string]interface{}) ([]byte, error) + func MapToBytesString(jmap map[string]string) ([]byte, error) + func RandInt64(min, max int64) int64 + func Struct2Map(obj interface{}) map[string]interface + type BeeMap struct + func NewBeeMap() *BeeMap + func (m *BeeMap) Check(k interface{}) bool + func (m *BeeMap) Delete(k interface{}) + func (m *BeeMap) DeleteAll() + func (m *BeeMap) Get(k interface{}) interface{} + func (m *BeeMap) Items() map[interface{}]interface{} + func (m *BeeMap) Set(k interface{}, v interface{}) bool + type ConcurrentMap []*ConcurrentMapShared + func New() ConcurrentMap + func (m ConcurrentMap) Count() int + func (m ConcurrentMap) Get(key string) (interface{}, bool) + func (m ConcurrentMap) GetShard(key string) *ConcurrentMapShared + func (m ConcurrentMap) Has(key string) bool + func (m ConcurrentMap) IsEmpty() bool + func (m ConcurrentMap) Items() map[string]interface{} + func (m ConcurrentMap) Iter() <-chan Tuple + func (m ConcurrentMap) IterBuffered() <-chan Tuple + func (m ConcurrentMap) IterCb(fn IterCb) + func (m ConcurrentMap) Keys() []string + func (m ConcurrentMap) MSet(data map[string]interface{}) + func (m ConcurrentMap) MarshalJSON() ([]byte, error) + func (m ConcurrentMap) Pop(key string) (v interface{}, exists bool) + func (m ConcurrentMap) Remove(key string) + func (m ConcurrentMap) RemoveCb(key string, cb RemoveCb) bool + func (m ConcurrentMap) Set(key string, value interface{}) + func (m ConcurrentMap) SetIfAbsent(key string, value interface{}) bool + func (m ConcurrentMap) Upsert(key string, value interface{}, cb UpsertCb) (res interface{}) + type ConcurrentMapShared struct + type ID uint64 + func GenerateID() ID + func ParseID(s string) (ID, error) + func (id *ID) UnmarshalJSON(data []byte) error + func (id ID) MarshalJSON() ([]byte, error) + func (id ID) String() string + type IterCb func(key string, v interface{}) + type Queue struct + func NewQueue() *Queue + func (q *Queue) Add(elem interface{}) + func (q *Queue) Get(i int) interface{} + func (q *Queue) Length() int + func (q *Queue) Peek() interface{} + func (q *Queue) Remove() interface{} + type RedisFactory struct + func GetRedisFactory() *RedisFactory + func (this RedisFactory) CloseAllPool() + func (this RedisFactory) GetPool(url string) *redis.Pool + type RemoveCb func(key string, v interface{}, exists bool) bool + type SyncQueue struct + func NewSyncQueue() *SyncQueue + func (q *SyncQueue) Close() + func (q *SyncQueue) IsClose() (v bool) + func (q *SyncQueue) Len() (l int) + func (q *SyncQueue) Pop() (v interface{}) + func (q *SyncQueue) Push(v interface{}) + func (q *SyncQueue) TryPop() (v interface{}, ok bool) + type Tuple struct + Key string + Val interface{} + type UpsertCb func(exist bool, valueInMap interface{}, newValue interface{}) interface
Go to main page