inputs

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

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

type IInput interface {
	GetTemplates(ctx context.Context) (map[string]any, error)
	GetIndices(ctx context.Context) ([]string, error)
	GetIndicesSetting(ctx context.Context, indices string) ([]byte, error)
	GetIndicesAliases(ctx context.Context, indices string) (map[string][]string, error)
	ProcessIndicesData(ctx context.Context, options ...Option) error
}

type Option func(*Options)

type Options struct {
	Indices              string                                                             // 必填：索引名称，多个用逗号分隔
	Size                 int                                                                // 必填：每批次查询的数量，必须>0
	ScrollID             string                                                             // 可选：滚动ID，首次查询可为空
	Query                string                                                             // 可选：DSL查询语句，默认查询所有
	DocsProcess          func(docs []map[string]interface{}, scrollID string, docCount int) // 文档处理函数
	BuildBulkBodyProcess func(bulkBody bytes.Buffer, scrollID string, docCount int) error   // 批量构建处理函数
}

type ScrollConfig struct {
	Index    string
	Size     int
	Query    string
	ScrollID string
	Timeout  time.Duration
}