in Elastic.SemanticKernel.Connectors.Elasticsearch/MockableElasticsearchClient.cs [222:246]
public virtual async Task<string> IndexDocumentAsync<TDocument>(
IndexName indexName,
Id id,
TDocument document,
CancellationToken cancellationToken = default)
{
Verify.NotNull(indexName);
Verify.NotNull(document);
var response = await ElasticsearchClient
.IndexAsync(
new IndexRequest<TDocument>(document, indexName, id)
{
RequestConfiguration = CustomUserAgentRequestConfiguration
},
cancellationToken)
.ConfigureAwait(false);
if (!response.IsSuccess())
{
throw new TransportException(PipelineFailure.Unexpected, "Failed to execute request.", response);
}
return response.Id;
}