component

May 17, 2023

Changes in this version

+ type EsApiLog func(op, idx, body string) func()

type EsClient

+ func (c *EsClient) SearchLog(l EsApiLog, idx string, body string, receive interface{}) (cnt uint64, err error)

+ type MongoApiLog func(tbl, op string, args [][2]interface{}) func()

type MongoClient

+ func (c *MongoClient) AggregateAllLog(l MongoApiLog, list interface{}, table string, pipeline interface{}, ...) error

+ func (c *MongoClient) CountLog(l MongoApiLog, table string, pipeline interface{}, ...) int64

+ func (c *MongoClient) FindAllLog(l MongoApiLog, list interface{}, table string, filter interface{}, ...) error

+ func (c *MongoClient) FindOneLog(l MongoApiLog, data interface{}, table string, filter interface{}, ...) error

+ func (c *MongoClient) InsertLog(l MongoApiLog, table string, data interface{}, ...) (*mongo.InsertOneResult, error)

+ func (c *MongoClient) UpdateLog(l MongoApiLog, table string, filter, data interface{}, ...) (*mongo.UpdateResult, error)

+ type MysqlLoggerDefault struct

+ func (l MysqlLoggerDefault) Error(_ context.Context, format string, v ...interface{})

+ func (l MysqlLoggerDefault) Info(_ context.Context, format string, v ...interface{})

+ func (l MysqlLoggerDefault) Warn(_ context.Context, format string, v ...interface{})

+ type MysqlLoggerInterface interface

+ Error func(ctx context.Context, format string, v ...interface{})

+ Info func(ctx context.Context, format string, v ...interface{})

+ Warn func(ctx context.Context, format string, v ...interface{})

Feb 23, 2023

Changes in this version

type ElasticSearch

+ Log logger.Interface

type EsClient

+ func (c *EsClient) ApiLog(op, idx, body string) func()

+ func (c *EsClient) Ref() *ElasticSearch

type Mongo

+ Log logger.Interface

type MongoClient

+ func (c *MongoClient) ApiLog(tbl, op string, args [][2]interface{}) func()

+ func (c *MongoClient) Insert(table string, data interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

+ func (c *MongoClient) Ref() *Mongo

+ func (c *MongoClient) Update(table string, filter, data interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

type MySQLClient

+ func (c *MySQLClient) Ref() *MySQL

type Redis

+ Log logger.Interface

type RedisClient

+ func (c *RedisClient) ApiLog(args [][2]interface{}) func()

+ func (c *RedisClient) Ref() *Redis

Feb 10, 2023

Changes in this version

type EsClient

+ IndexSuffix string

+ func (c *EsClient) Config() *define.EntityEs

+ func (c *EsClient) Init(env int, cc *ElasticSearch)

+ func (c *EsClient) Search(idx string, body string, receive interface{}) (cnt uint64, err error)

+ type EsDatabase interface

+ CliFlags func(string) []cli.Flag

+ Config func() *define.EntityEs

+ Init func(int, *ElasticSearch)

+ Load func(string) error

type MongoClient

+ func (c *MongoClient) AggregateAll(list interface{}, table string, pipeline interface{}, ...) error

+ func (c *MongoClient) Config() *define.EntityMongo

+ func (c *MongoClient) Count(table string, pipeline interface{}) int64

+ func (c *MongoClient) FindAll(list interface{}, table string, filter interface{}, ...) error

+ func (c *MongoClient) FindOne(data interface{}, table string, filter interface{}, ...) error

+ func (c *MongoClient) Init(env int, cc *Mongo)

+ type MongoDatabase interface

+ CliFlags func(string) []cli.Flag

+ Config func() *define.EntityMongo

+ Init func(int, *Mongo)

+ Load func(string) error

type MySQLClient

+ func (c *MySQLClient) Config() *define.EntityMysql

+ func (c *MySQLClient) Init(env int, cc *MySQL)

+ type MysqlDatabase interface

+ CliFlags func(string) []cli.Flag

+ Config func() *define.EntityMysql

+ Init func(int, *MySQL)

+ Load func(string) error

type RedisClient

+ func (c *RedisClient) Config() *define.EntityRedis

+ func (c *RedisClient) Init(env int, cc *Redis)

+ type RedisDatabase interface

+ CliFlags func(string) []cli.Flag

+ Config func() *define.EntityRedis

+ Init func(int, *Redis)

+ Load func(string) error

Feb 10, 2023

Changes in this version

+ type Cron struct

+ Cfg config.ComponentCron

+ func (s *Cron) CliFlags() []cli.Flag

+ func (s *Cron) Close() error

+ func (s *Cron) FreeCron(name string) error

+ func (s *Cron) Init(_ logger.Interface, _ *gsf.AppConfig, _ *cli.Context) error

+ func (s *Cron) NewCron(name string) (*cron.Cron, error)

+ func (s *Cron) NewCronEx(name string, bSize int) (*cron.Cron, error)

+ func (s *Cron) Run() error

type ElasticSearch

+ Clts map[string]*EsClient

+ func (c *ElasticSearch) LoadOne(name string) (err error)

+ type EsClient struct

+ Cfg config.EntityEs

+ DB *elasticsearch.Client

+ func (c *EsClient) CliFlags(name string) []cli.Flag

+ func (c *EsClient) Load(name string, cfg *config.ComponentEs) (err error)

type Mongo

+ Clts map[string]*MongoClient

+ func (c *Mongo) LoadOne(name string) (err error)

+ type MongoClient struct

+ Cfg config.EntityMongo

+ DB *mongo.Database

+ func (c *MongoClient) CliFlags(name string) []cli.Flag

+ func (c *MongoClient) Load(name string, cfg *config.ComponentMongo) error

type MySQL

+ Clts map[string]*MySQLClient

+ func (c *MySQL) LoadOne(name string) (err error)

+ type MySQLClient struct

+ Cfg config.EntityMysql

+ DB *gorm.DB

+ func (c *MySQLClient) CliFlags(name string) []cli.Flag

+ func (c *MySQLClient) Load(name string, _ *config.ComponentMysql, log logger.Interface) (err error)

type Redis

+ Clts map[string]*RedisClient

+ func (c *Redis) LoadOne(name string) (err error)

+ type RedisClient struct

+ Cfg config.EntityRedis

+ DB *redis.Client

+ func (c *RedisClient) CliFlags(name string) []cli.Flag

+ func (c *RedisClient) Load(name string, cfg *config.ComponentRedis) error

+ type Resize struct

+ func (r *Resize) Check(cap, len int) bool

+ func (r *Resize) NewCap(len int) int

Feb 9, 2023

Changes in this version

+ var PrintfDSN = true

Feb 8, 2023

Changes in this version

+ var EsKeepAliveTime int

+ var EsMaxConnTime int

+ var EsMaxIdleTime int

+ var EsMaxRepTime int

+ var EsSlowThreshold int

+ var MongoMaxIdleTime int

+ var MongoMaxPoolSize int

+ var MongoMinPoolSize int

+ var MongoReqMaxTime int

+ var MongoSelectionTime int

+ var MongoSlowThreshold int

+ var MysqlSlowThreshold = 300

+ var RedisIdleCheckTime int

+ var RedisMaxReadTime int

+ var RedisMaxRequestTime int

+ var RedisMaxWriteTime int

+ var RedisSlowThreshold int

+ type ElasticSearch struct

+ Cfg *config.EntityEs

+ DB *elasticsearch.Client

+ Name string

+ func (c *ElasticSearch) CliFlags() []cli.Flag

+ func (c *ElasticSearch) Close() error

+ func (c *ElasticSearch) Init(l logger.Interface, cfg *gsf.AppConfig, ctx *cli.Context) error

+ func (c *ElasticSearch) Run() (err error)

+ type Mongo struct

+ Cfg *config.EntityMongo

+ DB *mongo.Database

+ Name string

+ func (c *Mongo) CliFlags() []cli.Flag

+ func (c *Mongo) Close() error

+ func (c *Mongo) Init(l logger.Interface, cfg *gsf.AppConfig, ctx *cli.Context) error

+ func (c *Mongo) Run() error

+ type MySQL struct

+ Cfg *config.EntityMysql

+ DB *gorm.DB

+ Log MysqlLogger

+ Name string

+ func (c *MySQL) CliFlags() []cli.Flag

+ func (c *MySQL) Close() error

+ func (c *MySQL) Init(l glogger.Interface, cfg *gsf.AppConfig, _ *cli.Context) error

+ func (c *MySQL) Run() error

+ func (c *MySQL) SetLogLevel(v int)

+ type MysqlLogger struct

+ func (l *MysqlLogger) Error(_ context.Context, msg string, data ...interface{})

+ func (l *MysqlLogger) Info(_ context.Context, msg string, data ...interface{})

+ func (l *MysqlLogger) LogMode(level logger.LogLevel) logger.Interface

+ func (l *MysqlLogger) SetLogger(log glogger.Interface)

+ func (l *MysqlLogger) Trace(_ context.Context, begin time.Time, fc func() (string, int64), err error)

+ func (l *MysqlLogger) Warn(_ context.Context, msg string, data ...interface{})

+ type Redis struct

+ Cfg *config.EntityRedis

+ DB *redis.Client

+ Name string

+ func (c *Redis) CliFlags() []cli.Flag

+ func (c *Redis) Close() error

+ func (c *Redis) Init(l logger.Interface, cfg *gsf.AppConfig, _ *cli.Context) error

+ func (c *Redis) Run() error