in config.go [344:355]
func BulkIndexerConfigFrom(cl elastictransport.Interface, cfg Config) BulkIndexerConfig {
return BulkIndexerConfig{
Client: cl,
MaxDocumentRetries: cfg.MaxDocumentRetries,
RetryOnDocumentStatus: cfg.RetryOnDocumentStatus,
CompressionLevel: cfg.CompressionLevel,
Pipeline: cfg.Pipeline,
RequireDataStream: cfg.RequireDataStream,
IncludeSourceOnError: cfg.IncludeSourceOnError,
PopulateFailedDocsInput: cfg.PopulateFailedDocsInput,
}
}