README
¶
storage
存储层实现
Documentation
¶
Index ¶
- func Do(ctx context.Context, params interface{}, handlers ...DataHandler) (interface{}, error)
- func NewDefaultLocker(biz string) locker.Locker
- func NewMultiCacheReader(keyfn scache.RedisKeyGenerator) scache.RedisKeyValueObjectReader
- func NewMultiCacheRepoReader1(keyFn scache.RedisKeyGenerator, tablename string, columns []string, biz string) ...
- func NewMultiCacheWriter(keyfn scache.RedisKeyGenerator) func(ctx context.Context, data interface{}, expire time.Duration) error
- func NewMultiRepoReader(tableName string, columns []string) func(ctx context.Context, out interface{}, hand ...srepo.ClauseHandler) error
- func NewOneCacheReader(prefix string) scache.RedisKeyValueObjectReader
- func NewOneCacheRepoReader(prefix string, tablename string, columns []string, biz string) ...
- func NewOneCacheWriter(prefix string) func(ctx context.Context, kv scache.Pair, expire time.Duration) error
- func NewOneRepoReader(tableName string, columns []string) func(ctx context.Context, out interface{}, hand ...srepo.ClauseHandler) error
- type DataHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Do ¶
func Do(ctx context.Context, params interface{}, handlers ...DataHandler) (interface{}, error)
Do 执行 前一步操作的输出是下一步的输入
func NewMultiCacheReader ¶
func NewMultiCacheReader(keyfn scache.RedisKeyGenerator) scache.RedisKeyValueObjectReader
NewMultiCacheRepoReader 多key读取 @params keyfn Key生成函数
func NewMultiCacheRepoReader1 ¶
func NewMultiCacheRepoReader1(keyFn scache.RedisKeyGenerator, tablename string, columns []string, biz string) func(ctx context.Context, params interface{}, expire time.Duration, out interface{}, opts ...srepo.ClauseHandler) error
NewMultiCacheRepoReader1 通用缓存-库数据读取器,多值 DO NOT USE TODO
func NewMultiCacheWriter ¶
func NewMultiCacheWriter(keyfn scache.RedisKeyGenerator) func(ctx context.Context, data interface{}, expire time.Duration) error
NewOneCacheWriter 缓存对象写入
func NewMultiRepoReader ¶
func NewMultiRepoReader(tableName string, columns []string) func(ctx context.Context, out interface{}, hand ...srepo.ClauseHandler) error
NewMultiRepoReader 通用数据库读取
func NewOneCacheReader ¶
func NewOneCacheReader(prefix string) scache.RedisKeyValueObjectReader
NewOneCacheReader 缓存对象读取
func NewOneCacheRepoReader ¶
func NewOneCacheRepoReader(prefix string, tablename string, columns []string, biz string) func(ctx context.Context, params interface{}, expire time.Duration, out interface{}, opts ...srepo.ClauseHandler) error
NewOneCacheRepoReader 通用缓存-库数据读取器,单对象
func NewOneCacheWriter ¶
func NewOneCacheWriter(prefix string) func(ctx context.Context, kv scache.Pair, expire time.Duration) error
NewOneCacheWriter 缓存对象写入
func NewOneRepoReader ¶
func NewOneRepoReader(tableName string, columns []string) func(ctx context.Context, out interface{}, hand ...srepo.ClauseHandler) error
NewOneRepoReader 通用数据库读取
Types ¶
type DataHandler ¶
type DataHandler func(ctx context.Context, params interface{}) (interface{}, meta.OptionStatus, error)
DataHandler 数据处理
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.