esHandler

Documentation

Index

• Variables
• func EsInit(dumpInfo DumpInfo)
• func Exporter(dumpInfo *DumpInfo, ch chan string) (err error)
• func MetaData(str string, dumpInfo *DumpInfo) (mate, data []byte)
• func PipeImporter(dumpInfo *DumpInfo, 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)

Exporter 从elasticsearch中导出索引

func MetaData

func MetaData(str string, dumpInfo *DumpInfo) (mate, data []byte)

func PipeImporter

func PipeImporter(dumpInfo *DumpInfo, 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
	ExistsFilter string
}

type EsIndex

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