esHandler

Documentation

Index

• Variables
• func EsInit(dumpInfo DumpInfo)
• func Exporter(dumpInfo *DumpInfo, ch chan string) (err error)
• func Importer(dumpInfo *DumpInfo, lineCount int, ch chan string)
• func Read(r io.Reader) string
• type DumpInfo
• type EsIndex

Variables

var (
	Es *elasticsearch.Client
)

Functions

func EsInit

func EsInit(dumpInfo DumpInfo)

func Exporter

func Exporter(dumpInfo *DumpInfo, ch chan string) (err error)

从elasticsearch中导出索引

func Importer

func Importer(dumpInfo *DumpInfo, lineCount int, ch chan string)

func Read

func Read(r io.Reader) string

Types

type DumpInfo

type DumpInfo struct {
	User     string
	Password string
	Host     string
	Index    string
	Size     int
	Query    string
}

type EsIndex

type EsIndex struct {
	Index string `json:"_index"`
	Type  string `json:"_type"`
	Id    string `json:"_id"`
}