es

README

gsf-es

db config json

component

{
  "keep_alive_time": 5,
  "max_idle_time": 60,
  "max_con_time": 3,
  "slow_threshold": 300
}

client

{
  "host": [
    "127.0.0.1:9800"
  ],
  "user": "",
  "pwd": "",
  "idle_limit": 2
}

命令行参数

--es-conn-timeout value          es connect timeout (default: 0)
--es-idle-timeout value          es idle connect timeout (default: 0)
--es-keepalive-time value        es keepalive time (default: 0)
--es-slow-threshold value        es slow threshold (default: 0)
--es-{{key}}-idle-limit value    es({{key}}) idle max count (default: 0)
--es-{{key}}-dsn value           es({{key}}) DSN (format: {{user}}:{{password}}@{{host}},{{host}})

Documentation

Index

• Variables
• type Client
  • func (c *Client) CliFlags(name string) []cli.Flag
  • func (c *Client) Load(name string, cfg *ComponentConfig) (err error)
• type ClientConfig
• type Component
  • func (c *Component) CliFlags() []cli.Flag
  • func (c *Component) Close() error
  • func (c *Component) Init(l logger.Interface, cfg *gsf.AppConfig, ctx *cli.Context) error
  • func (c *Component) LoadOne(name string) (err error)
  • func (c *Component) Run() (err error)
• type ComponentConfig

Variables

var CreateClient = defaultNewClient

Types

type Client

type Client struct {
	Client *elasticsearch.Client
	Cfg    ClientConfig
}

func (*Client) CliFlags

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

func (*Client) Load

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

type ClientConfig

type ClientConfig struct {
	Host        []string `json:"host"       yaml:"host"`
	Pwd         string   `json:"pwd"        yaml:"pwd"`
	User        string   `json:"user"       yaml:"user"`
	MaxIdleConn int      `json:"idle_limit" yaml:"idle_limit"`
}

type Component

type Component struct {
	DSNPrint bool
	Cfg      ComponentConfig
	Clts     map[string]*Client
}

func (*Component) CliFlags

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

func (*Component) Close

func (c *Component) Close() error

func (*Component) Init

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

func (*Component) LoadOne

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

func (*Component) Run

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

type ComponentConfig

type ComponentConfig struct {
	MaxConnTime   int `json:"max_con_time"    yaml:"max_con_time"`
	MaxIdleTime   int `json:"max_idle_time"   yaml:"max_idle_time"`
	KeepAliveTime int `json:"keep_alive_time" yaml:"keep_alive_time"`
	SlowThreshold int `json:"slow_threshold"  yaml:"slow_threshold"`
}