in internal/mode/advanced/elastic/elastic.go [42:58]
func ReadConfig(r io.Reader) (*Config, error) {
var out Config
if err := json.NewDecoder(r).Decode(&out); err != nil {
return nil, err
}
if out.MaxBulkSize == 0 {
out.MaxBulkSize = DefaultMaxBulkSize
}
if out.BulkWorkers == 0 {
out.BulkWorkers = DefaultBulkWorkers
}
return &out, nil
}