in src/Traits/ClientEndpointsTrait.php [65:84]
public function bulk(?array $params = null)
{
$params = $params ?? [];
$this->checkRequiredParameters(['body'], $params);
if (isset($params['index'])) {
$url = '/' . $this->encode($params['index']) . '/_bulk';
$method = 'POST';
} else {
$url = '/_bulk';
$method = 'POST';
}
$url = $this->addQueryString($url, $params, ['wait_for_active_shards','refresh','routing','timeout','_source','_source_excludes','_source_includes','pipeline','require_alias','require_data_stream','list_executed_pipelines','include_source_on_error','pretty','human','error_trace','source','filter_path']);
$headers = [
'Accept' => 'application/json',
'Content-Type' => 'application/x-ndjson',
];
$request = $this->createRequest($method, $url, $headers, $params['body'] ?? null);
$request = $this->addOtelAttributes($params, ['index'], $request, 'bulk');
return $this->sendRequest($request);
}