Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
Original file line number Diff line number Diff line change
Expand Up @@ -100,6 +100,7 @@ internal static class ApiUrlLookup
internal static ApiUrls IndexManagementDeleteDataStream = new ApiUrls(new[] { "_data_stream/{name}" });
internal static ApiUrls IndexManagementDeleteDataStreamOptions = new ApiUrls(new[] { "_data_stream/{name}/_options" });
internal static ApiUrls IndexManagementDeleteIndexTemplate = new ApiUrls(new[] { "_index_template/{name}" });
internal static ApiUrls IndexManagementDeleteSampleConfiguration = new ApiUrls(new[] { "{index}/_sample/config" });
internal static ApiUrls IndexManagementDeleteTemplate = new ApiUrls(new[] { "_template/{name}" });
internal static ApiUrls IndexManagementDiskUsage = new ApiUrls(new[] { "{index}/_disk_usage" });
internal static ApiUrls IndexManagementDownsample = new ApiUrls(new[] { "{index}/_downsample/{target_index}" });
Expand All @@ -113,6 +114,7 @@ internal static class ApiUrlLookup
internal static ApiUrls IndexManagementForcemerge = new ApiUrls(new[] { "_forcemerge", "{index}/_forcemerge" });
internal static ApiUrls IndexManagementGet = new ApiUrls(new[] { "{index}" });
internal static ApiUrls IndexManagementGetAlias = new ApiUrls(new[] { "_alias", "_alias/{name}", "{index}/_alias/{name}", "{index}/_alias" });
internal static ApiUrls IndexManagementGetAllSampleConfiguration = new ApiUrls(new[] { "_sample/config" });
internal static ApiUrls IndexManagementGetDataLifecycle = new ApiUrls(new[] { "_data_stream/{name}/_lifecycle" });
internal static ApiUrls IndexManagementGetDataLifecycleStats = new ApiUrls(new[] { "_lifecycle/stats" });
internal static ApiUrls IndexManagementGetDataStream = new ApiUrls(new[] { "_data_stream", "_data_stream/{name}" });
Expand All @@ -124,6 +126,7 @@ internal static class ApiUrlLookup
internal static ApiUrls IndexManagementGetMapping = new ApiUrls(new[] { "_mapping", "{index}/_mapping" });
internal static ApiUrls IndexManagementGetMigrateReindexStatus = new ApiUrls(new[] { "_migration/reindex/{index}/_status" });
internal static ApiUrls IndexManagementGetSample = new ApiUrls(new[] { "{index}/_sample" });
internal static ApiUrls IndexManagementGetSampleConfiguration = new ApiUrls(new[] { "{index}/_sample/config" });
internal static ApiUrls IndexManagementGetSampleStats = new ApiUrls(new[] { "{index}/_sample/stats" });
internal static ApiUrls IndexManagementGetSettings = new ApiUrls(new[] { "_settings", "{index}/_settings", "{index}/_settings/{name}", "_settings/{name}" });
internal static ApiUrls IndexManagementGetTemplate = new ApiUrls(new[] { "_template", "_template/{name}" });
Expand All @@ -139,6 +142,7 @@ internal static class ApiUrlLookup
internal static ApiUrls IndexManagementPutDataStreamSettings = new ApiUrls(new[] { "_data_stream/{name}/_settings" });
internal static ApiUrls IndexManagementPutIndexTemplate = new ApiUrls(new[] { "_index_template/{name}" });
internal static ApiUrls IndexManagementPutMapping = new ApiUrls(new[] { "{index}/_mapping" });
internal static ApiUrls IndexManagementPutSampleConfiguration = new ApiUrls(new[] { "{index}/_sample/config" });
internal static ApiUrls IndexManagementPutSettings = new ApiUrls(new[] { "_settings", "{index}/_settings" });
internal static ApiUrls IndexManagementPutTemplate = new ApiUrls(new[] { "_template/{name}" });
internal static ApiUrls IndexManagementRecovery = new ApiUrls(new[] { "_recovery", "{index}/_recovery" });
Expand Down Expand Up @@ -183,6 +187,7 @@ internal static class ApiUrlLookup
internal static ApiUrls InferencePutLlama = new ApiUrls(new[] { "_inference/{task_type}/{llama_inference_id}" });
internal static ApiUrls InferencePutMistral = new ApiUrls(new[] { "_inference/{task_type}/{mistral_inference_id}" });
internal static ApiUrls InferencePutOpenai = new ApiUrls(new[] { "_inference/{task_type}/{openai_inference_id}" });
internal static ApiUrls InferencePutOpenshiftAi = new ApiUrls(new[] { "_inference/{task_type}/{openshiftai_inference_id}" });
internal static ApiUrls InferencePutVoyageai = new ApiUrls(new[] { "_inference/{task_type}/{voyageai_inference_id}" });
internal static ApiUrls InferencePutWatsonx = new ApiUrls(new[] { "_inference/{task_type}/{watsonx_inference_id}" });
internal static ApiUrls InferenceRerank = new ApiUrls(new[] { "_inference/rerank/{inference_id}" });
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ public sealed partial class AsyncSearchStatusResponseConverter : System.Text.Jso
private static readonly System.Text.Json.JsonEncodedText PropCompletionStatus = System.Text.Json.JsonEncodedText.Encode("completion_status");
private static readonly System.Text.Json.JsonEncodedText PropCompletionTime = System.Text.Json.JsonEncodedText.Encode("completion_time");
private static readonly System.Text.Json.JsonEncodedText PropCompletionTimeInMillis = System.Text.Json.JsonEncodedText.Encode("completion_time_in_millis");
private static readonly System.Text.Json.JsonEncodedText PropError = System.Text.Json.JsonEncodedText.Encode("error");
private static readonly System.Text.Json.JsonEncodedText PropExpirationTime = System.Text.Json.JsonEncodedText.Encode("expiration_time");
private static readonly System.Text.Json.JsonEncodedText PropExpirationTimeInMillis = System.Text.Json.JsonEncodedText.Encode("expiration_time_in_millis");
private static readonly System.Text.Json.JsonEncodedText PropId = System.Text.Json.JsonEncodedText.Encode("id");
Expand All @@ -45,6 +46,7 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.AsyncSearchStatusRespo
LocalJsonValue<int?> propCompletionStatus = default;
LocalJsonValue<System.DateTimeOffset?> propCompletionTime = default;
LocalJsonValue<System.DateTimeOffset?> propCompletionTimeInMillis = default;
LocalJsonValue<Elastic.Clients.Elasticsearch.ErrorCause?> propError = default;
LocalJsonValue<System.DateTimeOffset?> propExpirationTime = default;
LocalJsonValue<System.DateTimeOffset> propExpirationTimeInMillis = default;
LocalJsonValue<string?> propId = default;
Expand Down Expand Up @@ -75,6 +77,11 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.AsyncSearchStatusRespo
continue;
}

if (propError.TryReadProperty(ref reader, options, PropError, null))
{
continue;
}

if (propExpirationTime.TryReadProperty(ref reader, options, PropExpirationTime, static System.DateTimeOffset? (ref System.Text.Json.Utf8JsonReader r, System.Text.Json.JsonSerializerOptions o) => r.ReadNullableValueEx<System.DateTimeOffset>(o, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker))))
{
continue;
Expand Down Expand Up @@ -131,6 +138,7 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.AsyncSearchStatusRespo
CompletionStatus = propCompletionStatus.Value,
CompletionTime = propCompletionTime.Value,
CompletionTimeInMillis = propCompletionTimeInMillis.Value,
Error = propError.Value,
ExpirationTime = propExpirationTime.Value,
ExpirationTimeInMillis = propExpirationTimeInMillis.Value,
Id = propId.Value,
Expand All @@ -149,6 +157,7 @@ public override void Write(System.Text.Json.Utf8JsonWriter writer, Elastic.Clien
writer.WriteProperty(options, PropCompletionStatus, value.CompletionStatus, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, int? v) => w.WriteNullableValue<int>(o, v));
writer.WriteProperty(options, PropCompletionTime, value.CompletionTime, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker)));
writer.WriteProperty(options, PropCompletionTimeInMillis, value.CompletionTimeInMillis, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMillisMarker)));
writer.WriteProperty(options, PropError, value.Error, null, null);
writer.WriteProperty(options, PropExpirationTime, value.ExpirationTime, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker)));
writer.WriteProperty(options, PropExpirationTimeInMillis, value.ExpirationTimeInMillis, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset v) => w.WriteValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMillisMarker)));
writer.WriteProperty(options, PropId, value.Id, null, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,7 @@ internal AsyncSearchStatusResponse(Elastic.Clients.Elasticsearch.Serialization.J
/// </summary>
public System.DateTimeOffset? CompletionTime { get; set; }
public System.DateTimeOffset? CompletionTimeInMillis { get; set; }
public Elastic.Clients.Elasticsearch.ErrorCause? Error { get; set; }

/// <summary>
/// <para>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ public sealed partial class GetAsyncSearchResponseConverter<TDocument> : System.
{
private static readonly System.Text.Json.JsonEncodedText PropCompletionTime = System.Text.Json.JsonEncodedText.Encode("completion_time");
private static readonly System.Text.Json.JsonEncodedText PropCompletionTimeInMillis = System.Text.Json.JsonEncodedText.Encode("completion_time_in_millis");
private static readonly System.Text.Json.JsonEncodedText PropError = System.Text.Json.JsonEncodedText.Encode("error");
private static readonly System.Text.Json.JsonEncodedText PropExpirationTime = System.Text.Json.JsonEncodedText.Encode("expiration_time");
private static readonly System.Text.Json.JsonEncodedText PropExpirationTimeInMillis = System.Text.Json.JsonEncodedText.Encode("expiration_time_in_millis");
private static readonly System.Text.Json.JsonEncodedText PropId = System.Text.Json.JsonEncodedText.Encode("id");
Expand All @@ -41,6 +42,7 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.GetAsyncSearchResponse
reader.ValidateToken(System.Text.Json.JsonTokenType.StartObject);
LocalJsonValue<System.DateTimeOffset?> propCompletionTime = default;
LocalJsonValue<System.DateTimeOffset?> propCompletionTimeInMillis = default;
LocalJsonValue<Elastic.Clients.Elasticsearch.ErrorCause?> propError = default;
LocalJsonValue<System.DateTimeOffset?> propExpirationTime = default;
LocalJsonValue<System.DateTimeOffset> propExpirationTimeInMillis = default;
LocalJsonValue<string?> propId = default;
Expand All @@ -61,6 +63,11 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.GetAsyncSearchResponse
continue;
}

if (propError.TryReadProperty(ref reader, options, PropError, null))
{
continue;
}

if (propExpirationTime.TryReadProperty(ref reader, options, PropExpirationTime, static System.DateTimeOffset? (ref System.Text.Json.Utf8JsonReader r, System.Text.Json.JsonSerializerOptions o) => r.ReadNullableValueEx<System.DateTimeOffset>(o, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker))))
{
continue;
Expand Down Expand Up @@ -115,6 +122,7 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.GetAsyncSearchResponse
{
CompletionTime = propCompletionTime.Value,
CompletionTimeInMillis = propCompletionTimeInMillis.Value,
Error = propError.Value,
ExpirationTime = propExpirationTime.Value,
ExpirationTimeInMillis = propExpirationTimeInMillis.Value,
Id = propId.Value,
Expand All @@ -131,6 +139,7 @@ public override void Write(System.Text.Json.Utf8JsonWriter writer, Elastic.Clien
writer.WriteStartObject();
writer.WriteProperty(options, PropCompletionTime, value.CompletionTime, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker)));
writer.WriteProperty(options, PropCompletionTimeInMillis, value.CompletionTimeInMillis, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMillisMarker)));
writer.WriteProperty(options, PropError, value.Error, null, null);
writer.WriteProperty(options, PropExpirationTime, value.ExpirationTime, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker)));
writer.WriteProperty(options, PropExpirationTimeInMillis, value.ExpirationTimeInMillis, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset v) => w.WriteValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMillisMarker)));
writer.WriteProperty(options, PropId, value.Id, null, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ internal GetAsyncSearchResponse(Elastic.Clients.Elasticsearch.Serialization.Json
/// </summary>
public System.DateTimeOffset? CompletionTime { get; set; }
public System.DateTimeOffset? CompletionTimeInMillis { get; set; }
public Elastic.Clients.Elasticsearch.ErrorCause? Error { get; set; }

/// <summary>
/// <para>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ public sealed partial class SubmitAsyncSearchResponseConverter<TDocument> : Syst
{
private static readonly System.Text.Json.JsonEncodedText PropCompletionTime = System.Text.Json.JsonEncodedText.Encode("completion_time");
private static readonly System.Text.Json.JsonEncodedText PropCompletionTimeInMillis = System.Text.Json.JsonEncodedText.Encode("completion_time_in_millis");
private static readonly System.Text.Json.JsonEncodedText PropError = System.Text.Json.JsonEncodedText.Encode("error");
private static readonly System.Text.Json.JsonEncodedText PropExpirationTime = System.Text.Json.JsonEncodedText.Encode("expiration_time");
private static readonly System.Text.Json.JsonEncodedText PropExpirationTimeInMillis = System.Text.Json.JsonEncodedText.Encode("expiration_time_in_millis");
private static readonly System.Text.Json.JsonEncodedText PropId = System.Text.Json.JsonEncodedText.Encode("id");
Expand All @@ -41,6 +42,7 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.SubmitAsyncSearchRespo
reader.ValidateToken(System.Text.Json.JsonTokenType.StartObject);
LocalJsonValue<System.DateTimeOffset?> propCompletionTime = default;
LocalJsonValue<System.DateTimeOffset?> propCompletionTimeInMillis = default;
LocalJsonValue<Elastic.Clients.Elasticsearch.ErrorCause?> propError = default;
LocalJsonValue<System.DateTimeOffset?> propExpirationTime = default;
LocalJsonValue<System.DateTimeOffset> propExpirationTimeInMillis = default;
LocalJsonValue<string?> propId = default;
Expand All @@ -61,6 +63,11 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.SubmitAsyncSearchRespo
continue;
}

if (propError.TryReadProperty(ref reader, options, PropError, null))
{
continue;
}

if (propExpirationTime.TryReadProperty(ref reader, options, PropExpirationTime, static System.DateTimeOffset? (ref System.Text.Json.Utf8JsonReader r, System.Text.Json.JsonSerializerOptions o) => r.ReadNullableValueEx<System.DateTimeOffset>(o, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker))))
{
continue;
Expand Down Expand Up @@ -115,6 +122,7 @@ public override Elastic.Clients.Elasticsearch.AsyncSearch.SubmitAsyncSearchRespo
{
CompletionTime = propCompletionTime.Value,
CompletionTimeInMillis = propCompletionTimeInMillis.Value,
Error = propError.Value,
ExpirationTime = propExpirationTime.Value,
ExpirationTimeInMillis = propExpirationTimeInMillis.Value,
Id = propId.Value,
Expand All @@ -131,6 +139,7 @@ public override void Write(System.Text.Json.Utf8JsonWriter writer, Elastic.Clien
writer.WriteStartObject();
writer.WriteProperty(options, PropCompletionTime, value.CompletionTime, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker)));
writer.WriteProperty(options, PropCompletionTimeInMillis, value.CompletionTimeInMillis, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMillisMarker)));
writer.WriteProperty(options, PropError, value.Error, null, null);
writer.WriteProperty(options, PropExpirationTime, value.ExpirationTime, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset? v) => w.WriteNullableValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMarker)));
writer.WriteProperty(options, PropExpirationTimeInMillis, value.ExpirationTimeInMillis, null, static (System.Text.Json.Utf8JsonWriter w, System.Text.Json.JsonSerializerOptions o, System.DateTimeOffset v) => w.WriteValueEx<System.DateTimeOffset>(o, v, typeof(Elastic.Clients.Elasticsearch.Serialization.DateTimeMillisMarker)));
writer.WriteProperty(options, PropId, value.Id, null, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ internal SubmitAsyncSearchResponse(Elastic.Clients.Elasticsearch.Serialization.J
/// </summary>
public System.DateTimeOffset? CompletionTime { get; set; }
public System.DateTimeOffset? CompletionTimeInMillis { get; set; }
public Elastic.Clients.Elasticsearch.ErrorCause? Error { get; set; }

/// <summary>
/// <para>
Expand Down
21 changes: 21 additions & 0 deletions src/Elastic.Clients.Elasticsearch/_Generated/Api/BulkRequest.g.cs
Original file line number Diff line number Diff line change
Expand Up @@ -127,6 +127,8 @@ public sealed partial class BulkRequestParameters : Elastic.Transport.RequestPar
/// <summary>
/// <para>
/// Bulk index or delete documents.
/// </para>
/// <para>
/// Perform multiple <c>index</c>, <c>create</c>, <c>delete</c>, and <c>update</c> actions in a single request.
/// This reduces overhead and can greatly increase indexing speed.
/// </para>
Expand Down Expand Up @@ -247,6 +249,11 @@ public sealed partial class BulkRequestParameters : Elastic.Transport.RequestPar
/// </item>
/// <item>
/// <para>
/// Java: Check out <c>co.elastic.clients.elasticsearch._helpers.bulk.BulkIngester</c>
/// </para>
/// </item>
/// <item>
/// <para>
/// .NET: Check out <c>BulkAllObservable</c>
/// </para>
/// </item>
Expand Down Expand Up @@ -461,6 +468,8 @@ internal BulkRequest(Elastic.Clients.Elasticsearch.Serialization.JsonConstructor
/// <summary>
/// <para>
/// Bulk index or delete documents.
/// </para>
/// <para>
/// Perform multiple <c>index</c>, <c>create</c>, <c>delete</c>, and <c>update</c> actions in a single request.
/// This reduces overhead and can greatly increase indexing speed.
/// </para>
Expand Down Expand Up @@ -581,6 +590,11 @@ internal BulkRequest(Elastic.Clients.Elasticsearch.Serialization.JsonConstructor
/// </item>
/// <item>
/// <para>
/// Java: Check out <c>co.elastic.clients.elasticsearch._helpers.bulk.BulkIngester</c>
/// </para>
/// </item>
/// <item>
/// <para>
/// .NET: Check out <c>BulkAllObservable</c>
/// </para>
/// </item>
Expand Down Expand Up @@ -945,6 +959,8 @@ public Elastic.Clients.Elasticsearch.BulkRequestDescriptor RequestConfiguration(
/// <summary>
/// <para>
/// Bulk index or delete documents.
/// </para>
/// <para>
/// Perform multiple <c>index</c>, <c>create</c>, <c>delete</c>, and <c>update</c> actions in a single request.
/// This reduces overhead and can greatly increase indexing speed.
/// </para>
Expand Down Expand Up @@ -1065,6 +1081,11 @@ public Elastic.Clients.Elasticsearch.BulkRequestDescriptor RequestConfiguration(
/// </item>
/// <item>
/// <para>
/// Java: Check out <c>co.elastic.clients.elasticsearch._helpers.bulk.BulkIngester</c>
/// </para>
/// </item>
/// <item>
/// <para>
/// .NET: Check out <c>BulkAllObservable</c>
/// </para>
/// </item>
Expand Down
Loading
Loading