Skip to content
Open
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
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,7 @@ internal static class ApiUrlLookup
internal static ApiUrls InferenceChatCompletionUnified = new ApiUrls(new[] { "_inference/chat_completion/{inference_id}/_stream" });
internal static ApiUrls InferenceCompletion = new ApiUrls(new[] { "_inference/completion/{inference_id}" });
internal static ApiUrls InferenceDelete = new ApiUrls(new[] { "_inference/{inference_id}", "_inference/{task_type}/{inference_id}" });
internal static ApiUrls InferenceGet = new ApiUrls(new[] { "_inference", "_inference/{inference_id}", "_inference/{task_type}/{inference_id}" });
internal static ApiUrls InferenceGet = new ApiUrls(new[] { "_inference", "_inference/{inference_id}", "_inference/{task_type}/{inference_id}", "_inference/{task_type}/_all" });
internal static ApiUrls InferenceInference = new ApiUrls(new[] { "_inference/{inference_id}", "_inference/{task_type}/{inference_id}" });
internal static ApiUrls InferencePut = new ApiUrls(new[] { "_inference/{inference_id}", "_inference/{task_type}/{inference_id}" });
internal static ApiUrls InferencePutAlibabacloud = new ApiUrls(new[] { "_inference/{task_type}/{alibabacloud_inference_id}" });
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,9 @@ public sealed partial class PutDataStreamSettingsRequestParameters : Elastic.Tra
/// Update data stream settings.
/// </para>
/// <para>
/// NOTE: Available in 8.19. Not available in earlier versions.
/// </para>
/// <para>
/// This API can be used to override settings on specific data streams. These overrides will take precedence over what
/// is specified in the template that the data stream matches. To prevent your data stream from getting into an invalid state,
/// only certain settings are allowed. If possible, the setting change is applied to all
Expand Down Expand Up @@ -136,6 +139,9 @@ internal PutDataStreamSettingsRequest(Elastic.Clients.Elasticsearch.Serializatio
/// Update data stream settings.
/// </para>
/// <para>
/// NOTE: Available in 8.19. Not available in earlier versions.
/// </para>
/// <para>
/// This API can be used to override settings on specific data streams. These overrides will take precedence over what
/// is specified in the template that the data stream matches. To prevent your data stream from getting into an invalid state,
/// only certain settings are allowed. If possible, the setting change is applied to all
Expand Down Expand Up @@ -302,6 +308,9 @@ public Elastic.Clients.Elasticsearch.IndexManagement.PutDataStreamSettingsReques
/// Update data stream settings.
/// </para>
/// <para>
/// NOTE: Available in 8.19. Not available in earlier versions.
/// </para>
/// <para>
/// This API can be used to override settings on specific data streams. These overrides will take precedence over what
/// is specified in the template that the data stream matches. To prevent your data stream from getting into an invalid state,
/// only certain settings are allowed. If possible, the setting change is applied to all
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,10 @@ public GetInferenceRequest(Elastic.Clients.Elasticsearch.Inference.TaskType? tas
{
}

public GetInferenceRequest(Elastic.Clients.Elasticsearch.Inference.TaskType? taskType) : base(r => r.Optional("task_type", taskType))
{
}

public GetInferenceRequest()
{
}
Expand All @@ -63,14 +67,15 @@ internal GetInferenceRequest(Elastic.Clients.Elasticsearch.Serialization.JsonCon

/// <summary>
/// <para>
/// The inference Id
/// The inference Id of the endpoint to return. Using <c>_all</c> or <c>*</c> will return all endpoints with the specified
/// <c>task_type</c> if one is specified, or all endpoints for all task types if no <c>task_type</c> is specified
/// </para>
/// </summary>
public Elastic.Clients.Elasticsearch.Id? InferenceId { get => P<Elastic.Clients.Elasticsearch.Id?>("inference_id"); set => PO("inference_id", value); }

/// <summary>
/// <para>
/// The task type
/// The task type of the endpoint to return
/// </para>
/// </summary>
public Elastic.Clients.Elasticsearch.Inference.TaskType? TaskType { get => P<Elastic.Clients.Elasticsearch.Inference.TaskType?>("task_type"); set => PO("task_type", value); }
Expand Down Expand Up @@ -101,6 +106,11 @@ public GetInferenceRequestDescriptor(Elastic.Clients.Elasticsearch.Inference.Tas
Instance = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest(taskType, inferenceId);
}

public GetInferenceRequestDescriptor(Elastic.Clients.Elasticsearch.Inference.TaskType? taskType)
{
Instance = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest(taskType);
}

public GetInferenceRequestDescriptor()
{
Instance = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest(Elastic.Clients.Elasticsearch.Serialization.JsonConstructorSentinel.Instance);
Expand All @@ -111,7 +121,8 @@ public GetInferenceRequestDescriptor()

/// <summary>
/// <para>
/// The inference Id
/// The inference Id of the endpoint to return. Using <c>_all</c> or <c>*</c> will return all endpoints with the specified
/// <c>task_type</c> if one is specified, or all endpoints for all task types if no <c>task_type</c> is specified
/// </para>
/// </summary>
public Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor InferenceId(Elastic.Clients.Elasticsearch.Id? value)
Expand All @@ -122,7 +133,7 @@ public Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor Inf

/// <summary>
/// <para>
/// The task type
/// The task type of the endpoint to return
/// </para>
/// </summary>
public Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor TaskType(Elastic.Clients.Elasticsearch.Inference.TaskType? value)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ public sealed partial class GetSnapshotRequestParameters : Elastic.Transport.Req
/// <summary>
/// <para>
/// The maximum number of snapshots to return.
/// The default is 0, which means to return all that match the request without limit.
/// The default is -1, which means to return all that match the request without limit.
/// </para>
/// </summary>
public int? Size { get => Q<int?>("size"); set => Q("size", value); }
Expand Down Expand Up @@ -270,7 +270,7 @@ internal GetSnapshotRequest(Elastic.Clients.Elasticsearch.Serialization.JsonCons
/// <summary>
/// <para>
/// The maximum number of snapshots to return.
/// The default is 0, which means to return all that match the request without limit.
/// The default is -1, which means to return all that match the request without limit.
/// </para>
/// </summary>
public int? Size { get => Q<int?>("size"); set => Q("size", value); }
Expand Down Expand Up @@ -485,7 +485,7 @@ public Elastic.Clients.Elasticsearch.Snapshot.GetSnapshotRequestDescriptor Order
/// <summary>
/// <para>
/// The maximum number of snapshots to return.
/// The default is 0, which means to return all that match the request without limit.
/// The default is -1, which means to return all that match the request without limit.
/// </para>
/// </summary>
public Elastic.Clients.Elasticsearch.Snapshot.GetSnapshotRequestDescriptor Size(int? value)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -267,6 +267,23 @@ public virtual Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse Get(
return DoRequest<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest, Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse, Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestParameters>(request);
}

public virtual Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse Get(Elastic.Clients.Elasticsearch.Inference.TaskType? taskType)
{
var builder = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor(taskType);
var request = builder.Instance;
request.BeforeRequest();
return DoRequest<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest, Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse, Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestParameters>(request);
}

public virtual Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse Get(Elastic.Clients.Elasticsearch.Inference.TaskType? taskType, System.Action<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor> action)
{
var builder = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor(taskType);
action.Invoke(builder);
var request = builder.Instance;
request.BeforeRequest();
return DoRequest<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest, Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse, Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestParameters>(request);
}

public virtual System.Threading.Tasks.Task<Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse> GetAsync(Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest request, System.Threading.CancellationToken cancellationToken = default)
{
request.BeforeRequest();
Expand Down Expand Up @@ -324,6 +341,23 @@ public virtual Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse Get(
return DoRequestAsync<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest, Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse, Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestParameters>(request, cancellationToken);
}

public virtual System.Threading.Tasks.Task<Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse> GetAsync(Elastic.Clients.Elasticsearch.Inference.TaskType? taskType, System.Threading.CancellationToken cancellationToken = default)
{
var builder = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor(taskType);
var request = builder.Instance;
request.BeforeRequest();
return DoRequestAsync<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest, Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse, Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestParameters>(request, cancellationToken);
}

public virtual System.Threading.Tasks.Task<Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse> GetAsync(Elastic.Clients.Elasticsearch.Inference.TaskType? taskType, System.Action<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor> action, System.Threading.CancellationToken cancellationToken = default)
{
var builder = new Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestDescriptor(taskType);
action.Invoke(builder);
var request = builder.Instance;
request.BeforeRequest();
return DoRequestAsync<Elastic.Clients.Elasticsearch.Inference.GetInferenceRequest, Elastic.Clients.Elasticsearch.Inference.GetInferenceResponse, Elastic.Clients.Elasticsearch.Inference.GetInferenceRequestParameters>(request, cancellationToken);
}

public virtual Elastic.Clients.Elasticsearch.Inference.InferenceResponse Inference(Elastic.Clients.Elasticsearch.Inference.InferenceRequest request)
{
request.BeforeRequest();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,23 +25,36 @@ namespace Elastic.Clients.Elasticsearch.Aggregations.Json;

public sealed partial class MultiTermLookupConverter : System.Text.Json.Serialization.JsonConverter<Elastic.Clients.Elasticsearch.Aggregations.MultiTermLookup>
{
private static readonly System.Text.Json.JsonEncodedText PropField = System.Text.Json.JsonEncodedText.Encode("field"u8);
private static readonly System.Text.Json.JsonEncodedText PropMissing = System.Text.Json.JsonEncodedText.Encode("missing"u8);
private static readonly System.Text.Json.JsonEncodedText VariantField = System.Text.Json.JsonEncodedText.Encode("field");
private static readonly System.Text.Json.JsonEncodedText VariantScript = System.Text.Json.JsonEncodedText.Encode("script");

public override Elastic.Clients.Elasticsearch.Aggregations.MultiTermLookup Read(ref System.Text.Json.Utf8JsonReader reader, System.Type typeToConvert, System.Text.Json.JsonSerializerOptions options)
{
reader.ValidateToken(System.Text.Json.JsonTokenType.StartObject);
LocalJsonValue<Elastic.Clients.Elasticsearch.Field> propField = default;
LocalJsonValue<object?> propMissing = default;
string? variantType = null;
object? variant = null;
while (reader.Read() && reader.TokenType is System.Text.Json.JsonTokenType.PropertyName)
{
if (propField.TryReadProperty(ref reader, options, PropField, null))
if (propMissing.TryReadProperty(ref reader, options, PropMissing, null))
{
continue;
}

if (propMissing.TryReadProperty(ref reader, options, PropMissing, null))
if (reader.ValueTextEquals(VariantField))
{
variantType = VariantField.Value;
reader.Read();
variant = reader.ReadValue<Elastic.Clients.Elasticsearch.Field>(options, null);
continue;
}

if (reader.ValueTextEquals(VariantScript))
{
variantType = VariantScript.Value;
reader.Read();
variant = reader.ReadValue<Elastic.Clients.Elasticsearch.Script>(options, null);
continue;
}

Expand All @@ -57,15 +70,29 @@ public override Elastic.Clients.Elasticsearch.Aggregations.MultiTermLookup Read(
reader.ValidateToken(System.Text.Json.JsonTokenType.EndObject);
return new Elastic.Clients.Elasticsearch.Aggregations.MultiTermLookup(Elastic.Clients.Elasticsearch.Serialization.JsonConstructorSentinel.Instance)
{
Field = propField.Value,
VariantType = variantType,
Variant = variant,
Missing = propMissing.Value
};
}

public override void Write(System.Text.Json.Utf8JsonWriter writer, Elastic.Clients.Elasticsearch.Aggregations.MultiTermLookup value, System.Text.Json.JsonSerializerOptions options)
{
writer.WriteStartObject();
writer.WriteProperty(options, PropField, value.Field, null, null);
switch (value.VariantType)
{
case null:
break;
case "field":
writer.WriteProperty(options, value.VariantType, (Elastic.Clients.Elasticsearch.Field)value.Variant, null, null);
break;
case "script":
writer.WriteProperty(options, value.VariantType, (Elastic.Clients.Elasticsearch.Script)value.Variant, null, null);
break;
default:
throw new System.Text.Json.JsonException($"Variant '{value.VariantType}' is not supported for type '{nameof(Elastic.Clients.Elasticsearch.Aggregations.MultiTermLookup)}'.");
}

writer.WriteProperty(options, PropMissing, value.Missing, null, null);
writer.WriteEndObject();
}
Expand Down
Loading
Loading