es

Documentation

Index

• type BulkCfg
• type ESWriter
  • func NewEsWriter(name string, cfg *EsCfg) (*ESWriter, error)
  • func (w *ESWriter) Add(doc interface{}, indexs ...string)
  • func (w *ESWriter) Close() error
  • func (w *ESWriter) SetIndex(index string)
• type EsCfg

Types

type BulkCfg

type BulkCfg struct {
	BulkActions int `yaml:"bulk_actions" json:"bulk_actions"`
	Workers     int `yaml:"workers" json:"workers"`
}

type ESWriter

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

func NewEsWriter

func NewEsWriter(name string, cfg *EsCfg) (*ESWriter, error)

func (*ESWriter) Add

func (w *ESWriter) Add(doc interface{}, indexs ...string)

func (*ESWriter) Close

func (w *ESWriter) Close() error

func (*ESWriter) SetIndex

func (w *ESWriter) SetIndex(index string)

type EsCfg

type EsCfg struct {
	Addr     string  `yaml:"addr" json:"addr"`
	User     string  `yaml:"user" json:"user"`
	Password string  `yaml:"password" json:"password"`
	Index    string  `yaml:"index" json:"index"`
	BulkCfg  BulkCfg `yaml:"bulk_cfg" json:"bulk_cfg"`
}