Versions in this module Expand all Collapse all v0 v0.1.1 Apr 25, 2023 Changes in this version + const ClientMaxBlockSize + const ClientReadTimeout + const ClientReadTimeoutDuration + const LogConsoleSeparator + const MinIdles + const NilType + const PoolSize + var Logger *zap.Logger + func GetLogPrefix(traceId string, msgList ...string) string + func NewZapLogger(filename string, maxSize int, maxBackups int, maxAge int, compress bool) + type CKHandler struct + InsertSql string + func NewCKHandler(ckConf *ClickhouseConf) *CKHandler + func (c *CKHandler) BatchInsertData(query string, dataArrays [][]interface{}) (bool, error) + func (c *CKHandler) InitClickHouse() + func (c *CKHandler) InitInsertSQL() + func (c *CKHandler) InsertData(query string, data ...interface{}) (bool, error) + func (c *CKHandler) QueryData(items interface{}, query string) error + type ClickhouseConf struct + DataSchema []string + Database string + Host string + Password string + Port int + Table string + Username string + type ModelRedisHandler struct + RedisClient *redis.Client + RedisClusterClient *redis.ClusterClient + func NewRedisHandler(redisConf *RedisConf) *ModelRedisHandler + func (r *ModelRedisHandler) AppendList(key string, value interface{}) bool + func (r *ModelRedisHandler) BFAdd(key string, value string) (bool, bool) + func (r *ModelRedisHandler) BFExists(key string, value string) bool + func (r *ModelRedisHandler) EmptyList(key string) bool + func (r *ModelRedisHandler) Get(key string) (string, bool) + func (r *ModelRedisHandler) GetList(key string, start, stop int64) ([]string, bool) + func (r *ModelRedisHandler) HashDel(key string, fields ...string) bool + func (r *ModelRedisHandler) HashGet(key, field string) (string, bool) + func (r *ModelRedisHandler) HashLen(key string) int64 + func (r *ModelRedisHandler) HashMGET(key string, fields ...string) ([]interface{}, bool) + func (r *ModelRedisHandler) HashMSet(key string, values ...interface{}) bool + func (r *ModelRedisHandler) HashSet(key string, values ...interface{}) bool + func (r *ModelRedisHandler) Pipeline() (redis.Pipeliner, context.Context) + func (r *ModelRedisHandler) PipelineExecute(pipe redis.Pipeliner, ctx context.Context) ([]redis.Cmder, error) + func (r *ModelRedisHandler) Set(key string, value interface{}, ex time.Duration) bool + func (r *ModelRedisHandler) ShutdownRedisHandler() error + type RedisConf struct + Database int + Enable bool + Host string + IsCluster bool + Password string + type ZapLogger struct + Compress bool + Filename string + MaxAge int + MaxBackups int + MaxSize int