component

Documentation

Index

• type Cron
  • 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
  • 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) LoadOne(name string) (err error)
  • func (c *ElasticSearch) Run() (err error)
• type EsClient
  • func (c *EsClient) CliFlags(name string) []cli.Flag
  • func (c *EsClient) Load(name string, cfg *config.ComponentEs) (err error)
• type Mongo
  • 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) LoadOne(name string) (err error)
  • func (c *Mongo) Run() error
• type MongoClient
  • func (c *MongoClient) CliFlags(name string) []cli.Flag
  • func (c *MongoClient) Load(name string, cfg *config.ComponentMongo) error
• type MySQL
  • 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) LoadOne(name string) (err error)
  • func (c *MySQL) Run() error
  • func (c *MySQL) SetLogLevel(v int)
• type MySQLClient
  • func (c *MySQLClient) CliFlags(name string) []cli.Flag
  • func (c *MySQLClient) Load(name string, _ *config.ComponentMysql, log logger.Interface) (err error)
• type MysqlLogger
  • 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
  • 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) LoadOne(name string) (err error)
  • func (c *Redis) Run() (err error)
• type RedisClient
  • func (c *RedisClient) CliFlags(name string) []cli.Flag
  • func (c *RedisClient) Load(name string, cfg *config.ComponentRedis) error
• type Resize
  • func (r *Resize) Check(cap, len int) bool
  • func (r *Resize) NewCap(len int) int

Types

type Cron

type Cron struct {
	Cfg config.ComponentCron
	// contains filtered or unexported fields
}

func (*Cron) CliFlags

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

func (*Cron) Close

func (s *Cron) Close() error

func (*Cron) FreeCron

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

func (*Cron) Init

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

func (*Cron) NewCron

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

func (*Cron) NewCronEx

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

func (*Cron) Run

func (s *Cron) Run() error

type ElasticSearch

type ElasticSearch struct {
	Cfg  config.ComponentEs
	Clts map[string]*EsClient
}

func (*ElasticSearch) CliFlags

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

func (*ElasticSearch) Close

func (c *ElasticSearch) Close() error

func (*ElasticSearch) Init

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

func (*ElasticSearch) LoadOne

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

func (*ElasticSearch) Run

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

type EsClient

type EsClient struct {
	DB  *elasticsearch.Client
	Cfg config.EntityEs
}

func (*EsClient) CliFlags

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

func (*EsClient) Load

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

type Mongo

type Mongo struct {
	Cfg  config.ComponentMongo
	Clts map[string]*MongoClient
}

func (*Mongo) CliFlags

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

func (*Mongo) Close

func (c *Mongo) Close() error

func (*Mongo) Init

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

func (*Mongo) LoadOne

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

func (*Mongo) Run

func (c *Mongo) Run() error

type MongoClient

type MongoClient struct {
	DB  *mongo.Database
	Cfg config.EntityMongo
}

func (*MongoClient) CliFlags

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

func (*MongoClient) Load

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

type MySQL

type MySQL struct {
	Cfg  config.ComponentMysql
	Clts map[string]*MySQLClient
	Log  MysqlLogger
}

func (*MySQL) CliFlags

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

func (*MySQL) Close

func (c *MySQL) Close() error

func (*MySQL) Init

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

func (*MySQL) LoadOne

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

func (*MySQL) Run

func (c *MySQL) Run() error

func (*MySQL) SetLogLevel

func (c *MySQL) SetLogLevel(v int)

type MySQLClient

type MySQLClient struct {
	DB  *gorm.DB
	Cfg config.EntityMysql
}

func (*MySQLClient) CliFlags

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

func (*MySQLClient) Load

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

type MysqlLogger

type MysqlLogger struct {
	// contains filtered or unexported fields
}

func (*MysqlLogger) Error

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

func (*MysqlLogger) Info

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

func (*MysqlLogger) LogMode

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

func (*MysqlLogger) SetLogger

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

func (*MysqlLogger) Trace

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

func (*MysqlLogger) Warn

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

type Redis

type Redis struct {
	Cfg  config.ComponentRedis
	Clts map[string]*RedisClient
}

func (*Redis) CliFlags

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

func (*Redis) Close

func (c *Redis) Close() error

func (*Redis) Init

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

func (*Redis) LoadOne

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

func (*Redis) Run

func (c *Redis) Run() (err error)

type RedisClient

type RedisClient struct {
	DB  *redis.Client
	Cfg config.EntityRedis
}

func (*RedisClient) CliFlags

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

func (*RedisClient) Load

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

type Resize

type Resize struct {
	// contains filtered or unexported fields
}

func (*Resize) Check

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

func (*Resize) NewCap

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