Documentation ¶
Index ¶
- Constants
- 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, timeout time.Duration, args ...interface{}) (interface{}, error)
- func Flow(enter Method, args []interface{}, methods []Method, timeout time.Duration) (interface{}, error)
- func For(count int, method func(int) (interface{}, error), maxConcurrent int) []interface{}
- func ForceGet(group string, key interface{}) (interface{}, error)
- func ForceMGet(group string, keys ...interface{}) []interface{}
- func Foreach(objs []interface{}, method func(int) (interface{}, error), maxConcurrent int) []interface{}
- func Get(group string, key interface{}) (interface{}, error)
- func Lambda(method func() (interface{}, error), timeout time.Duration) (interface{}, error)
- func MGet(group string, keys ...interface{}) []interface{}
- func Parallel(methods []LambdaMethod, maxCount int) []interface{}
- func RegisterGroup(name string, batchSize int, ...) error
- func Retry(method func() (interface{}, error), maxCount int, interval time.Duration) (interface{}, error)
- func Safety(method func() (interface{}, error)) (res interface{}, err error)
- func Serise(methods []LambdaMethod, timeout time.Duration) []interface{}
- func SetPanicHandler(hanlder func(interface{}))
- type CacheProvider
- type KVCache
- type KVData
- func (kv *KVData) Clean()
- 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
- type Merge
- type Method
Constants ¶
View Source
const Unlimit = 0
Variables ¶
This section is empty.
Functions ¶
func All ¶
func All(methods []LambdaMethod, timeout time.Duration) []interface{}
func Parallel ¶ added in v0.0.2
func Parallel(methods []LambdaMethod, maxCount int) []interface{}
func RegisterGroup ¶ added in v0.1.12
func RegisterGroup( name string, batchSize int, method func(...interface{}) (map[interface{}]interface{}, error), cache CacheProvider) error
func Serise ¶
func Serise(methods []LambdaMethod, timeout time.Duration) []interface{}
func SetPanicHandler ¶ added in v0.0.2
func SetPanicHandler(hanlder func(interface{}))
Types ¶
type CacheProvider ¶ added in v0.1.12
type KVCache ¶
type KVCache struct {
// contains filtered or unexported fields
}
func NewKVCache ¶
func NewKVCache() *KVCache
type LambdaMethod ¶
type LambdaMethod func() (interface{}, error)
Click to show internal directories.
Click to hide internal directories.