async

Dec 20, 2021

Changes in this version

+ func BarchExec(group string, tasks ...Task) map[string]interface

+ func Exec(group string, task Task) (interface{}, error)

+ func RegisterTaskGroup(name string, batchSize int, ...) error

+ type Task interface

+ Key func() string

Sep 9, 2021

Changes in this version

+ func ForceGet(group string, key interface{}) (interface{}, error)

+ func ForceMGet(group string, keys ...interface{}) []interface

Aug 31, 2021

Changes in this version

+ func MGet(group string, keys ...interface{}) []interface

Aug 17, 2021

Changes in this version

+ func For(count int, method func(int) (interface{}, error), maxConcurrent int) []interface

Feb 7, 2021

Changes in this version

+ func Get(group string, key interface{}) (interface{}, error)

+ func RegisterGroup(name string, batchSize int, ...) error

+ type CacheProvider interface

+ Get func(string, interface{}) (interface{}, error)

+ Put func(string, interface{}, interface{}) error

Jan 31, 2021

Changes in this version

type Batch

+ func (p *Batch) Get(key interface{}) (interface{}, error)

Jan 29, 2021

Changes in this version

type KVCache

+ func (kv *KVCache) LRU(flag bool) *KVCache

Jul 5, 2020

Changes in this version

+ const Unlimit

Jul 5, 2020

Changes in this version

+ func Foreach(objs []interface{}, method func(int) (interface{}, error), maxCount int) []interface

Oct 23, 2018

Changes in this version

+ func Retry(method func() (interface{}, error), maxCount int, interval time.Duration) (interface{}, error)

+ type Batch struct

+ func NewBatch(kernal func([]interface{}) (map[interface{}]interface{}, error), ...) *Batch

+ func (p *Batch) MGet(keys []interface{}) (map[interface{}]interface{}, error)

Aug 20, 2018

Changes in this version

type Merge

+ func (m *Merge) Destory()

+ func (m *Merge) Exec(key string, method func() (interface{}, error)) (interface{}, error)

Jul 30, 2018

Changes in this version

+ func Safety(method func() (interface{}, error)) (res interface{}, err error)

May 9, 2018

Changes in this version

+ func Parallel(methods []LambdaMethod, maxCount int) []interface

+ func SetPanicHandler(hanlder func())

type KVData

+ func (kv *KVData) Clean()

Jan 8, 2018

Changes in this version

+ func All(methods []LambdaMethod, timeout time.Duration) []interface

+ func Any(methods []LambdaMethod, timeout time.Duration) ([]interface{}, error)

+ func AnyOne(methods []LambdaMethod, timeout time.Duration) (interface{}, []error)

+ func Call(m Method, ctx context.Context, timeout time.Duration, args ...interface{}) (interface{}, error)

+ func Flow(enter Method, ctx context.Context, args []interface{}, methods []Method, ...) (interface{}, error)

+ func Lambda(method func() (interface{}, error), timeout time.Duration) (interface{}, error)

+ func Serise(methods []LambdaMethod, timeout time.Duration) []interface

+ type GQuery struct

+ type KVCache struct

+ func NewKVCache() *KVCache

+ func (kv *KVCache) Commit(method func(*KVData) (interface{}, error)) (interface{}, error)

+ func (kv *KVCache) Destory()

+ func (kv *KVCache) MaxSize(maxSize int) *KVCache

+ func (kv *KVCache) TTL(ttl int64) *KVCache

+ type KVData struct

+ func (kv *KVData) Del(key interface{})

+ func (kv *KVData) Get(key interface{}) (interface{}, error)

+ func (kv *KVData) Keys() []interface{}

+ func (kv *KVData) MDel(keys []interface{})

+ func (kv *KVData) MGet(keys []interface{}) []interface{}

+ func (kv *KVData) MSet(keys []interface{}, values []interface{})

+ func (kv *KVData) Merge(pairs map[interface{}]interface{})

+ func (kv *KVData) Set(key interface{}, value interface{})

+ type LambdaMethod func() (interface{}, error)

+ type Merge struct

+ func NewMerge(name string, kernal func([]interface{}) (map[interface{}]interface{}, error), ...) *Merge

+ func (p *Merge) MGet(keys []interface{}) (map[interface{}]interface{}, error)

+ type Method func(ctx context.Context, args ...interface{}) (interface{}, error)

+ type QResult struct

+ type Query struct