es

Feb 9, 2023

Changes in this version

+ var CreateClient = defaultNewClient

type Client

+ Cfg ClientConfig

+ Client *elasticsearch.Client

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

+ func (c *Client) Load(name string, cfg *ComponentConfig) (err error)

+ type ClientConfig struct

+ Host []string

+ MaxIdleConn int

+ Pwd string

+ User string

type Component

+ Cfg ComponentConfig

+ Clts map[string]*Client

+ DSNPrint bool

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

+ type ComponentConfig struct

+ KeepAliveTime int

+ MaxConnTime int

+ MaxIdleTime int

+ SlowThreshold int

Feb 3, 2023

Changes in this version

type ConnConfig

+ MaxIdleConn int

Feb 2, 2023

Changes in this version

+ const CliDSNList

+ const CliInitType

+ type BasicConfig struct

+ InitType int

+ KeepAliveTime int

+ MaxConnTime int

+ MaxIdleConn int

+ MaxIdleTime int

+ MaxRepTime int

+ RepSlowThreshold int

type Component

+ New NewDatabase

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

+ func (s *Component) Log() logger.Interface

+ type ConnConfig struct

+ Host []string

+ Pwd string

+ User string

+ type Database struct

+ func (c *Database) Config() BasicConfig

+ func (c *Database) DB() *elasticsearch.Client

+ func (c *Database) ReqTimeoutDuration() time.Duration

+ func (c *Database) RequestTimeoutCtx() (context.Context, context.CancelFunc)

+ type NewDatabase func(*Component, *ConnConfig) (*elasticsearch.Client, error)

Jan 31, 2023

Changes in this version

+ const CliConnTimeout

+ const CliDnsList

+ const CliIdleMaxCnt

+ const CliIdleTimeout

+ const CliKeepAliveTime

+ const CliReqSlowThreshold

+ const CliReqTimeout

+ type Client struct

+ func (c *Client) ReqThreshold() time.Duration

+ func (c *Client) ReqTimeout() time.Duration

+ type Component struct

+ Parser FileParser

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

+ func (s *Component) Close(logger.Interface, *gsf.AppConfig) error

+ func (s *Component) GetDB(dbName string) (*Client, error)

+ func (s *Component) InitConfig(l logger.Interface, cfg *gsf.AppConfig, ctx *cli.Context) (err error)

+ func (s *Component) Run(l logger.Interface, cfg *gsf.AppConfig) error

+ type Config struct

+ DBMap map[string]DBConfig

+ KeepAliveTime int

+ MaxConnTime int

+ MaxIdleConn int

+ MaxIdleTime int

+ MaxRepTime int

+ RepSlowThreshold int

+ type DBConfig struct

+ Host []string

+ Pwd string

+ User string

+ type FileParser func(logger.Interface, *gsf.AppConfig, *cli.Context, *Config) error