dump_hash

type Config struct {
	//字段名称必须是大写
	PartitionSize       int                          `config:"partition_size"`
	BatchSize           int                          `config:"batch_size"`
	SliceSize           int                          `config:"slice_size"`
	Elasticsearch       string                       `config:"elasticsearch"`
	ElasticsearchConfig *elastic.ElasticsearchConfig `config:"elasticsearch_config"`
	Output              string                       `config:"output_queue"`
	SortType            string                       `config:"sort_type"`
	SortField           string                       `config:"sort_field"`
	Indices             string                       `config:"indices"`
	CleanOldFiles       bool                         `config:"clean_old_files"`
	KeepSourceInResult  bool                         `config:"keep_source"`

	QueryString string `config:"query_string"`
	QueryDSL    string `config:"query_dsl"`

	HashFunc     string              `config:"hash_func"`
	ScrollTime   string              `config:"scroll_time"`
	Fields       string              `config:"fields"`
	RotateConfig rotate.RotateConfig `config:"rotate"`
}

type DumpHashProcessor struct {
	HTTPPool *fasthttp.RequestResponsePool
	// contains filtered or unexported fields
}