Skip to content
Closed
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 @@ -116,6 +116,7 @@
import co.elastic.clients.elasticsearch.core.UpdateRequest;
import co.elastic.clients.elasticsearch.core.UpdateResponse;
import co.elastic.clients.elasticsearch.dangling_indices.ElasticsearchDanglingIndicesAsyncClient;
import co.elastic.clients.elasticsearch.encryption.ElasticsearchEncryptionAsyncClient;
import co.elastic.clients.elasticsearch.enrich.ElasticsearchEnrichAsyncClient;
import co.elastic.clients.elasticsearch.eql.ElasticsearchEqlAsyncClient;
import co.elastic.clients.elasticsearch.esql.ElasticsearchEsqlAsyncClient;
Expand Down Expand Up @@ -246,6 +247,10 @@ public ElasticsearchDanglingIndicesAsyncClient danglingIndices() {
return new ElasticsearchDanglingIndicesAsyncClient(this.transport, this.transportOptions);
}

public ElasticsearchEncryptionAsyncClient encryption() {
return new ElasticsearchEncryptionAsyncClient(this.transport, this.transportOptions);
}

public ElasticsearchEnrichAsyncClient enrich() {
return new ElasticsearchEnrichAsyncClient(this.transport, this.transportOptions);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,7 @@
import co.elastic.clients.elasticsearch.core.UpdateRequest;
import co.elastic.clients.elasticsearch.core.UpdateResponse;
import co.elastic.clients.elasticsearch.dangling_indices.ElasticsearchDanglingIndicesClient;
import co.elastic.clients.elasticsearch.encryption.ElasticsearchEncryptionClient;
import co.elastic.clients.elasticsearch.enrich.ElasticsearchEnrichClient;
import co.elastic.clients.elasticsearch.eql.ElasticsearchEqlClient;
import co.elastic.clients.elasticsearch.esql.ElasticsearchEsqlClient;
Expand Down Expand Up @@ -246,6 +247,10 @@ public ElasticsearchDanglingIndicesClient danglingIndices() {
return new ElasticsearchDanglingIndicesClient(this.transport, this.transportOptions);
}

public ElasticsearchEncryptionClient encryption() {
return new ElasticsearchEncryptionClient(this.transport, this.transportOptions);
}

public ElasticsearchEnrichClient enrich() {
return new ElasticsearchEnrichClient(this.transport, this.transportOptions);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,11 @@ public class FlushStats implements JsonpSerializable {

private final long totalTimeInMillis;

@Nullable
private final Time totalTimeExcludingWaiting;

private final long totalTimeExcludingWaitingOnLockInMillis;

// ---------------------------------------------------------------------------------------------

private FlushStats(Builder builder) {
Expand All @@ -76,6 +81,9 @@ private FlushStats(Builder builder) {
this.total = ApiTypeHelper.requireNonNull(builder.total, this, "total", 0);
this.totalTime = builder.totalTime;
this.totalTimeInMillis = ApiTypeHelper.requireNonNull(builder.totalTimeInMillis, this, "totalTimeInMillis", 0);
this.totalTimeExcludingWaiting = builder.totalTimeExcludingWaiting;
this.totalTimeExcludingWaitingOnLockInMillis = ApiTypeHelper.requireNonNull(
builder.totalTimeExcludingWaitingOnLockInMillis, this, "totalTimeExcludingWaitingOnLockInMillis", 0);

}

Expand Down Expand Up @@ -112,6 +120,21 @@ public final long totalTimeInMillis() {
return this.totalTimeInMillis;
}

/**
* API name: {@code total_time_excluding_waiting}
*/
@Nullable
public final Time totalTimeExcludingWaiting() {
return this.totalTimeExcludingWaiting;
}

/**
* Required - API name: {@code total_time_excluding_waiting_on_lock_in_millis}
*/
public final long totalTimeExcludingWaitingOnLockInMillis() {
return this.totalTimeExcludingWaitingOnLockInMillis;
}

/**
* Serialize this object to JSON.
*/
Expand All @@ -137,6 +160,14 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("total_time_in_millis");
generator.write(this.totalTimeInMillis);

if (this.totalTimeExcludingWaiting != null) {
generator.writeKey("total_time_excluding_waiting");
this.totalTimeExcludingWaiting.serialize(generator, mapper);

}
generator.writeKey("total_time_excluding_waiting_on_lock_in_millis");
generator.write(this.totalTimeExcludingWaitingOnLockInMillis);

}

@Override
Expand All @@ -160,13 +191,20 @@ public static class Builder extends WithJsonObjectBuilderBase<Builder> implement

private Long totalTimeInMillis;

@Nullable
private Time totalTimeExcludingWaiting;

private Long totalTimeExcludingWaitingOnLockInMillis;

public Builder() {
}
private Builder(FlushStats instance) {
this.periodic = instance.periodic;
this.total = instance.total;
this.totalTime = instance.totalTime;
this.totalTimeInMillis = instance.totalTimeInMillis;
this.totalTimeExcludingWaiting = instance.totalTimeExcludingWaiting;
this.totalTimeExcludingWaitingOnLockInMillis = instance.totalTimeExcludingWaitingOnLockInMillis;

}
/**
Expand Down Expand Up @@ -208,6 +246,29 @@ public final Builder totalTimeInMillis(long value) {
return this;
}

/**
* API name: {@code total_time_excluding_waiting}
*/
public final Builder totalTimeExcludingWaiting(@Nullable Time value) {
this.totalTimeExcludingWaiting = value;
return this;
}

/**
* API name: {@code total_time_excluding_waiting}
*/
public final Builder totalTimeExcludingWaiting(Function<Time.Builder, ObjectBuilder<Time>> fn) {
return this.totalTimeExcludingWaiting(fn.apply(new Time.Builder()).build());
}

/**
* Required - API name: {@code total_time_excluding_waiting_on_lock_in_millis}
*/
public final Builder totalTimeExcludingWaitingOnLockInMillis(long value) {
this.totalTimeExcludingWaitingOnLockInMillis = value;
return this;
}

@Override
protected Builder self() {
return this;
Expand Down Expand Up @@ -246,6 +307,9 @@ protected static void setupFlushStatsDeserializer(ObjectDeserializer<FlushStats.
op.add(Builder::total, JsonpDeserializer.longDeserializer(), "total");
op.add(Builder::totalTime, Time._DESERIALIZER, "total_time");
op.add(Builder::totalTimeInMillis, JsonpDeserializer.longDeserializer(), "total_time_in_millis");
op.add(Builder::totalTimeExcludingWaiting, Time._DESERIALIZER, "total_time_excluding_waiting");
op.add(Builder::totalTimeExcludingWaitingOnLockInMillis, JsonpDeserializer.longDeserializer(),
"total_time_excluding_waiting_on_lock_in_millis");

}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ public class GetStats implements JsonpSerializable {
private final long missingTotal;

@Nullable
private final Time time;
private final Time gettime;

private final long timeInMillis;

Expand All @@ -95,7 +95,7 @@ private GetStats(Builder builder) {
this.missingTimeInMillis = ApiTypeHelper.requireNonNull(builder.missingTimeInMillis, this,
"missingTimeInMillis", 0);
this.missingTotal = ApiTypeHelper.requireNonNull(builder.missingTotal, this, "missingTotal", 0);
this.time = builder.time;
this.gettime = builder.gettime;
this.timeInMillis = ApiTypeHelper.requireNonNull(builder.timeInMillis, this, "timeInMillis", 0);
this.total = ApiTypeHelper.requireNonNull(builder.total, this, "total", 0);

Expand Down Expand Up @@ -157,11 +157,11 @@ public final long missingTotal() {
}

/**
* API name: {@code time}
* API name: {@code getTime}
*/
@Nullable
public final Time time() {
return this.time;
public final Time gettime() {
return this.gettime;
}

/**
Expand Down Expand Up @@ -214,9 +214,9 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("missing_total");
generator.write(this.missingTotal);

if (this.time != null) {
generator.writeKey("time");
this.time.serialize(generator, mapper);
if (this.gettime != null) {
generator.writeKey("getTime");
this.gettime.serialize(generator, mapper);

}
generator.writeKey("time_in_millis");
Expand Down Expand Up @@ -256,7 +256,7 @@ public static class Builder extends WithJsonObjectBuilderBase<Builder> implement
private Long missingTotal;

@Nullable
private Time time;
private Time gettime;

private Long timeInMillis;

Expand All @@ -272,7 +272,7 @@ private Builder(GetStats instance) {
this.missingTime = instance.missingTime;
this.missingTimeInMillis = instance.missingTimeInMillis;
this.missingTotal = instance.missingTotal;
this.time = instance.time;
this.gettime = instance.gettime;
this.timeInMillis = instance.timeInMillis;
this.total = instance.total;

Expand Down Expand Up @@ -348,18 +348,18 @@ public final Builder missingTotal(long value) {
}

/**
* API name: {@code time}
* API name: {@code getTime}
*/
public final Builder time(@Nullable Time value) {
this.time = value;
public final Builder gettime(@Nullable Time value) {
this.gettime = value;
return this;
}

/**
* API name: {@code time}
* API name: {@code getTime}
*/
public final Builder time(Function<Time.Builder, ObjectBuilder<Time>> fn) {
return this.time(fn.apply(new Time.Builder()).build());
public final Builder gettime(Function<Time.Builder, ObjectBuilder<Time>> fn) {
return this.gettime(fn.apply(new Time.Builder()).build());
}

/**
Expand Down Expand Up @@ -419,7 +419,7 @@ protected static void setupGetStatsDeserializer(ObjectDeserializer<GetStats.Buil
op.add(Builder::missingTime, Time._DESERIALIZER, "missing_time");
op.add(Builder::missingTimeInMillis, JsonpDeserializer.longDeserializer(), "missing_time_in_millis");
op.add(Builder::missingTotal, JsonpDeserializer.longDeserializer(), "missing_total");
op.add(Builder::time, Time._DESERIALIZER, "time");
op.add(Builder::gettime, Time._DESERIALIZER, "getTime");
op.add(Builder::timeInMillis, JsonpDeserializer.longDeserializer(), "time_in_millis");
op.add(Builder::total, JsonpDeserializer.longDeserializer(), "total");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,6 +92,8 @@ public class IndexingStats implements JsonpSerializable {

private final long indexFailed;

private final long indexFailedDueToVersionConflict;

private final Map<String, IndexingStats> types;

@Nullable
Expand Down Expand Up @@ -122,6 +124,8 @@ private IndexingStats(Builder builder) {
this.indexTimeInMillis = ApiTypeHelper.requireNonNull(builder.indexTimeInMillis, this, "indexTimeInMillis", 0);
this.indexTotal = ApiTypeHelper.requireNonNull(builder.indexTotal, this, "indexTotal", 0);
this.indexFailed = ApiTypeHelper.requireNonNull(builder.indexFailed, this, "indexFailed", 0);
this.indexFailedDueToVersionConflict = ApiTypeHelper.requireNonNull(builder.indexFailedDueToVersionConflict,
this, "indexFailedDueToVersionConflict", 0);
this.types = ApiTypeHelper.unmodifiable(builder.types);
this.writeLoad = builder.writeLoad;
this.recentWriteLoad = builder.recentWriteLoad;
Expand Down Expand Up @@ -227,6 +231,13 @@ public final long indexFailed() {
return this.indexFailed;
}

/**
* Required - API name: {@code index_failed_due_to_version_conflict}
*/
public final long indexFailedDueToVersionConflict() {
return this.indexFailedDueToVersionConflict;
}

/**
* API name: {@code types}
*/
Expand Down Expand Up @@ -314,6 +325,9 @@ protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
generator.writeKey("index_failed");
generator.write(this.indexFailed);

generator.writeKey("index_failed_due_to_version_conflict");
generator.write(this.indexFailedDueToVersionConflict);

if (ApiTypeHelper.isDefined(this.types)) {
generator.writeKey("types");
generator.writeStartObject();
Expand Down Expand Up @@ -384,6 +398,8 @@ public static class Builder extends WithJsonObjectBuilderBase<Builder> implement

private Long indexFailed;

private Long indexFailedDueToVersionConflict;

@Nullable
private Map<String, IndexingStats> types;

Expand Down Expand Up @@ -412,6 +428,7 @@ private Builder(IndexingStats instance) {
this.indexTimeInMillis = instance.indexTimeInMillis;
this.indexTotal = instance.indexTotal;
this.indexFailed = instance.indexFailed;
this.indexFailedDueToVersionConflict = instance.indexFailedDueToVersionConflict;
this.types = instance.types;
this.writeLoad = instance.writeLoad;
this.recentWriteLoad = instance.recentWriteLoad;
Expand Down Expand Up @@ -543,6 +560,14 @@ public final Builder indexFailed(long value) {
return this;
}

/**
* Required - API name: {@code index_failed_due_to_version_conflict}
*/
public final Builder indexFailedDueToVersionConflict(long value) {
this.indexFailedDueToVersionConflict = value;
return this;
}

/**
* API name: {@code types}
* <p>
Expand Down Expand Up @@ -643,6 +668,8 @@ protected static void setupIndexingStatsDeserializer(ObjectDeserializer<Indexing
op.add(Builder::indexTimeInMillis, JsonpDeserializer.longDeserializer(), "index_time_in_millis");
op.add(Builder::indexTotal, JsonpDeserializer.longDeserializer(), "index_total");
op.add(Builder::indexFailed, JsonpDeserializer.longDeserializer(), "index_failed");
op.add(Builder::indexFailedDueToVersionConflict, JsonpDeserializer.longDeserializer(),
"index_failed_due_to_version_conflict");
op.add(Builder::types, JsonpDeserializer.stringMapDeserializer(IndexingStats._DESERIALIZER), "types");
op.add(Builder::writeLoad, JsonpDeserializer.doubleDeserializer(), "write_load");
op.add(Builder::recentWriteLoad, JsonpDeserializer.doubleDeserializer(), "recent_write_load");
Expand Down
Loading
Loading