Documentation ¶
Index ¶
- Constants
- func CamelToUnderline(title string) string
- func CommandLogger(level string) (zerolog.Logger, error)
- func CreateTopic(brokers string, topic string, partition int32, replica int16) error
- func CustomConsumer(brokers string, group string, config *sarama.Config) (sarama.ConsumerGroup, error)
- func DefaultConsumer(brokers string, group string) (sarama.ConsumerGroup, error)
- func DefaultConsumerConfig() *sarama.Config
- func DefaultProducer(brokers string) (sarama.SyncProducer, error)
- func DefaultProducerConfig() *sarama.Config
- func Del(rds *redis.Client, keys ...string) error
- func FileLogger(filePath string, roll int, level string) (zerolog.Logger, error)
- func GoTypeToMysqlColType(t reflect.Type, longText bool, strLen int) string
- func HashDel(rds *redis.Client, key string, fields ...string) error
- func HashGet(rds *redis.Client, key string, field string) string
- func HashGetAll(rds *redis.Client, key string) map[string]string
- func HashKeys(rds *redis.Client, key string) []string
- func HashLen(rds *redis.Client, key string) int
- func HashSet(rds *redis.Client, key string, kv map[string]string) error
- func InitDynamic(inCluster bool) (dynamic.Interface, error)
- func InitK8sClient(inCluster bool) (*kubernetes.Clientset, error)
- func Keys(rds *redis.Client, query string) []string
- func ListLen(rds *redis.Client, key string, start, end int64) int
- func ListLpop(rds *redis.Client, key string) string
- func ListModify(rds *redis.Client, key string, idx int64, newVal string) error
- func ListRange(rds *redis.Client, key string, start, end int64) []string
- func ListRpop(rds *redis.Client, key string) string
- func ListSetAndLpush(rds *redis.Client, key string, vals ...string) error
- func Lock(rds *redis.Client, key string, exp time.Duration) bool
- func NewRedisClient(addr string, db int) *redis.Client
- func RegisterTable(tb any, comment string)
- func SetUp(config MouseConfig) error
- func StrGet(rds *redis.Client, key string) string
- func StrSet(rds *redis.Client, key, val string) error
- func UnLock(rds *redis.Client, key string) error
- func WriteFile(path string, data []byte) error
- func ZCard(rds *redis.Client, key string) int
- func ZCount(rds *redis.Client, key string, min, max float64) int
- func ZRange(rds *redis.Client, key string, min, max float64) []string
- func ZSetAdd(rds *redis.Client, key string, members map[float64]string) error
- type Base
- type ColumnInfo
- type Create
- type FileLoggerWriter
- type KafkaErr
- type MouseConfig
- type MouseMysqlErr
- type Student
- type TableMetaData
Constants ¶
View Source
const ( Col = "col" Primary = "primary" Unique = "unique" Auto = "auto" Null = "null" Default = "default" Comment = "comment" StrLen = "strlen" LongStr = "longstr" DEFAULT_STR_LEN = 200 INNODB = "innodb" )
Variables ¶
This section is empty.
Functions ¶
func CamelToUnderline ¶ added in v0.0.6
CamelToUnderline 驼峰命名转换为下划线命名
func CommandLogger ¶ added in v0.0.6
CommandLogger 命令行logger,可以直接使用,默认level为DEBUG
func CreateTopic ¶ added in v0.0.13
CreateTopic 创建topic
func CustomConsumer ¶ added in v0.0.14
func DefaultConsumer ¶ added in v0.0.12
func DefaultConsumer(brokers string, group string) (sarama.ConsumerGroup, error)
func DefaultConsumerConfig ¶ added in v0.0.13
func DefaultProducer ¶ added in v0.0.13
func DefaultProducer(brokers string) (sarama.SyncProducer, error)
func DefaultProducerConfig ¶ added in v0.0.13
func FileLogger ¶ added in v0.0.6
FileLogger 文件logger,错误必须处理,如果路径无效则创建logger失败 目前固定每天归档日志
func GoTypeToMysqlColType ¶ added in v0.0.6
GoTypeToMysqlColType 返回mysql中对应golang类型的类型,如果不存在则返回空字符串
func HashGetAll ¶ added in v0.0.9
HashGetAll 获取hash的所有值
func InitK8sClient ¶
func InitK8sClient(inCluster bool) (*kubernetes.Clientset, error)
InitK8sClient 初始化k8s的client
inCluster 是否在集群中部署
func ListModify ¶ added in v0.0.9
ListModify 根据索引值修改列表的值
func ListSetAndLpush ¶ added in v0.0.9
ListSet 创建一个列表
func NewRedisClient ¶ added in v0.0.9
func RegisterTable ¶ added in v0.0.6
RegisterType 创建并执行建表语句,表不存在时创建,存在则更新
func SetUp ¶ added in v0.0.3
func SetUp(config MouseConfig) error
SetUp 初始化库中的一些全局变量以及初始化客户端需要的参数,不显式调用则使用默认值
Types ¶
type ColumnInfo ¶ added in v0.0.6
type ColumnInfo struct { ColName string ColType string IsPrimary bool IsUnique bool IsAuto bool IsNull bool DefaultVal string Comment string }
func ExtractColFromTableType ¶ added in v0.0.6
func ExtractColFromTableType(tb any) ([]ColumnInfo, error)
func GroupColInfo ¶ added in v0.0.6
func GroupColInfo(t reflect.Type) ([]ColumnInfo, error)
type Create ¶ added in v0.0.6
type Create struct { TableMeta TableMetaData TableCols []ColumnInfo MaxColIdx int MaxIndexIdx int }
type FileLoggerWriter ¶ added in v0.0.3
type FileLoggerWriter struct { Debug io.Writer Info io.Writer Warn io.Writer Error io.Writer Fatal io.Writer // contains filtered or unexported fields }
func NewFileLoggerWriter ¶ added in v0.0.3
type KafkaErr ¶ added in v0.0.13
type KafkaErr struct {
// contains filtered or unexported fields
}
func KafkaError ¶ added in v0.0.13
type MouseConfig ¶ added in v0.0.3
MouseConfig mouselib全局配置
Mode 模式,debug/prod,测试和生产均使用prod
LogPath 日志存储位置
type MouseMysqlErr ¶ added in v0.0.6
type MouseMysqlErr struct {
// contains filtered or unexported fields
}
func NewMysqlErr ¶ added in v0.0.6
func NewMysqlErr(msg string, e error) MouseMysqlErr
func (MouseMysqlErr) Error ¶ added in v0.0.6
func (e MouseMysqlErr) Error() string
type TableMetaData ¶ added in v0.0.6
func ExtractTableInfo ¶ added in v0.0.6
func ExtractTableInfo(tb any, comment string) (*TableMetaData, error)
Click to show internal directories.
Click to hide internal directories.