README
¶
storage
存储层实现
Documentation
¶
Index ¶
- func Do(ctx context.Context, params interface{}, handlers ...DataHandler) (interface{}, error)
- 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 NewOneCacheRepoReader(opts OneCacheRepoOptions) ...
- type DataHandler
- type OneCacheRepoOptions
- type OneCacheRepoOptionsHandler
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 NewOneCacheRepoReader ¶
func NewOneCacheRepoReader(opts OneCacheRepoOptions) func(ctx context.Context, params interface{}, expire time.Duration, out interface{}) error
NewOneCacheRepoReader 通用缓存-库数据读取器,单对象
Types ¶
type DataHandler ¶
type DataHandler func(ctx context.Context, params interface{}) (interface{}, meta.OptionStatus, error)
DataHandler 数据处理
type OneCacheRepoOptions ¶ added in v0.1.1
type OneCacheRepoOptions struct {
CacheReader scache.RedisKeyValueObjectReader
CacheWriter scache.RedisKeyValueWriter
RepoReader srepo.RepoGroupReader
Locker locker.Locker
}
OneCacheRepoOptions 单一对象缓存配置
func NewOneCacheRepoOptions ¶ added in v0.1.1
func NewOneCacheRepoOptions(hand ...OneCacheRepoOptionsHandler) OneCacheRepoOptions
NewOneCacheRepoOptions 创建新的单一对象缓存配置
type OneCacheRepoOptionsHandler ¶ added in v0.1.1
type OneCacheRepoOptionsHandler func(*OneCacheRepoOptions)
OneCacheRepoOptionsHandler 单一对象缓存配置处理方法
func WithCacheReader ¶ added in v0.1.1
func WithCacheReader(r scache.RedisKeyValueObjectReader) OneCacheRepoOptionsHandler
WithCacheReader 缓存读取器
func WithCacheWriter ¶ added in v0.1.1
func WithCacheWriter(w scache.RedisKeyValueWriter) OneCacheRepoOptionsHandler
WithCacheWriter 缓存写入
func WithLocker ¶ added in v0.1.1
func WithLocker(l locker.Locker) OneCacheRepoOptionsHandler
WithLocker 锁
func WithRepoReader ¶ added in v0.1.1
func WithRepoReader(r srepo.RepoGroupReader) OneCacheRepoOptionsHandler
WithRepoReader 数据库读取
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.