> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * Required - The unique identifier of the connector to be checked in
- *
- * API name: {@code connector_id}
- */
- public final String connectorId() {
- return this.connectorId;
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link CheckInRequest}.
- */
-
- public static class Builder extends RequestBase.AbstractBuilder implements ObjectBuilder {
- private String connectorId;
-
- /**
- * Required - The unique identifier of the connector to be checked in
- *
- * API name: {@code connector_id}
- */
- public final Builder connectorId(String value) {
- this.connectorId = value;
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link CheckInRequest}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public CheckInRequest build() {
- _checkSingleUse();
-
- return new CheckInRequest(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Endpoint "{@code connector.check_in}".
- */
- public static final Endpoint _ENDPOINT = new SimpleEndpoint<>(
- "es/connector.check_in",
-
- // Request method
- request -> {
- return "PUT";
-
- },
-
- // Request path
- request -> {
- final int _connectorId = 1 << 0;
-
- int propsSet = 0;
-
- propsSet |= _connectorId;
-
- if (propsSet == (_connectorId)) {
- StringBuilder buf = new StringBuilder();
- buf.append("/_connector");
- buf.append("/");
- SimpleEndpoint.pathEncode(request.connectorId, buf);
- buf.append("/_check_in");
- return buf.toString();
- }
- throw SimpleEndpoint.noPathTemplateFound("path");
-
- },
-
- // Path parameters
- request -> {
- Map params = new HashMap<>();
- final int _connectorId = 1 << 0;
-
- int propsSet = 0;
-
- propsSet |= _connectorId;
-
- if (propsSet == (_connectorId)) {
- params.put("connectorId", request.connectorId);
- }
- return params;
- },
-
- // Request parameters
- request -> {
- return Collections.emptyMap();
-
- }, SimpleEndpoint.emptyMap(), false, CheckInResponse._DESERIALIZER);
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CheckInResponse.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CheckInResponse.java
deleted file mode 100644
index a3ce1a027..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CheckInResponse.java
+++ /dev/null
@@ -1,153 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.elasticsearch._types.Result;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector.check_in.Response
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class CheckInResponse implements JsonpSerializable {
- private final Result result;
-
- // ---------------------------------------------------------------------------------------------
-
- private CheckInResponse(Builder builder) {
-
- this.result = ApiTypeHelper.requireNonNull(builder.result, this, "result");
-
- }
-
- public static CheckInResponse of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * Required - API name: {@code result}
- */
- public final Result result() {
- return this.result;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- generator.writeKey("result");
- this.result.serialize(generator, mapper);
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link CheckInResponse}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase implements ObjectBuilder {
- private Result result;
-
- /**
- * Required - API name: {@code result}
- */
- public final Builder result(Result value) {
- this.result = value;
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link CheckInResponse}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public CheckInResponse build() {
- _checkSingleUse();
-
- return new CheckInResponse(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link CheckInResponse}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer.lazy(Builder::new,
- CheckInResponse::setupCheckInResponseDeserializer);
-
- protected static void setupCheckInResponseDeserializer(ObjectDeserializer op) {
-
- op.add(Builder::result, Result._DESERIALIZER, "result");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/Connector.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/Connector.java
deleted file mode 100644
index efe33bfcf..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/Connector.java
+++ /dev/null
@@ -1,1025 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.DateTime;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.lang.Long;
-import java.lang.String;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.Connector
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class Connector implements JsonpSerializable {
- @Nullable
- private final String apiKeyId;
-
- private final Map configuration;
-
- private final Map customScheduling;
-
- @Nullable
- private final String description;
-
- @Nullable
- private final String error;
-
- @Nullable
- private final ConnectorFeatures features;
-
- private final List filtering;
-
- @Nullable
- private final String id;
-
- @Nullable
- private final String indexName;
-
- private final boolean isNative;
-
- @Nullable
- private final String language;
-
- @Nullable
- private final String lastAccessControlSyncError;
-
- @Nullable
- private final DateTime lastAccessControlSyncScheduledAt;
-
- @Nullable
- private final SyncStatus lastAccessControlSyncStatus;
-
- @Nullable
- private final Long lastDeletedDocumentCount;
-
- @Nullable
- private final DateTime lastIncrementalSyncScheduledAt;
-
- @Nullable
- private final Long lastIndexedDocumentCount;
-
- @Nullable
- private final DateTime lastSeen;
-
- @Nullable
- private final String lastSyncError;
-
- @Nullable
- private final DateTime lastSyncScheduledAt;
-
- @Nullable
- private final SyncStatus lastSyncStatus;
-
- @Nullable
- private final DateTime lastSynced;
-
- @Nullable
- private final String name;
-
- @Nullable
- private final IngestPipelineParams pipeline;
-
- private final SchedulingConfiguration scheduling;
-
- private final String serviceType;
-
- private final ConnectorStatus status;
-
- private final boolean syncNow;
-
- // ---------------------------------------------------------------------------------------------
-
- protected Connector(AbstractBuilder builder) {
-
- this.apiKeyId = builder.apiKeyId;
- this.configuration = ApiTypeHelper.unmodifiableRequired(builder.configuration, this, "configuration");
- this.customScheduling = ApiTypeHelper.unmodifiableRequired(builder.customScheduling, this, "customScheduling");
- this.description = builder.description;
- this.error = builder.error;
- this.features = builder.features;
- this.filtering = ApiTypeHelper.unmodifiableRequired(builder.filtering, this, "filtering");
- this.id = builder.id;
- this.indexName = builder.indexName;
- this.isNative = ApiTypeHelper.requireNonNull(builder.isNative, this, "isNative");
- this.language = builder.language;
- this.lastAccessControlSyncError = builder.lastAccessControlSyncError;
- this.lastAccessControlSyncScheduledAt = builder.lastAccessControlSyncScheduledAt;
- this.lastAccessControlSyncStatus = builder.lastAccessControlSyncStatus;
- this.lastDeletedDocumentCount = builder.lastDeletedDocumentCount;
- this.lastIncrementalSyncScheduledAt = builder.lastIncrementalSyncScheduledAt;
- this.lastIndexedDocumentCount = builder.lastIndexedDocumentCount;
- this.lastSeen = builder.lastSeen;
- this.lastSyncError = builder.lastSyncError;
- this.lastSyncScheduledAt = builder.lastSyncScheduledAt;
- this.lastSyncStatus = builder.lastSyncStatus;
- this.lastSynced = builder.lastSynced;
- this.name = builder.name;
- this.pipeline = builder.pipeline;
- this.scheduling = ApiTypeHelper.requireNonNull(builder.scheduling, this, "scheduling");
- this.serviceType = ApiTypeHelper.requireNonNull(builder.serviceType, this, "serviceType");
- this.status = ApiTypeHelper.requireNonNull(builder.status, this, "status");
- this.syncNow = ApiTypeHelper.requireNonNull(builder.syncNow, this, "syncNow");
-
- }
-
- public static Connector connectorOf(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * API name: {@code api_key_id}
- */
- @Nullable
- public final String apiKeyId() {
- return this.apiKeyId;
- }
-
- /**
- * Required - API name: {@code configuration}
- */
- public final Map configuration() {
- return this.configuration;
- }
-
- /**
- * Required - API name: {@code custom_scheduling}
- */
- public final Map customScheduling() {
- return this.customScheduling;
- }
-
- /**
- * API name: {@code description}
- */
- @Nullable
- public final String description() {
- return this.description;
- }
-
- /**
- * API name: {@code error}
- */
- @Nullable
- public final String error() {
- return this.error;
- }
-
- /**
- * API name: {@code features}
- */
- @Nullable
- public final ConnectorFeatures features() {
- return this.features;
- }
-
- /**
- * Required - API name: {@code filtering}
- */
- public final List filtering() {
- return this.filtering;
- }
-
- /**
- * API name: {@code id}
- */
- @Nullable
- public final String id() {
- return this.id;
- }
-
- /**
- * API name: {@code index_name}
- */
- @Nullable
- public final String indexName() {
- return this.indexName;
- }
-
- /**
- * Required - API name: {@code is_native}
- */
- public final boolean isNative() {
- return this.isNative;
- }
-
- /**
- * API name: {@code language}
- */
- @Nullable
- public final String language() {
- return this.language;
- }
-
- /**
- * API name: {@code last_access_control_sync_error}
- */
- @Nullable
- public final String lastAccessControlSyncError() {
- return this.lastAccessControlSyncError;
- }
-
- /**
- * API name: {@code last_access_control_sync_scheduled_at}
- */
- @Nullable
- public final DateTime lastAccessControlSyncScheduledAt() {
- return this.lastAccessControlSyncScheduledAt;
- }
-
- /**
- * API name: {@code last_access_control_sync_status}
- */
- @Nullable
- public final SyncStatus lastAccessControlSyncStatus() {
- return this.lastAccessControlSyncStatus;
- }
-
- /**
- * API name: {@code last_deleted_document_count}
- */
- @Nullable
- public final Long lastDeletedDocumentCount() {
- return this.lastDeletedDocumentCount;
- }
-
- /**
- * API name: {@code last_incremental_sync_scheduled_at}
- */
- @Nullable
- public final DateTime lastIncrementalSyncScheduledAt() {
- return this.lastIncrementalSyncScheduledAt;
- }
-
- /**
- * API name: {@code last_indexed_document_count}
- */
- @Nullable
- public final Long lastIndexedDocumentCount() {
- return this.lastIndexedDocumentCount;
- }
-
- /**
- * API name: {@code last_seen}
- */
- @Nullable
- public final DateTime lastSeen() {
- return this.lastSeen;
- }
-
- /**
- * API name: {@code last_sync_error}
- */
- @Nullable
- public final String lastSyncError() {
- return this.lastSyncError;
- }
-
- /**
- * API name: {@code last_sync_scheduled_at}
- */
- @Nullable
- public final DateTime lastSyncScheduledAt() {
- return this.lastSyncScheduledAt;
- }
-
- /**
- * API name: {@code last_sync_status}
- */
- @Nullable
- public final SyncStatus lastSyncStatus() {
- return this.lastSyncStatus;
- }
-
- /**
- * API name: {@code last_synced}
- */
- @Nullable
- public final DateTime lastSynced() {
- return this.lastSynced;
- }
-
- /**
- * API name: {@code name}
- */
- @Nullable
- public final String name() {
- return this.name;
- }
-
- /**
- * API name: {@code pipeline}
- */
- @Nullable
- public final IngestPipelineParams pipeline() {
- return this.pipeline;
- }
-
- /**
- * Required - API name: {@code scheduling}
- */
- public final SchedulingConfiguration scheduling() {
- return this.scheduling;
- }
-
- /**
- * Required - API name: {@code service_type}
- */
- public final String serviceType() {
- return this.serviceType;
- }
-
- /**
- * Required - API name: {@code status}
- */
- public final ConnectorStatus status() {
- return this.status;
- }
-
- /**
- * Required - API name: {@code sync_now}
- */
- public final boolean syncNow() {
- return this.syncNow;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- if (this.apiKeyId != null) {
- generator.writeKey("api_key_id");
- generator.write(this.apiKeyId);
-
- }
- if (ApiTypeHelper.isDefined(this.configuration)) {
- generator.writeKey("configuration");
- generator.writeStartObject();
- for (Map.Entry item0 : this.configuration.entrySet()) {
- generator.writeKey(item0.getKey());
- item0.getValue().serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- if (ApiTypeHelper.isDefined(this.customScheduling)) {
- generator.writeKey("custom_scheduling");
- generator.writeStartObject();
- for (Map.Entry item0 : this.customScheduling.entrySet()) {
- generator.writeKey(item0.getKey());
- item0.getValue().serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- if (this.description != null) {
- generator.writeKey("description");
- generator.write(this.description);
-
- }
- if (this.error != null) {
- generator.writeKey("error");
- generator.write(this.error);
-
- }
- if (this.features != null) {
- generator.writeKey("features");
- this.features.serialize(generator, mapper);
-
- }
- if (ApiTypeHelper.isDefined(this.filtering)) {
- generator.writeKey("filtering");
- generator.writeStartArray();
- for (FilteringConfig item0 : this.filtering) {
- item0.serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- if (this.id != null) {
- generator.writeKey("id");
- generator.write(this.id);
-
- }
- if (this.indexName != null) {
- generator.writeKey("index_name");
- generator.write(this.indexName);
-
- }
- generator.writeKey("is_native");
- generator.write(this.isNative);
-
- if (this.language != null) {
- generator.writeKey("language");
- generator.write(this.language);
-
- }
- if (this.lastAccessControlSyncError != null) {
- generator.writeKey("last_access_control_sync_error");
- generator.write(this.lastAccessControlSyncError);
-
- }
- if (this.lastAccessControlSyncScheduledAt != null) {
- generator.writeKey("last_access_control_sync_scheduled_at");
- this.lastAccessControlSyncScheduledAt.serialize(generator, mapper);
- }
- if (this.lastAccessControlSyncStatus != null) {
- generator.writeKey("last_access_control_sync_status");
- this.lastAccessControlSyncStatus.serialize(generator, mapper);
- }
- if (this.lastDeletedDocumentCount != null) {
- generator.writeKey("last_deleted_document_count");
- generator.write(this.lastDeletedDocumentCount);
-
- }
- if (this.lastIncrementalSyncScheduledAt != null) {
- generator.writeKey("last_incremental_sync_scheduled_at");
- this.lastIncrementalSyncScheduledAt.serialize(generator, mapper);
- }
- if (this.lastIndexedDocumentCount != null) {
- generator.writeKey("last_indexed_document_count");
- generator.write(this.lastIndexedDocumentCount);
-
- }
- if (this.lastSeen != null) {
- generator.writeKey("last_seen");
- this.lastSeen.serialize(generator, mapper);
- }
- if (this.lastSyncError != null) {
- generator.writeKey("last_sync_error");
- generator.write(this.lastSyncError);
-
- }
- if (this.lastSyncScheduledAt != null) {
- generator.writeKey("last_sync_scheduled_at");
- this.lastSyncScheduledAt.serialize(generator, mapper);
- }
- if (this.lastSyncStatus != null) {
- generator.writeKey("last_sync_status");
- this.lastSyncStatus.serialize(generator, mapper);
- }
- if (this.lastSynced != null) {
- generator.writeKey("last_synced");
- this.lastSynced.serialize(generator, mapper);
- }
- if (this.name != null) {
- generator.writeKey("name");
- generator.write(this.name);
-
- }
- if (this.pipeline != null) {
- generator.writeKey("pipeline");
- this.pipeline.serialize(generator, mapper);
-
- }
- generator.writeKey("scheduling");
- this.scheduling.serialize(generator, mapper);
-
- generator.writeKey("service_type");
- generator.write(this.serviceType);
-
- generator.writeKey("status");
- this.status.serialize(generator, mapper);
- generator.writeKey("sync_now");
- generator.write(this.syncNow);
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link Connector}.
- */
-
- public static class Builder extends Connector.AbstractBuilder implements ObjectBuilder {
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link Connector}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public Connector build() {
- _checkSingleUse();
-
- return new Connector(this);
- }
- }
-
- public abstract static class AbstractBuilder>
- extends
- WithJsonObjectBuilderBase {
- @Nullable
- private String apiKeyId;
-
- private Map configuration;
-
- private Map customScheduling;
-
- @Nullable
- private String description;
-
- @Nullable
- private String error;
-
- @Nullable
- private ConnectorFeatures features;
-
- private List filtering;
-
- @Nullable
- private String id;
-
- @Nullable
- private String indexName;
-
- private Boolean isNative;
-
- @Nullable
- private String language;
-
- @Nullable
- private String lastAccessControlSyncError;
-
- @Nullable
- private DateTime lastAccessControlSyncScheduledAt;
-
- @Nullable
- private SyncStatus lastAccessControlSyncStatus;
-
- @Nullable
- private Long lastDeletedDocumentCount;
-
- @Nullable
- private DateTime lastIncrementalSyncScheduledAt;
-
- @Nullable
- private Long lastIndexedDocumentCount;
-
- @Nullable
- private DateTime lastSeen;
-
- @Nullable
- private String lastSyncError;
-
- @Nullable
- private DateTime lastSyncScheduledAt;
-
- @Nullable
- private SyncStatus lastSyncStatus;
-
- @Nullable
- private DateTime lastSynced;
-
- @Nullable
- private String name;
-
- @Nullable
- private IngestPipelineParams pipeline;
-
- private SchedulingConfiguration scheduling;
-
- private String serviceType;
-
- private ConnectorStatus status;
-
- private Boolean syncNow;
-
- /**
- * API name: {@code api_key_id}
- */
- public final BuilderT apiKeyId(@Nullable String value) {
- this.apiKeyId = value;
- return self();
- }
-
- /**
- * Required - API name: {@code configuration}
- *
- * Adds all entries of map to configuration.
- */
- public final BuilderT configuration(Map map) {
- this.configuration = _mapPutAll(this.configuration, map);
- return self();
- }
-
- /**
- * Required - API name: {@code configuration}
- *
- * Adds an entry to configuration.
- */
- public final BuilderT configuration(String key, ConnectorConfigProperties value) {
- this.configuration = _mapPut(this.configuration, key, value);
- return self();
- }
-
- /**
- * Required - API name: {@code configuration}
- *
- * Adds an entry to configuration using a builder lambda.
- */
- public final BuilderT configuration(String key,
- Function> fn) {
- return configuration(key, fn.apply(new ConnectorConfigProperties.Builder()).build());
- }
-
- /**
- * Required - API name: {@code custom_scheduling}
- *
- * Adds all entries of map to customScheduling.
- */
- public final BuilderT customScheduling(Map map) {
- this.customScheduling = _mapPutAll(this.customScheduling, map);
- return self();
- }
-
- /**
- * Required - API name: {@code custom_scheduling}
- *
- * Adds an entry to customScheduling.
- */
- public final BuilderT customScheduling(String key, CustomScheduling value) {
- this.customScheduling = _mapPut(this.customScheduling, key, value);
- return self();
- }
-
- /**
- * Required - API name: {@code custom_scheduling}
- *
- * Adds an entry to customScheduling using a builder lambda.
- */
- public final BuilderT customScheduling(String key,
- Function> fn) {
- return customScheduling(key, fn.apply(new CustomScheduling.Builder()).build());
- }
-
- /**
- * API name: {@code description}
- */
- public final BuilderT description(@Nullable String value) {
- this.description = value;
- return self();
- }
-
- /**
- * API name: {@code error}
- */
- public final BuilderT error(@Nullable String value) {
- this.error = value;
- return self();
- }
-
- /**
- * API name: {@code features}
- */
- public final BuilderT features(@Nullable ConnectorFeatures value) {
- this.features = value;
- return self();
- }
-
- /**
- * API name: {@code features}
- */
- public final BuilderT features(Function> fn) {
- return this.features(fn.apply(new ConnectorFeatures.Builder()).build());
- }
-
- /**
- * Required - API name: {@code filtering}
- *
- * Adds all elements of list to filtering.
- */
- public final BuilderT filtering(List list) {
- this.filtering = _listAddAll(this.filtering, list);
- return self();
- }
-
- /**
- * Required - API name: {@code filtering}
- *
- * Adds one or more values to filtering.
- */
- public final BuilderT filtering(FilteringConfig value, FilteringConfig... values) {
- this.filtering = _listAdd(this.filtering, value, values);
- return self();
- }
-
- /**
- * Required - API name: {@code filtering}
- *
- * Adds a value to filtering using a builder lambda.
- */
- public final BuilderT filtering(Function> fn) {
- return filtering(fn.apply(new FilteringConfig.Builder()).build());
- }
-
- /**
- * API name: {@code id}
- */
- public final BuilderT id(@Nullable String value) {
- this.id = value;
- return self();
- }
-
- /**
- * API name: {@code index_name}
- */
- public final BuilderT indexName(@Nullable String value) {
- this.indexName = value;
- return self();
- }
-
- /**
- * Required - API name: {@code is_native}
- */
- public final BuilderT isNative(boolean value) {
- this.isNative = value;
- return self();
- }
-
- /**
- * API name: {@code language}
- */
- public final BuilderT language(@Nullable String value) {
- this.language = value;
- return self();
- }
-
- /**
- * API name: {@code last_access_control_sync_error}
- */
- public final BuilderT lastAccessControlSyncError(@Nullable String value) {
- this.lastAccessControlSyncError = value;
- return self();
- }
-
- /**
- * API name: {@code last_access_control_sync_scheduled_at}
- */
- public final BuilderT lastAccessControlSyncScheduledAt(@Nullable DateTime value) {
- this.lastAccessControlSyncScheduledAt = value;
- return self();
- }
-
- /**
- * API name: {@code last_access_control_sync_status}
- */
- public final BuilderT lastAccessControlSyncStatus(@Nullable SyncStatus value) {
- this.lastAccessControlSyncStatus = value;
- return self();
- }
-
- /**
- * API name: {@code last_deleted_document_count}
- */
- public final BuilderT lastDeletedDocumentCount(@Nullable Long value) {
- this.lastDeletedDocumentCount = value;
- return self();
- }
-
- /**
- * API name: {@code last_incremental_sync_scheduled_at}
- */
- public final BuilderT lastIncrementalSyncScheduledAt(@Nullable DateTime value) {
- this.lastIncrementalSyncScheduledAt = value;
- return self();
- }
-
- /**
- * API name: {@code last_indexed_document_count}
- */
- public final BuilderT lastIndexedDocumentCount(@Nullable Long value) {
- this.lastIndexedDocumentCount = value;
- return self();
- }
-
- /**
- * API name: {@code last_seen}
- */
- public final BuilderT lastSeen(@Nullable DateTime value) {
- this.lastSeen = value;
- return self();
- }
-
- /**
- * API name: {@code last_sync_error}
- */
- public final BuilderT lastSyncError(@Nullable String value) {
- this.lastSyncError = value;
- return self();
- }
-
- /**
- * API name: {@code last_sync_scheduled_at}
- */
- public final BuilderT lastSyncScheduledAt(@Nullable DateTime value) {
- this.lastSyncScheduledAt = value;
- return self();
- }
-
- /**
- * API name: {@code last_sync_status}
- */
- public final BuilderT lastSyncStatus(@Nullable SyncStatus value) {
- this.lastSyncStatus = value;
- return self();
- }
-
- /**
- * API name: {@code last_synced}
- */
- public final BuilderT lastSynced(@Nullable DateTime value) {
- this.lastSynced = value;
- return self();
- }
-
- /**
- * API name: {@code name}
- */
- public final BuilderT name(@Nullable String value) {
- this.name = value;
- return self();
- }
-
- /**
- * API name: {@code pipeline}
- */
- public final BuilderT pipeline(@Nullable IngestPipelineParams value) {
- this.pipeline = value;
- return self();
- }
-
- /**
- * API name: {@code pipeline}
- */
- public final BuilderT pipeline(Function> fn) {
- return this.pipeline(fn.apply(new IngestPipelineParams.Builder()).build());
- }
-
- /**
- * Required - API name: {@code scheduling}
- */
- public final BuilderT scheduling(SchedulingConfiguration value) {
- this.scheduling = value;
- return self();
- }
-
- /**
- * Required - API name: {@code scheduling}
- */
- public final BuilderT scheduling(
- Function> fn) {
- return this.scheduling(fn.apply(new SchedulingConfiguration.Builder()).build());
- }
-
- /**
- * Required - API name: {@code service_type}
- */
- public final BuilderT serviceType(String value) {
- this.serviceType = value;
- return self();
- }
-
- /**
- * Required - API name: {@code status}
- */
- public final BuilderT status(ConnectorStatus value) {
- this.status = value;
- return self();
- }
-
- /**
- * Required - API name: {@code sync_now}
- */
- public final BuilderT syncNow(boolean value) {
- this.syncNow = value;
- return self();
- }
-
- protected abstract BuilderT self();
-
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link Connector}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer.lazy(Builder::new,
- Connector::setupConnectorDeserializer);
-
- protected static > void setupConnectorDeserializer(
- ObjectDeserializer op) {
-
- op.add(AbstractBuilder::apiKeyId, JsonpDeserializer.stringDeserializer(), "api_key_id");
- op.add(AbstractBuilder::configuration,
- JsonpDeserializer.stringMapDeserializer(ConnectorConfigProperties._DESERIALIZER), "configuration");
- op.add(AbstractBuilder::customScheduling,
- JsonpDeserializer.stringMapDeserializer(CustomScheduling._DESERIALIZER), "custom_scheduling");
- op.add(AbstractBuilder::description, JsonpDeserializer.stringDeserializer(), "description");
- op.add(AbstractBuilder::error, JsonpDeserializer.stringDeserializer(), "error");
- op.add(AbstractBuilder::features, ConnectorFeatures._DESERIALIZER, "features");
- op.add(AbstractBuilder::filtering, JsonpDeserializer.arrayDeserializer(FilteringConfig._DESERIALIZER),
- "filtering");
- op.add(AbstractBuilder::id, JsonpDeserializer.stringDeserializer(), "id");
- op.add(AbstractBuilder::indexName, JsonpDeserializer.stringDeserializer(), "index_name");
- op.add(AbstractBuilder::isNative, JsonpDeserializer.booleanDeserializer(), "is_native");
- op.add(AbstractBuilder::language, JsonpDeserializer.stringDeserializer(), "language");
- op.add(AbstractBuilder::lastAccessControlSyncError, JsonpDeserializer.stringDeserializer(),
- "last_access_control_sync_error");
- op.add(AbstractBuilder::lastAccessControlSyncScheduledAt, DateTime._DESERIALIZER,
- "last_access_control_sync_scheduled_at");
- op.add(AbstractBuilder::lastAccessControlSyncStatus, SyncStatus._DESERIALIZER,
- "last_access_control_sync_status");
- op.add(AbstractBuilder::lastDeletedDocumentCount, JsonpDeserializer.longDeserializer(),
- "last_deleted_document_count");
- op.add(AbstractBuilder::lastIncrementalSyncScheduledAt, DateTime._DESERIALIZER,
- "last_incremental_sync_scheduled_at");
- op.add(AbstractBuilder::lastIndexedDocumentCount, JsonpDeserializer.longDeserializer(),
- "last_indexed_document_count");
- op.add(AbstractBuilder::lastSeen, DateTime._DESERIALIZER, "last_seen");
- op.add(AbstractBuilder::lastSyncError, JsonpDeserializer.stringDeserializer(), "last_sync_error");
- op.add(AbstractBuilder::lastSyncScheduledAt, DateTime._DESERIALIZER, "last_sync_scheduled_at");
- op.add(AbstractBuilder::lastSyncStatus, SyncStatus._DESERIALIZER, "last_sync_status");
- op.add(AbstractBuilder::lastSynced, DateTime._DESERIALIZER, "last_synced");
- op.add(AbstractBuilder::name, JsonpDeserializer.stringDeserializer(), "name");
- op.add(AbstractBuilder::pipeline, IngestPipelineParams._DESERIALIZER, "pipeline");
- op.add(AbstractBuilder::scheduling, SchedulingConfiguration._DESERIALIZER, "scheduling");
- op.add(AbstractBuilder::serviceType, JsonpDeserializer.stringDeserializer(), "service_type");
- op.add(AbstractBuilder::status, ConnectorStatus._DESERIALIZER, "status");
- op.add(AbstractBuilder::syncNow, JsonpDeserializer.booleanDeserializer(), "sync_now");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorConfigProperties.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorConfigProperties.java
deleted file mode 100644
index b2be793bb..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorConfigProperties.java
+++ /dev/null
@@ -1,697 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.elasticsearch._types.FieldValue;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.lang.Integer;
-import java.lang.String;
-import java.util.List;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.ConnectorConfigProperties
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class ConnectorConfigProperties implements JsonpSerializable {
- @Nullable
- private final String category;
-
- private final FieldValue defaultValue;
-
- private final List dependsOn;
-
- private final DisplayType display;
-
- private final String label;
-
- private final List options;
-
- @Nullable
- private final Integer order;
-
- @Nullable
- private final String placeholder;
-
- private final boolean required;
-
- private final boolean sensitive;
-
- @Nullable
- private final String tooltip;
-
- private final ConnectorFieldType type;
-
- private final List uiRestrictions;
-
- private final List validations;
-
- private final FieldValue value;
-
- // ---------------------------------------------------------------------------------------------
-
- private ConnectorConfigProperties(Builder builder) {
-
- this.category = builder.category;
- this.defaultValue = ApiTypeHelper.requireNonNull(builder.defaultValue, this, "defaultValue");
- this.dependsOn = ApiTypeHelper.unmodifiableRequired(builder.dependsOn, this, "dependsOn");
- this.display = ApiTypeHelper.requireNonNull(builder.display, this, "display");
- this.label = ApiTypeHelper.requireNonNull(builder.label, this, "label");
- this.options = ApiTypeHelper.unmodifiableRequired(builder.options, this, "options");
- this.order = builder.order;
- this.placeholder = builder.placeholder;
- this.required = ApiTypeHelper.requireNonNull(builder.required, this, "required");
- this.sensitive = ApiTypeHelper.requireNonNull(builder.sensitive, this, "sensitive");
- this.tooltip = builder.tooltip;
- this.type = ApiTypeHelper.requireNonNull(builder.type, this, "type");
- this.uiRestrictions = ApiTypeHelper.unmodifiableRequired(builder.uiRestrictions, this, "uiRestrictions");
- this.validations = ApiTypeHelper.unmodifiableRequired(builder.validations, this, "validations");
- this.value = ApiTypeHelper.requireNonNull(builder.value, this, "value");
-
- }
-
- public static ConnectorConfigProperties of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * API name: {@code category}
- */
- @Nullable
- public final String category() {
- return this.category;
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final FieldValue defaultValue() {
- return this.defaultValue;
- }
-
- /**
- * Required - API name: {@code depends_on}
- */
- public final List dependsOn() {
- return this.dependsOn;
- }
-
- /**
- * Required - API name: {@code display}
- */
- public final DisplayType display() {
- return this.display;
- }
-
- /**
- * Required - API name: {@code label}
- */
- public final String label() {
- return this.label;
- }
-
- /**
- * Required - API name: {@code options}
- */
- public final List options() {
- return this.options;
- }
-
- /**
- * API name: {@code order}
- */
- @Nullable
- public final Integer order() {
- return this.order;
- }
-
- /**
- * API name: {@code placeholder}
- */
- @Nullable
- public final String placeholder() {
- return this.placeholder;
- }
-
- /**
- * Required - API name: {@code required}
- */
- public final boolean required() {
- return this.required;
- }
-
- /**
- * Required - API name: {@code sensitive}
- */
- public final boolean sensitive() {
- return this.sensitive;
- }
-
- /**
- * API name: {@code tooltip}
- */
- @Nullable
- public final String tooltip() {
- return this.tooltip;
- }
-
- /**
- * Required - API name: {@code type}
- */
- public final ConnectorFieldType type() {
- return this.type;
- }
-
- /**
- * Required - API name: {@code ui_restrictions}
- */
- public final List uiRestrictions() {
- return this.uiRestrictions;
- }
-
- /**
- * Required - API name: {@code validations}
- */
- public final List validations() {
- return this.validations;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final FieldValue value() {
- return this.value;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- if (this.category != null) {
- generator.writeKey("category");
- generator.write(this.category);
-
- }
- generator.writeKey("default_value");
- this.defaultValue.serialize(generator, mapper);
-
- if (ApiTypeHelper.isDefined(this.dependsOn)) {
- generator.writeKey("depends_on");
- generator.writeStartArray();
- for (Dependency item0 : this.dependsOn) {
- item0.serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- generator.writeKey("display");
- this.display.serialize(generator, mapper);
- generator.writeKey("label");
- generator.write(this.label);
-
- if (ApiTypeHelper.isDefined(this.options)) {
- generator.writeKey("options");
- generator.writeStartArray();
- for (SelectOption item0 : this.options) {
- item0.serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- if (this.order != null) {
- generator.writeKey("order");
- generator.write(this.order);
-
- }
- if (this.placeholder != null) {
- generator.writeKey("placeholder");
- generator.write(this.placeholder);
-
- }
- generator.writeKey("required");
- generator.write(this.required);
-
- generator.writeKey("sensitive");
- generator.write(this.sensitive);
-
- if (this.tooltip != null) {
- generator.writeKey("tooltip");
- generator.write(this.tooltip);
-
- }
- generator.writeKey("type");
- this.type.serialize(generator, mapper);
- if (ApiTypeHelper.isDefined(this.uiRestrictions)) {
- generator.writeKey("ui_restrictions");
- generator.writeStartArray();
- for (String item0 : this.uiRestrictions) {
- generator.write(item0);
-
- }
- generator.writeEnd();
-
- }
- if (ApiTypeHelper.isDefined(this.validations)) {
- generator.writeKey("validations");
- generator.writeStartArray();
- for (Validation item0 : this.validations) {
- item0.serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- generator.writeKey("value");
- this.value.serialize(generator, mapper);
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link ConnectorConfigProperties}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase
- implements
- ObjectBuilder {
- @Nullable
- private String category;
-
- private FieldValue defaultValue;
-
- private List dependsOn;
-
- private DisplayType display;
-
- private String label;
-
- private List options;
-
- @Nullable
- private Integer order;
-
- @Nullable
- private String placeholder;
-
- private Boolean required;
-
- private Boolean sensitive;
-
- @Nullable
- private String tooltip;
-
- private ConnectorFieldType type;
-
- private List uiRestrictions;
-
- private List validations;
-
- private FieldValue value;
-
- /**
- * API name: {@code category}
- */
- public final Builder category(@Nullable String value) {
- this.category = value;
- return this;
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final Builder defaultValue(FieldValue value) {
- this.defaultValue = value;
- return this;
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final Builder defaultValue(Function> fn) {
- return this.defaultValue(fn.apply(new FieldValue.Builder()).build());
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final Builder defaultValue(String value) {
- this.defaultValue = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final Builder defaultValue(long value) {
- this.defaultValue = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final Builder defaultValue(double value) {
- this.defaultValue = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code default_value}
- */
- public final Builder defaultValue(boolean value) {
- this.defaultValue = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code depends_on}
- *
- * Adds all elements of list to dependsOn.
- */
- public final Builder dependsOn(List list) {
- this.dependsOn = _listAddAll(this.dependsOn, list);
- return this;
- }
-
- /**
- * Required - API name: {@code depends_on}
- *
- * Adds one or more values to dependsOn.
- */
- public final Builder dependsOn(Dependency value, Dependency... values) {
- this.dependsOn = _listAdd(this.dependsOn, value, values);
- return this;
- }
-
- /**
- * Required - API name: {@code depends_on}
- *
- * Adds a value to dependsOn using a builder lambda.
- */
- public final Builder dependsOn(Function> fn) {
- return dependsOn(fn.apply(new Dependency.Builder()).build());
- }
-
- /**
- * Required - API name: {@code display}
- */
- public final Builder display(DisplayType value) {
- this.display = value;
- return this;
- }
-
- /**
- * Required - API name: {@code label}
- */
- public final Builder label(String value) {
- this.label = value;
- return this;
- }
-
- /**
- * Required - API name: {@code options}
- *
- * Adds all elements of list to options.
- */
- public final Builder options(List list) {
- this.options = _listAddAll(this.options, list);
- return this;
- }
-
- /**
- * Required - API name: {@code options}
- *
- * Adds one or more values to options.
- */
- public final Builder options(SelectOption value, SelectOption... values) {
- this.options = _listAdd(this.options, value, values);
- return this;
- }
-
- /**
- * Required - API name: {@code options}
- *
- * Adds a value to options using a builder lambda.
- */
- public final Builder options(Function> fn) {
- return options(fn.apply(new SelectOption.Builder()).build());
- }
-
- /**
- * API name: {@code order}
- */
- public final Builder order(@Nullable Integer value) {
- this.order = value;
- return this;
- }
-
- /**
- * API name: {@code placeholder}
- */
- public final Builder placeholder(@Nullable String value) {
- this.placeholder = value;
- return this;
- }
-
- /**
- * Required - API name: {@code required}
- */
- public final Builder required(boolean value) {
- this.required = value;
- return this;
- }
-
- /**
- * Required - API name: {@code sensitive}
- */
- public final Builder sensitive(boolean value) {
- this.sensitive = value;
- return this;
- }
-
- /**
- * API name: {@code tooltip}
- */
- public final Builder tooltip(@Nullable String value) {
- this.tooltip = value;
- return this;
- }
-
- /**
- * Required - API name: {@code type}
- */
- public final Builder type(ConnectorFieldType value) {
- this.type = value;
- return this;
- }
-
- /**
- * Required - API name: {@code ui_restrictions}
- *
- * Adds all elements of list to uiRestrictions.
- */
- public final Builder uiRestrictions(List list) {
- this.uiRestrictions = _listAddAll(this.uiRestrictions, list);
- return this;
- }
-
- /**
- * Required - API name: {@code ui_restrictions}
- *
- * Adds one or more values to uiRestrictions.
- */
- public final Builder uiRestrictions(String value, String... values) {
- this.uiRestrictions = _listAdd(this.uiRestrictions, value, values);
- return this;
- }
-
- /**
- * Required - API name: {@code validations}
- *
- * Adds all elements of list to validations.
- */
- public final Builder validations(List list) {
- this.validations = _listAddAll(this.validations, list);
- return this;
- }
-
- /**
- * Required - API name: {@code validations}
- *
- * Adds one or more values to validations.
- */
- public final Builder validations(Validation value, Validation... values) {
- this.validations = _listAdd(this.validations, value, values);
- return this;
- }
-
- /**
- * Required - API name: {@code validations}
- *
- * Adds a value to validations using a builder lambda.
- */
- public final Builder validations(Function> fn) {
- return validations(fn.apply(new Validation.Builder()).build());
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(FieldValue value) {
- this.value = value;
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(Function> fn) {
- return this.value(fn.apply(new FieldValue.Builder()).build());
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(String value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(long value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(double value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(boolean value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link ConnectorConfigProperties}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public ConnectorConfigProperties build() {
- _checkSingleUse();
-
- return new ConnectorConfigProperties(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link ConnectorConfigProperties}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer
- .lazy(Builder::new, ConnectorConfigProperties::setupConnectorConfigPropertiesDeserializer);
-
- protected static void setupConnectorConfigPropertiesDeserializer(
- ObjectDeserializer op) {
-
- op.add(Builder::category, JsonpDeserializer.stringDeserializer(), "category");
- op.add(Builder::defaultValue, FieldValue._DESERIALIZER, "default_value");
- op.add(Builder::dependsOn, JsonpDeserializer.arrayDeserializer(Dependency._DESERIALIZER), "depends_on");
- op.add(Builder::display, DisplayType._DESERIALIZER, "display");
- op.add(Builder::label, JsonpDeserializer.stringDeserializer(), "label");
- op.add(Builder::options, JsonpDeserializer.arrayDeserializer(SelectOption._DESERIALIZER), "options");
- op.add(Builder::order, JsonpDeserializer.integerDeserializer(), "order");
- op.add(Builder::placeholder, JsonpDeserializer.stringDeserializer(), "placeholder");
- op.add(Builder::required, JsonpDeserializer.booleanDeserializer(), "required");
- op.add(Builder::sensitive, JsonpDeserializer.booleanDeserializer(), "sensitive");
- op.add(Builder::tooltip, JsonpDeserializer.stringDeserializer(), "tooltip");
- op.add(Builder::type, ConnectorFieldType._DESERIALIZER, "type");
- op.add(Builder::uiRestrictions, JsonpDeserializer.arrayDeserializer(JsonpDeserializer.stringDeserializer()),
- "ui_restrictions");
- op.add(Builder::validations, JsonpDeserializer.arrayDeserializer(Validation._DESERIALIZER), "validations");
- op.add(Builder::value, FieldValue._DESERIALIZER, "value");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorFeatures.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorFeatures.java
deleted file mode 100644
index 5ee9628dd..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorFeatures.java
+++ /dev/null
@@ -1,296 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.ConnectorFeatures
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class ConnectorFeatures implements JsonpSerializable {
- @Nullable
- private final FeatureEnabled documentLevelSecurity;
-
- @Nullable
- private final Boolean filteringAdvancedConfig;
-
- @Nullable
- private final Boolean filteringRules;
-
- @Nullable
- private final FeatureEnabled incrementalSync;
-
- @Nullable
- private final SyncRulesFeature syncRules;
-
- // ---------------------------------------------------------------------------------------------
-
- private ConnectorFeatures(Builder builder) {
-
- this.documentLevelSecurity = builder.documentLevelSecurity;
- this.filteringAdvancedConfig = builder.filteringAdvancedConfig;
- this.filteringRules = builder.filteringRules;
- this.incrementalSync = builder.incrementalSync;
- this.syncRules = builder.syncRules;
-
- }
-
- public static ConnectorFeatures of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * API name: {@code document_level_security}
- */
- @Nullable
- public final FeatureEnabled documentLevelSecurity() {
- return this.documentLevelSecurity;
- }
-
- /**
- * API name: {@code filtering_advanced_config}
- */
- @Nullable
- public final Boolean filteringAdvancedConfig() {
- return this.filteringAdvancedConfig;
- }
-
- /**
- * API name: {@code filtering_rules}
- */
- @Nullable
- public final Boolean filteringRules() {
- return this.filteringRules;
- }
-
- /**
- * API name: {@code incremental_sync}
- */
- @Nullable
- public final FeatureEnabled incrementalSync() {
- return this.incrementalSync;
- }
-
- /**
- * API name: {@code sync_rules}
- */
- @Nullable
- public final SyncRulesFeature syncRules() {
- return this.syncRules;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- if (this.documentLevelSecurity != null) {
- generator.writeKey("document_level_security");
- this.documentLevelSecurity.serialize(generator, mapper);
-
- }
- if (this.filteringAdvancedConfig != null) {
- generator.writeKey("filtering_advanced_config");
- generator.write(this.filteringAdvancedConfig);
-
- }
- if (this.filteringRules != null) {
- generator.writeKey("filtering_rules");
- generator.write(this.filteringRules);
-
- }
- if (this.incrementalSync != null) {
- generator.writeKey("incremental_sync");
- this.incrementalSync.serialize(generator, mapper);
-
- }
- if (this.syncRules != null) {
- generator.writeKey("sync_rules");
- this.syncRules.serialize(generator, mapper);
-
- }
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link ConnectorFeatures}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase implements ObjectBuilder {
- @Nullable
- private FeatureEnabled documentLevelSecurity;
-
- @Nullable
- private Boolean filteringAdvancedConfig;
-
- @Nullable
- private Boolean filteringRules;
-
- @Nullable
- private FeatureEnabled incrementalSync;
-
- @Nullable
- private SyncRulesFeature syncRules;
-
- /**
- * API name: {@code document_level_security}
- */
- public final Builder documentLevelSecurity(@Nullable FeatureEnabled value) {
- this.documentLevelSecurity = value;
- return this;
- }
-
- /**
- * API name: {@code document_level_security}
- */
- public final Builder documentLevelSecurity(Function> fn) {
- return this.documentLevelSecurity(fn.apply(new FeatureEnabled.Builder()).build());
- }
-
- /**
- * API name: {@code filtering_advanced_config}
- */
- public final Builder filteringAdvancedConfig(@Nullable Boolean value) {
- this.filteringAdvancedConfig = value;
- return this;
- }
-
- /**
- * API name: {@code filtering_rules}
- */
- public final Builder filteringRules(@Nullable Boolean value) {
- this.filteringRules = value;
- return this;
- }
-
- /**
- * API name: {@code incremental_sync}
- */
- public final Builder incrementalSync(@Nullable FeatureEnabled value) {
- this.incrementalSync = value;
- return this;
- }
-
- /**
- * API name: {@code incremental_sync}
- */
- public final Builder incrementalSync(Function> fn) {
- return this.incrementalSync(fn.apply(new FeatureEnabled.Builder()).build());
- }
-
- /**
- * API name: {@code sync_rules}
- */
- public final Builder syncRules(@Nullable SyncRulesFeature value) {
- this.syncRules = value;
- return this;
- }
-
- /**
- * API name: {@code sync_rules}
- */
- public final Builder syncRules(Function> fn) {
- return this.syncRules(fn.apply(new SyncRulesFeature.Builder()).build());
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link ConnectorFeatures}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public ConnectorFeatures build() {
- _checkSingleUse();
-
- return new ConnectorFeatures(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link ConnectorFeatures}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer
- .lazy(Builder::new, ConnectorFeatures::setupConnectorFeaturesDeserializer);
-
- protected static void setupConnectorFeaturesDeserializer(ObjectDeserializer op) {
-
- op.add(Builder::documentLevelSecurity, FeatureEnabled._DESERIALIZER, "document_level_security");
- op.add(Builder::filteringAdvancedConfig, JsonpDeserializer.booleanDeserializer(), "filtering_advanced_config");
- op.add(Builder::filteringRules, JsonpDeserializer.booleanDeserializer(), "filtering_rules");
- op.add(Builder::incrementalSync, FeatureEnabled._DESERIALIZER, "incremental_sync");
- op.add(Builder::syncRules, SyncRulesFeature._DESERIALIZER, "sync_rules");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorFieldType.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorFieldType.java
deleted file mode 100644
index cbe0abe34..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorFieldType.java
+++ /dev/null
@@ -1,71 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonEnum;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public enum ConnectorFieldType implements JsonEnum {
- Str("str"),
-
- Int("int"),
-
- List("list"),
-
- Bool("bool"),
-
- ;
-
- private final String jsonValue;
-
- ConnectorFieldType(String jsonValue) {
- this.jsonValue = jsonValue;
- }
-
- public String jsonValue() {
- return this.jsonValue;
- }
-
- public static final JsonEnum.Deserializer _DESERIALIZER = new JsonEnum.Deserializer<>(
- ConnectorFieldType.values());
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorScheduling.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorScheduling.java
deleted file mode 100644
index 005338d47..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorScheduling.java
+++ /dev/null
@@ -1,185 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.lang.String;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.ConnectorScheduling
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class ConnectorScheduling implements JsonpSerializable {
- private final boolean enabled;
-
- private final String interval;
-
- // ---------------------------------------------------------------------------------------------
-
- private ConnectorScheduling(Builder builder) {
-
- this.enabled = ApiTypeHelper.requireNonNull(builder.enabled, this, "enabled");
- this.interval = ApiTypeHelper.requireNonNull(builder.interval, this, "interval");
-
- }
-
- public static ConnectorScheduling of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * Required - API name: {@code enabled}
- */
- public final boolean enabled() {
- return this.enabled;
- }
-
- /**
- * Required - The interval is expressed using the crontab syntax
- *
- * API name: {@code interval}
- */
- public final String interval() {
- return this.interval;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- generator.writeKey("enabled");
- generator.write(this.enabled);
-
- generator.writeKey("interval");
- generator.write(this.interval);
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link ConnectorScheduling}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase
- implements
- ObjectBuilder {
- private Boolean enabled;
-
- private String interval;
-
- /**
- * Required - API name: {@code enabled}
- */
- public final Builder enabled(boolean value) {
- this.enabled = value;
- return this;
- }
-
- /**
- * Required - The interval is expressed using the crontab syntax
- *
- * API name: {@code interval}
- */
- public final Builder interval(String value) {
- this.interval = value;
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link ConnectorScheduling}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public ConnectorScheduling build() {
- _checkSingleUse();
-
- return new ConnectorScheduling(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link ConnectorScheduling}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer
- .lazy(Builder::new, ConnectorScheduling::setupConnectorSchedulingDeserializer);
-
- protected static void setupConnectorSchedulingDeserializer(ObjectDeserializer op) {
-
- op.add(Builder::enabled, JsonpDeserializer.booleanDeserializer(), "enabled");
- op.add(Builder::interval, JsonpDeserializer.stringDeserializer(), "interval");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorStatus.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorStatus.java
deleted file mode 100644
index 2407d8c10..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorStatus.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonEnum;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public enum ConnectorStatus implements JsonEnum {
- Created("created"),
-
- NeedsConfiguration("needs_configuration"),
-
- Configured("configured"),
-
- Connected("connected"),
-
- Error("error"),
-
- ;
-
- private final String jsonValue;
-
- ConnectorStatus(String jsonValue) {
- this.jsonValue = jsonValue;
- }
-
- public String jsonValue() {
- return this.jsonValue;
- }
-
- public static final JsonEnum.Deserializer _DESERIALIZER = new JsonEnum.Deserializer<>(
- ConnectorStatus.values());
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorSyncJob.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorSyncJob.java
deleted file mode 100644
index 1b1e0e434..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ConnectorSyncJob.java
+++ /dev/null
@@ -1,634 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonData;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.DateTime;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Long;
-import java.lang.String;
-import java.util.Map;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.ConnectorSyncJob
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class ConnectorSyncJob implements JsonpSerializable {
- @Nullable
- private final DateTime cancelationRequestedAt;
-
- @Nullable
- private final DateTime canceledAt;
-
- @Nullable
- private final DateTime completedAt;
-
- private final SyncJobConnectorReference connector;
-
- private final DateTime createdAt;
-
- private final long deletedDocumentCount;
-
- @Nullable
- private final String error;
-
- private final String id;
-
- private final long indexedDocumentCount;
-
- private final long indexedDocumentVolume;
-
- private final SyncJobType jobType;
-
- @Nullable
- private final DateTime lastSeen;
-
- private final Map metadata;
-
- @Nullable
- private final DateTime startedAt;
-
- private final SyncStatus status;
-
- private final long totalDocumentCount;
-
- private final SyncJobTriggerMethod triggerMethod;
-
- @Nullable
- private final String workerHostname;
-
- // ---------------------------------------------------------------------------------------------
-
- protected ConnectorSyncJob(AbstractBuilder builder) {
-
- this.cancelationRequestedAt = builder.cancelationRequestedAt;
- this.canceledAt = builder.canceledAt;
- this.completedAt = builder.completedAt;
- this.connector = ApiTypeHelper.requireNonNull(builder.connector, this, "connector");
- this.createdAt = ApiTypeHelper.requireNonNull(builder.createdAt, this, "createdAt");
- this.deletedDocumentCount = ApiTypeHelper.requireNonNull(builder.deletedDocumentCount, this,
- "deletedDocumentCount");
- this.error = builder.error;
- this.id = ApiTypeHelper.requireNonNull(builder.id, this, "id");
- this.indexedDocumentCount = ApiTypeHelper.requireNonNull(builder.indexedDocumentCount, this,
- "indexedDocumentCount");
- this.indexedDocumentVolume = ApiTypeHelper.requireNonNull(builder.indexedDocumentVolume, this,
- "indexedDocumentVolume");
- this.jobType = ApiTypeHelper.requireNonNull(builder.jobType, this, "jobType");
- this.lastSeen = builder.lastSeen;
- this.metadata = ApiTypeHelper.unmodifiableRequired(builder.metadata, this, "metadata");
- this.startedAt = builder.startedAt;
- this.status = ApiTypeHelper.requireNonNull(builder.status, this, "status");
- this.totalDocumentCount = ApiTypeHelper.requireNonNull(builder.totalDocumentCount, this, "totalDocumentCount");
- this.triggerMethod = ApiTypeHelper.requireNonNull(builder.triggerMethod, this, "triggerMethod");
- this.workerHostname = builder.workerHostname;
-
- }
-
- public static ConnectorSyncJob connectorSyncJobOf(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * API name: {@code cancelation_requested_at}
- */
- @Nullable
- public final DateTime cancelationRequestedAt() {
- return this.cancelationRequestedAt;
- }
-
- /**
- * API name: {@code canceled_at}
- */
- @Nullable
- public final DateTime canceledAt() {
- return this.canceledAt;
- }
-
- /**
- * API name: {@code completed_at}
- */
- @Nullable
- public final DateTime completedAt() {
- return this.completedAt;
- }
-
- /**
- * Required - API name: {@code connector}
- */
- public final SyncJobConnectorReference connector() {
- return this.connector;
- }
-
- /**
- * Required - API name: {@code created_at}
- */
- public final DateTime createdAt() {
- return this.createdAt;
- }
-
- /**
- * Required - API name: {@code deleted_document_count}
- */
- public final long deletedDocumentCount() {
- return this.deletedDocumentCount;
- }
-
- /**
- * API name: {@code error}
- */
- @Nullable
- public final String error() {
- return this.error;
- }
-
- /**
- * Required - API name: {@code id}
- */
- public final String id() {
- return this.id;
- }
-
- /**
- * Required - API name: {@code indexed_document_count}
- */
- public final long indexedDocumentCount() {
- return this.indexedDocumentCount;
- }
-
- /**
- * Required - API name: {@code indexed_document_volume}
- */
- public final long indexedDocumentVolume() {
- return this.indexedDocumentVolume;
- }
-
- /**
- * Required - API name: {@code job_type}
- */
- public final SyncJobType jobType() {
- return this.jobType;
- }
-
- /**
- * API name: {@code last_seen}
- */
- @Nullable
- public final DateTime lastSeen() {
- return this.lastSeen;
- }
-
- /**
- * Required - API name: {@code metadata}
- */
- public final Map metadata() {
- return this.metadata;
- }
-
- /**
- * API name: {@code started_at}
- */
- @Nullable
- public final DateTime startedAt() {
- return this.startedAt;
- }
-
- /**
- * Required - API name: {@code status}
- */
- public final SyncStatus status() {
- return this.status;
- }
-
- /**
- * Required - API name: {@code total_document_count}
- */
- public final long totalDocumentCount() {
- return this.totalDocumentCount;
- }
-
- /**
- * Required - API name: {@code trigger_method}
- */
- public final SyncJobTriggerMethod triggerMethod() {
- return this.triggerMethod;
- }
-
- /**
- * API name: {@code worker_hostname}
- */
- @Nullable
- public final String workerHostname() {
- return this.workerHostname;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- if (this.cancelationRequestedAt != null) {
- generator.writeKey("cancelation_requested_at");
- this.cancelationRequestedAt.serialize(generator, mapper);
- }
- if (this.canceledAt != null) {
- generator.writeKey("canceled_at");
- this.canceledAt.serialize(generator, mapper);
- }
- if (this.completedAt != null) {
- generator.writeKey("completed_at");
- this.completedAt.serialize(generator, mapper);
- }
- generator.writeKey("connector");
- this.connector.serialize(generator, mapper);
-
- generator.writeKey("created_at");
- this.createdAt.serialize(generator, mapper);
- generator.writeKey("deleted_document_count");
- generator.write(this.deletedDocumentCount);
-
- if (this.error != null) {
- generator.writeKey("error");
- generator.write(this.error);
-
- }
- generator.writeKey("id");
- generator.write(this.id);
-
- generator.writeKey("indexed_document_count");
- generator.write(this.indexedDocumentCount);
-
- generator.writeKey("indexed_document_volume");
- generator.write(this.indexedDocumentVolume);
-
- generator.writeKey("job_type");
- this.jobType.serialize(generator, mapper);
- if (this.lastSeen != null) {
- generator.writeKey("last_seen");
- this.lastSeen.serialize(generator, mapper);
- }
- if (ApiTypeHelper.isDefined(this.metadata)) {
- generator.writeKey("metadata");
- generator.writeStartObject();
- for (Map.Entry item0 : this.metadata.entrySet()) {
- generator.writeKey(item0.getKey());
- item0.getValue().serialize(generator, mapper);
-
- }
- generator.writeEnd();
-
- }
- if (this.startedAt != null) {
- generator.writeKey("started_at");
- this.startedAt.serialize(generator, mapper);
- }
- generator.writeKey("status");
- this.status.serialize(generator, mapper);
- generator.writeKey("total_document_count");
- generator.write(this.totalDocumentCount);
-
- generator.writeKey("trigger_method");
- this.triggerMethod.serialize(generator, mapper);
- if (this.workerHostname != null) {
- generator.writeKey("worker_hostname");
- generator.write(this.workerHostname);
-
- }
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link ConnectorSyncJob}.
- */
-
- public static class Builder extends ConnectorSyncJob.AbstractBuilder
- implements
- ObjectBuilder {
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link ConnectorSyncJob}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public ConnectorSyncJob build() {
- _checkSingleUse();
-
- return new ConnectorSyncJob(this);
- }
- }
-
- public abstract static class AbstractBuilder>
- extends
- WithJsonObjectBuilderBase {
- @Nullable
- private DateTime cancelationRequestedAt;
-
- @Nullable
- private DateTime canceledAt;
-
- @Nullable
- private DateTime completedAt;
-
- private SyncJobConnectorReference connector;
-
- private DateTime createdAt;
-
- private Long deletedDocumentCount;
-
- @Nullable
- private String error;
-
- private String id;
-
- private Long indexedDocumentCount;
-
- private Long indexedDocumentVolume;
-
- private SyncJobType jobType;
-
- @Nullable
- private DateTime lastSeen;
-
- private Map metadata;
-
- @Nullable
- private DateTime startedAt;
-
- private SyncStatus status;
-
- private Long totalDocumentCount;
-
- private SyncJobTriggerMethod triggerMethod;
-
- @Nullable
- private String workerHostname;
-
- /**
- * API name: {@code cancelation_requested_at}
- */
- public final BuilderT cancelationRequestedAt(@Nullable DateTime value) {
- this.cancelationRequestedAt = value;
- return self();
- }
-
- /**
- * API name: {@code canceled_at}
- */
- public final BuilderT canceledAt(@Nullable DateTime value) {
- this.canceledAt = value;
- return self();
- }
-
- /**
- * API name: {@code completed_at}
- */
- public final BuilderT completedAt(@Nullable DateTime value) {
- this.completedAt = value;
- return self();
- }
-
- /**
- * Required - API name: {@code connector}
- */
- public final BuilderT connector(SyncJobConnectorReference value) {
- this.connector = value;
- return self();
- }
-
- /**
- * Required - API name: {@code connector}
- */
- public final BuilderT connector(
- Function> fn) {
- return this.connector(fn.apply(new SyncJobConnectorReference.Builder()).build());
- }
-
- /**
- * Required - API name: {@code created_at}
- */
- public final BuilderT createdAt(DateTime value) {
- this.createdAt = value;
- return self();
- }
-
- /**
- * Required - API name: {@code deleted_document_count}
- */
- public final BuilderT deletedDocumentCount(long value) {
- this.deletedDocumentCount = value;
- return self();
- }
-
- /**
- * API name: {@code error}
- */
- public final BuilderT error(@Nullable String value) {
- this.error = value;
- return self();
- }
-
- /**
- * Required - API name: {@code id}
- */
- public final BuilderT id(String value) {
- this.id = value;
- return self();
- }
-
- /**
- * Required - API name: {@code indexed_document_count}
- */
- public final BuilderT indexedDocumentCount(long value) {
- this.indexedDocumentCount = value;
- return self();
- }
-
- /**
- * Required - API name: {@code indexed_document_volume}
- */
- public final BuilderT indexedDocumentVolume(long value) {
- this.indexedDocumentVolume = value;
- return self();
- }
-
- /**
- * Required - API name: {@code job_type}
- */
- public final BuilderT jobType(SyncJobType value) {
- this.jobType = value;
- return self();
- }
-
- /**
- * API name: {@code last_seen}
- */
- public final BuilderT lastSeen(@Nullable DateTime value) {
- this.lastSeen = value;
- return self();
- }
-
- /**
- * Required - API name: {@code metadata}
- *
- * Adds all entries of map to metadata.
- */
- public final BuilderT metadata(Map map) {
- this.metadata = _mapPutAll(this.metadata, map);
- return self();
- }
-
- /**
- * Required - API name: {@code metadata}
- *
- * Adds an entry to metadata.
- */
- public final BuilderT metadata(String key, JsonData value) {
- this.metadata = _mapPut(this.metadata, key, value);
- return self();
- }
-
- /**
- * API name: {@code started_at}
- */
- public final BuilderT startedAt(@Nullable DateTime value) {
- this.startedAt = value;
- return self();
- }
-
- /**
- * Required - API name: {@code status}
- */
- public final BuilderT status(SyncStatus value) {
- this.status = value;
- return self();
- }
-
- /**
- * Required - API name: {@code total_document_count}
- */
- public final BuilderT totalDocumentCount(long value) {
- this.totalDocumentCount = value;
- return self();
- }
-
- /**
- * Required - API name: {@code trigger_method}
- */
- public final BuilderT triggerMethod(SyncJobTriggerMethod value) {
- this.triggerMethod = value;
- return self();
- }
-
- /**
- * API name: {@code worker_hostname}
- */
- public final BuilderT workerHostname(@Nullable String value) {
- this.workerHostname = value;
- return self();
- }
-
- protected abstract BuilderT self();
-
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link ConnectorSyncJob}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer.lazy(Builder::new,
- ConnectorSyncJob::setupConnectorSyncJobDeserializer);
-
- protected static > void setupConnectorSyncJobDeserializer(
- ObjectDeserializer op) {
-
- op.add(AbstractBuilder::cancelationRequestedAt, DateTime._DESERIALIZER, "cancelation_requested_at");
- op.add(AbstractBuilder::canceledAt, DateTime._DESERIALIZER, "canceled_at");
- op.add(AbstractBuilder::completedAt, DateTime._DESERIALIZER, "completed_at");
- op.add(AbstractBuilder::connector, SyncJobConnectorReference._DESERIALIZER, "connector");
- op.add(AbstractBuilder::createdAt, DateTime._DESERIALIZER, "created_at");
- op.add(AbstractBuilder::deletedDocumentCount, JsonpDeserializer.longDeserializer(), "deleted_document_count");
- op.add(AbstractBuilder::error, JsonpDeserializer.stringDeserializer(), "error");
- op.add(AbstractBuilder::id, JsonpDeserializer.stringDeserializer(), "id");
- op.add(AbstractBuilder::indexedDocumentCount, JsonpDeserializer.longDeserializer(), "indexed_document_count");
- op.add(AbstractBuilder::indexedDocumentVolume, JsonpDeserializer.longDeserializer(), "indexed_document_volume");
- op.add(AbstractBuilder::jobType, SyncJobType._DESERIALIZER, "job_type");
- op.add(AbstractBuilder::lastSeen, DateTime._DESERIALIZER, "last_seen");
- op.add(AbstractBuilder::metadata, JsonpDeserializer.stringMapDeserializer(JsonData._DESERIALIZER), "metadata");
- op.add(AbstractBuilder::startedAt, DateTime._DESERIALIZER, "started_at");
- op.add(AbstractBuilder::status, SyncStatus._DESERIALIZER, "status");
- op.add(AbstractBuilder::totalDocumentCount, JsonpDeserializer.longDeserializer(), "total_document_count");
- op.add(AbstractBuilder::triggerMethod, SyncJobTriggerMethod._DESERIALIZER, "trigger_method");
- op.add(AbstractBuilder::workerHostname, JsonpDeserializer.stringDeserializer(), "worker_hostname");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CustomScheduling.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CustomScheduling.java
deleted file mode 100644
index 302a7d46f..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CustomScheduling.java
+++ /dev/null
@@ -1,266 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.DateTime;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.lang.String;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.CustomScheduling
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class CustomScheduling implements JsonpSerializable {
- private final CustomSchedulingConfigurationOverrides configurationOverrides;
-
- private final boolean enabled;
-
- private final String interval;
-
- @Nullable
- private final DateTime lastSynced;
-
- private final String name;
-
- // ---------------------------------------------------------------------------------------------
-
- private CustomScheduling(Builder builder) {
-
- this.configurationOverrides = ApiTypeHelper.requireNonNull(builder.configurationOverrides, this,
- "configurationOverrides");
- this.enabled = ApiTypeHelper.requireNonNull(builder.enabled, this, "enabled");
- this.interval = ApiTypeHelper.requireNonNull(builder.interval, this, "interval");
- this.lastSynced = builder.lastSynced;
- this.name = ApiTypeHelper.requireNonNull(builder.name, this, "name");
-
- }
-
- public static CustomScheduling of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * Required - API name: {@code configuration_overrides}
- */
- public final CustomSchedulingConfigurationOverrides configurationOverrides() {
- return this.configurationOverrides;
- }
-
- /**
- * Required - API name: {@code enabled}
- */
- public final boolean enabled() {
- return this.enabled;
- }
-
- /**
- * Required - API name: {@code interval}
- */
- public final String interval() {
- return this.interval;
- }
-
- /**
- * API name: {@code last_synced}
- */
- @Nullable
- public final DateTime lastSynced() {
- return this.lastSynced;
- }
-
- /**
- * Required - API name: {@code name}
- */
- public final String name() {
- return this.name;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- generator.writeKey("configuration_overrides");
- this.configurationOverrides.serialize(generator, mapper);
-
- generator.writeKey("enabled");
- generator.write(this.enabled);
-
- generator.writeKey("interval");
- generator.write(this.interval);
-
- if (this.lastSynced != null) {
- generator.writeKey("last_synced");
- this.lastSynced.serialize(generator, mapper);
- }
- generator.writeKey("name");
- generator.write(this.name);
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link CustomScheduling}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase implements ObjectBuilder {
- private CustomSchedulingConfigurationOverrides configurationOverrides;
-
- private Boolean enabled;
-
- private String interval;
-
- @Nullable
- private DateTime lastSynced;
-
- private String name;
-
- /**
- * Required - API name: {@code configuration_overrides}
- */
- public final Builder configurationOverrides(CustomSchedulingConfigurationOverrides value) {
- this.configurationOverrides = value;
- return this;
- }
-
- /**
- * Required - API name: {@code configuration_overrides}
- */
- public final Builder configurationOverrides(
- Function> fn) {
- return this.configurationOverrides(fn.apply(new CustomSchedulingConfigurationOverrides.Builder()).build());
- }
-
- /**
- * Required - API name: {@code enabled}
- */
- public final Builder enabled(boolean value) {
- this.enabled = value;
- return this;
- }
-
- /**
- * Required - API name: {@code interval}
- */
- public final Builder interval(String value) {
- this.interval = value;
- return this;
- }
-
- /**
- * API name: {@code last_synced}
- */
- public final Builder lastSynced(@Nullable DateTime value) {
- this.lastSynced = value;
- return this;
- }
-
- /**
- * Required - API name: {@code name}
- */
- public final Builder name(String value) {
- this.name = value;
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link CustomScheduling}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public CustomScheduling build() {
- _checkSingleUse();
-
- return new CustomScheduling(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link CustomScheduling}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer.lazy(Builder::new,
- CustomScheduling::setupCustomSchedulingDeserializer);
-
- protected static void setupCustomSchedulingDeserializer(ObjectDeserializer op) {
-
- op.add(Builder::configurationOverrides, CustomSchedulingConfigurationOverrides._DESERIALIZER,
- "configuration_overrides");
- op.add(Builder::enabled, JsonpDeserializer.booleanDeserializer(), "enabled");
- op.add(Builder::interval, JsonpDeserializer.stringDeserializer(), "interval");
- op.add(Builder::lastSynced, DateTime._DESERIALIZER, "last_synced");
- op.add(Builder::name, JsonpDeserializer.stringDeserializer(), "name");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CustomSchedulingConfigurationOverrides.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CustomSchedulingConfigurationOverrides.java
deleted file mode 100644
index 11d919a0b..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/CustomSchedulingConfigurationOverrides.java
+++ /dev/null
@@ -1,333 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.lang.Integer;
-import java.lang.String;
-import java.util.List;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.CustomSchedulingConfigurationOverrides
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class CustomSchedulingConfigurationOverrides implements JsonpSerializable {
- @Nullable
- private final Integer maxCrawlDepth;
-
- @Nullable
- private final Boolean sitemapDiscoveryDisabled;
-
- private final List domainAllowlist;
-
- private final List sitemapUrls;
-
- private final List seedUrls;
-
- // ---------------------------------------------------------------------------------------------
-
- private CustomSchedulingConfigurationOverrides(Builder builder) {
-
- this.maxCrawlDepth = builder.maxCrawlDepth;
- this.sitemapDiscoveryDisabled = builder.sitemapDiscoveryDisabled;
- this.domainAllowlist = ApiTypeHelper.unmodifiable(builder.domainAllowlist);
- this.sitemapUrls = ApiTypeHelper.unmodifiable(builder.sitemapUrls);
- this.seedUrls = ApiTypeHelper.unmodifiable(builder.seedUrls);
-
- }
-
- public static CustomSchedulingConfigurationOverrides of(
- Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * API name: {@code max_crawl_depth}
- */
- @Nullable
- public final Integer maxCrawlDepth() {
- return this.maxCrawlDepth;
- }
-
- /**
- * API name: {@code sitemap_discovery_disabled}
- */
- @Nullable
- public final Boolean sitemapDiscoveryDisabled() {
- return this.sitemapDiscoveryDisabled;
- }
-
- /**
- * API name: {@code domain_allowlist}
- */
- public final List domainAllowlist() {
- return this.domainAllowlist;
- }
-
- /**
- * API name: {@code sitemap_urls}
- */
- public final List sitemapUrls() {
- return this.sitemapUrls;
- }
-
- /**
- * API name: {@code seed_urls}
- */
- public final List seedUrls() {
- return this.seedUrls;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- if (this.maxCrawlDepth != null) {
- generator.writeKey("max_crawl_depth");
- generator.write(this.maxCrawlDepth);
-
- }
- if (this.sitemapDiscoveryDisabled != null) {
- generator.writeKey("sitemap_discovery_disabled");
- generator.write(this.sitemapDiscoveryDisabled);
-
- }
- if (ApiTypeHelper.isDefined(this.domainAllowlist)) {
- generator.writeKey("domain_allowlist");
- generator.writeStartArray();
- for (String item0 : this.domainAllowlist) {
- generator.write(item0);
-
- }
- generator.writeEnd();
-
- }
- if (ApiTypeHelper.isDefined(this.sitemapUrls)) {
- generator.writeKey("sitemap_urls");
- generator.writeStartArray();
- for (String item0 : this.sitemapUrls) {
- generator.write(item0);
-
- }
- generator.writeEnd();
-
- }
- if (ApiTypeHelper.isDefined(this.seedUrls)) {
- generator.writeKey("seed_urls");
- generator.writeStartArray();
- for (String item0 : this.seedUrls) {
- generator.write(item0);
-
- }
- generator.writeEnd();
-
- }
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link CustomSchedulingConfigurationOverrides}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase
- implements
- ObjectBuilder {
- @Nullable
- private Integer maxCrawlDepth;
-
- @Nullable
- private Boolean sitemapDiscoveryDisabled;
-
- @Nullable
- private List domainAllowlist;
-
- @Nullable
- private List sitemapUrls;
-
- @Nullable
- private List seedUrls;
-
- /**
- * API name: {@code max_crawl_depth}
- */
- public final Builder maxCrawlDepth(@Nullable Integer value) {
- this.maxCrawlDepth = value;
- return this;
- }
-
- /**
- * API name: {@code sitemap_discovery_disabled}
- */
- public final Builder sitemapDiscoveryDisabled(@Nullable Boolean value) {
- this.sitemapDiscoveryDisabled = value;
- return this;
- }
-
- /**
- * API name: {@code domain_allowlist}
- *
- * Adds all elements of list to domainAllowlist.
- */
- public final Builder domainAllowlist(List list) {
- this.domainAllowlist = _listAddAll(this.domainAllowlist, list);
- return this;
- }
-
- /**
- * API name: {@code domain_allowlist}
- *
- * Adds one or more values to domainAllowlist.
- */
- public final Builder domainAllowlist(String value, String... values) {
- this.domainAllowlist = _listAdd(this.domainAllowlist, value, values);
- return this;
- }
-
- /**
- * API name: {@code sitemap_urls}
- *
- * Adds all elements of list to sitemapUrls.
- */
- public final Builder sitemapUrls(List list) {
- this.sitemapUrls = _listAddAll(this.sitemapUrls, list);
- return this;
- }
-
- /**
- * API name: {@code sitemap_urls}
- *
- * Adds one or more values to sitemapUrls.
- */
- public final Builder sitemapUrls(String value, String... values) {
- this.sitemapUrls = _listAdd(this.sitemapUrls, value, values);
- return this;
- }
-
- /**
- * API name: {@code seed_urls}
- *
- * Adds all elements of list to seedUrls.
- */
- public final Builder seedUrls(List list) {
- this.seedUrls = _listAddAll(this.seedUrls, list);
- return this;
- }
-
- /**
- * API name: {@code seed_urls}
- *
- * Adds one or more values to seedUrls.
- */
- public final Builder seedUrls(String value, String... values) {
- this.seedUrls = _listAdd(this.seedUrls, value, values);
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link CustomSchedulingConfigurationOverrides}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public CustomSchedulingConfigurationOverrides build() {
- _checkSingleUse();
-
- return new CustomSchedulingConfigurationOverrides(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link CustomSchedulingConfigurationOverrides}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer
- .lazy(Builder::new,
- CustomSchedulingConfigurationOverrides::setupCustomSchedulingConfigurationOverridesDeserializer);
-
- protected static void setupCustomSchedulingConfigurationOverridesDeserializer(
- ObjectDeserializer op) {
-
- op.add(Builder::maxCrawlDepth, JsonpDeserializer.integerDeserializer(), "max_crawl_depth");
- op.add(Builder::sitemapDiscoveryDisabled, JsonpDeserializer.booleanDeserializer(),
- "sitemap_discovery_disabled");
- op.add(Builder::domainAllowlist, JsonpDeserializer.arrayDeserializer(JsonpDeserializer.stringDeserializer()),
- "domain_allowlist");
- op.add(Builder::sitemapUrls, JsonpDeserializer.arrayDeserializer(JsonpDeserializer.stringDeserializer()),
- "sitemap_urls");
- op.add(Builder::seedUrls, JsonpDeserializer.arrayDeserializer(JsonpDeserializer.stringDeserializer()),
- "seed_urls");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DeleteConnectorRequest.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DeleteConnectorRequest.java
deleted file mode 100644
index c0eff592d..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DeleteConnectorRequest.java
+++ /dev/null
@@ -1,207 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.elasticsearch._types.ErrorResponse;
-import co.elastic.clients.elasticsearch._types.RequestBase;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.transport.Endpoint;
-import co.elastic.clients.transport.endpoints.SimpleEndpoint;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.ObjectBuilder;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.Boolean;
-import java.lang.String;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector.delete.Request
-
-/**
- * Deletes a connector.
- *
- * @see API
- * specification
- */
-
-public class DeleteConnectorRequest extends RequestBase {
- private final String connectorId;
-
- private final boolean deleteSyncJobs;
-
- // ---------------------------------------------------------------------------------------------
-
- private DeleteConnectorRequest(Builder builder) {
-
- this.connectorId = ApiTypeHelper.requireNonNull(builder.connectorId, this, "connectorId");
- this.deleteSyncJobs = ApiTypeHelper.requireNonNull(builder.deleteSyncJobs, this, "deleteSyncJobs");
-
- }
-
- public static DeleteConnectorRequest of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * Required - The unique identifier of the connector to be deleted
- *
- * API name: {@code connector_id}
- */
- public final String connectorId() {
- return this.connectorId;
- }
-
- /**
- * Required - Determines whether associated sync jobs are also deleted.
- *
- * API name: {@code delete_sync_jobs}
- */
- public final boolean deleteSyncJobs() {
- return this.deleteSyncJobs;
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link DeleteConnectorRequest}.
- */
-
- public static class Builder extends RequestBase.AbstractBuilder
- implements
- ObjectBuilder {
- private String connectorId;
-
- private Boolean deleteSyncJobs;
-
- /**
- * Required - The unique identifier of the connector to be deleted
- *
- * API name: {@code connector_id}
- */
- public final Builder connectorId(String value) {
- this.connectorId = value;
- return this;
- }
-
- /**
- * Required - Determines whether associated sync jobs are also deleted.
- *
- * API name: {@code delete_sync_jobs}
- */
- public final Builder deleteSyncJobs(boolean value) {
- this.deleteSyncJobs = value;
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link DeleteConnectorRequest}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public DeleteConnectorRequest build() {
- _checkSingleUse();
-
- return new DeleteConnectorRequest(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Endpoint "{@code connector.delete}".
- */
- public static final Endpoint _ENDPOINT = new SimpleEndpoint<>(
- "es/connector.delete",
-
- // Request method
- request -> {
- return "DELETE";
-
- },
-
- // Request path
- request -> {
- final int _connectorId = 1 << 0;
-
- int propsSet = 0;
-
- propsSet |= _connectorId;
-
- if (propsSet == (_connectorId)) {
- StringBuilder buf = new StringBuilder();
- buf.append("/_connector");
- buf.append("/");
- SimpleEndpoint.pathEncode(request.connectorId, buf);
- return buf.toString();
- }
- throw SimpleEndpoint.noPathTemplateFound("path");
-
- },
-
- // Path parameters
- request -> {
- Map params = new HashMap<>();
- final int _connectorId = 1 << 0;
-
- int propsSet = 0;
-
- propsSet |= _connectorId;
-
- if (propsSet == (_connectorId)) {
- params.put("connectorId", request.connectorId);
- }
- return params;
- },
-
- // Request parameters
- request -> {
- Map params = new HashMap<>();
- params.put("delete_sync_jobs", String.valueOf(request.deleteSyncJobs));
- return params;
-
- }, SimpleEndpoint.emptyMap(), false, DeleteConnectorResponse._DESERIALIZER);
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DeleteConnectorResponse.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DeleteConnectorResponse.java
deleted file mode 100644
index 801c81a34..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DeleteConnectorResponse.java
+++ /dev/null
@@ -1,108 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.elasticsearch._types.AcknowledgedResponseBase;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ObjectBuilder;
-import jakarta.json.stream.JsonGenerator;
-import java.util.Objects;
-import java.util.function.Function;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector.delete.Response
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class DeleteConnectorResponse extends AcknowledgedResponseBase {
- // ---------------------------------------------------------------------------------------------
-
- private DeleteConnectorResponse(Builder builder) {
- super(builder);
-
- }
-
- public static DeleteConnectorResponse of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link DeleteConnectorResponse}.
- */
-
- public static class Builder extends AcknowledgedResponseBase.AbstractBuilder
- implements
- ObjectBuilder {
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link DeleteConnectorResponse}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public DeleteConnectorResponse build() {
- _checkSingleUse();
-
- return new DeleteConnectorResponse(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link DeleteConnectorResponse}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer
- .lazy(Builder::new, DeleteConnectorResponse::setupDeleteConnectorResponseDeserializer);
-
- protected static void setupDeleteConnectorResponseDeserializer(
- ObjectDeserializer op) {
- AcknowledgedResponseBase.setupAcknowledgedResponseBaseDeserializer(op);
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/Dependency.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/Dependency.java
deleted file mode 100644
index 2934cefe4..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/Dependency.java
+++ /dev/null
@@ -1,217 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.elasticsearch._types.FieldValue;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-import co.elastic.clients.json.JsonpMapper;
-import co.elastic.clients.json.JsonpSerializable;
-import co.elastic.clients.json.JsonpUtils;
-import co.elastic.clients.json.ObjectBuilderDeserializer;
-import co.elastic.clients.json.ObjectDeserializer;
-import co.elastic.clients.util.ApiTypeHelper;
-import co.elastic.clients.util.ObjectBuilder;
-import co.elastic.clients.util.WithJsonObjectBuilderBase;
-import jakarta.json.stream.JsonGenerator;
-import java.lang.String;
-import java.util.Objects;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-// typedef: connector._types.Dependency
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public class Dependency implements JsonpSerializable {
- private final String field;
-
- private final FieldValue value;
-
- // ---------------------------------------------------------------------------------------------
-
- private Dependency(Builder builder) {
-
- this.field = ApiTypeHelper.requireNonNull(builder.field, this, "field");
- this.value = ApiTypeHelper.requireNonNull(builder.value, this, "value");
-
- }
-
- public static Dependency of(Function> fn) {
- return fn.apply(new Builder()).build();
- }
-
- /**
- * Required - API name: {@code field}
- */
- public final String field() {
- return this.field;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final FieldValue value() {
- return this.value;
- }
-
- /**
- * Serialize this object to JSON.
- */
- public void serialize(JsonGenerator generator, JsonpMapper mapper) {
- generator.writeStartObject();
- serializeInternal(generator, mapper);
- generator.writeEnd();
- }
-
- protected void serializeInternal(JsonGenerator generator, JsonpMapper mapper) {
-
- generator.writeKey("field");
- generator.write(this.field);
-
- generator.writeKey("value");
- this.value.serialize(generator, mapper);
-
- }
-
- @Override
- public String toString() {
- return JsonpUtils.toString(this);
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Builder for {@link Dependency}.
- */
-
- public static class Builder extends WithJsonObjectBuilderBase implements ObjectBuilder {
- private String field;
-
- private FieldValue value;
-
- /**
- * Required - API name: {@code field}
- */
- public final Builder field(String value) {
- this.field = value;
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(FieldValue value) {
- this.value = value;
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(Function> fn) {
- return this.value(fn.apply(new FieldValue.Builder()).build());
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(String value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(long value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(double value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- /**
- * Required - API name: {@code value}
- */
- public final Builder value(boolean value) {
- this.value = FieldValue.of(value);
- return this;
- }
-
- @Override
- protected Builder self() {
- return this;
- }
-
- /**
- * Builds a {@link Dependency}.
- *
- * @throws NullPointerException
- * if some of the required fields are null.
- */
- public Dependency build() {
- _checkSingleUse();
-
- return new Dependency(this);
- }
- }
-
- // ---------------------------------------------------------------------------------------------
-
- /**
- * Json deserializer for {@link Dependency}
- */
- public static final JsonpDeserializer _DESERIALIZER = ObjectBuilderDeserializer.lazy(Builder::new,
- Dependency::setupDependencyDeserializer);
-
- protected static void setupDependencyDeserializer(ObjectDeserializer op) {
-
- op.add(Builder::field, JsonpDeserializer.stringDeserializer(), "field");
- op.add(Builder::value, FieldValue._DESERIALIZER, "value");
-
- }
-
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DisplayType.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DisplayType.java
deleted file mode 100644
index 93fcd3569..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/DisplayType.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.json.JsonEnum;
-import co.elastic.clients.json.JsonpDeserializable;
-import co.elastic.clients.json.JsonpDeserializer;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-/**
- *
- * @see API
- * specification
- */
-@JsonpDeserializable
-public enum DisplayType implements JsonEnum {
- Textbox("textbox"),
-
- Textarea("textarea"),
-
- Numeric("numeric"),
-
- Toggle("toggle"),
-
- Dropdown("dropdown"),
-
- ;
-
- private final String jsonValue;
-
- DisplayType(String jsonValue) {
- this.jsonValue = jsonValue;
- }
-
- public String jsonValue() {
- return this.jsonValue;
- }
-
- public static final JsonEnum.Deserializer _DESERIALIZER = new JsonEnum.Deserializer<>(
- DisplayType.values());
-}
diff --git a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ElasticsearchConnectorAsyncClient.java b/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ElasticsearchConnectorAsyncClient.java
deleted file mode 100644
index 717f7bf3d..000000000
--- a/java-client/src/main/java/co/elastic/clients/elasticsearch/connector/ElasticsearchConnectorAsyncClient.java
+++ /dev/null
@@ -1,922 +0,0 @@
-/*
- * Licensed to Elasticsearch B.V. under one or more contributor
- * license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright
- * ownership. Elasticsearch B.V. licenses this file to you under
- * the Apache License, Version 2.0 (the "License"); you may
- * not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package co.elastic.clients.elasticsearch.connector;
-
-import co.elastic.clients.ApiClient;
-import co.elastic.clients.elasticsearch._types.ErrorResponse;
-import co.elastic.clients.transport.ElasticsearchTransport;
-import co.elastic.clients.transport.Endpoint;
-import co.elastic.clients.transport.JsonEndpoint;
-import co.elastic.clients.transport.Transport;
-import co.elastic.clients.transport.TransportOptions;
-import co.elastic.clients.util.ObjectBuilder;
-import java.util.concurrent.CompletableFuture;
-import java.util.function.Function;
-import javax.annotation.Nullable;
-
-//----------------------------------------------------------------
-// THIS CODE IS GENERATED. MANUAL EDITS WILL BE LOST.
-//----------------------------------------------------------------
-//
-// This code is generated from the Elasticsearch API specification
-// at https://github.com/elastic/elasticsearch-specification
-//
-// Manual updates to this file will be lost when the code is
-// re-generated.
-//
-// If you find a property that is missing or wrongly typed, please
-// open an issue or a PR on the API specification repository.
-//
-//----------------------------------------------------------------
-
-/**
- * Client for the connector namespace.
- */
-public class ElasticsearchConnectorAsyncClient
- extends
- ApiClient {
-
- public ElasticsearchConnectorAsyncClient(ElasticsearchTransport transport) {
- super(transport, null);
- }
-
- public ElasticsearchConnectorAsyncClient(ElasticsearchTransport transport,
- @Nullable TransportOptions transportOptions) {
- super(transport, transportOptions);
- }
-
- @Override
- public ElasticsearchConnectorAsyncClient withTransportOptions(@Nullable TransportOptions transportOptions) {
- return new ElasticsearchConnectorAsyncClient(this.transport, transportOptions);
- }
-
- // ----- Endpoint: connector.check_in
-
- /**
- * Updates the last_seen timestamp in the connector document.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture checkIn(CheckInRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) CheckInRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the last_seen timestamp in the connector document.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link CheckInRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture checkIn(
- Function> fn) {
- return checkIn(fn.apply(new CheckInRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.delete
-
- /**
- * Deletes a connector.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture delete(DeleteConnectorRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) DeleteConnectorRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Deletes a connector.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link DeleteConnectorRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture delete(
- Function> fn) {
- return delete(fn.apply(new DeleteConnectorRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.get
-
- /**
- * Returns the details about a connector.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture get(GetConnectorRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) GetConnectorRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Returns the details about a connector.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link GetConnectorRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture get(
- Function> fn) {
- return get(fn.apply(new GetConnectorRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.last_sync
-
- /**
- * Updates the stats of last sync in the connector document.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture lastSync(LastSyncRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) LastSyncRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the stats of last sync in the connector document.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link LastSyncRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture lastSync(
- Function> fn) {
- return lastSync(fn.apply(new LastSyncRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.list
-
- /**
- * Lists all connectors.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture list(ListRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) ListRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Lists all connectors.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link ListRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture list(Function> fn) {
- return list(fn.apply(new ListRequest.Builder()).build());
- }
-
- /**
- * Lists all connectors.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture list() {
- return this.transport.performRequestAsync(new ListRequest.Builder().build(), ListRequest._ENDPOINT,
- this.transportOptions);
- }
-
- // ----- Endpoint: connector.post
-
- /**
- * Creates a connector.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture post(PostRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) PostRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Creates a connector.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link PostRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture post(Function> fn) {
- return post(fn.apply(new PostRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.put
-
- /**
- * Creates or updates a connector.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture put(PutRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) PutRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Creates or updates a connector.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link PutRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture put(Function> fn) {
- return put(fn.apply(new PutRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.sync_job_cancel
-
- /**
- * Cancels a connector sync job.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture syncJobCancel(SyncJobCancelRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) SyncJobCancelRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Cancels a connector sync job.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link SyncJobCancelRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture syncJobCancel(
- Function> fn) {
- return syncJobCancel(fn.apply(new SyncJobCancelRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.sync_job_delete
-
- /**
- * Deletes a connector sync job.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture syncJobDelete(SyncJobDeleteRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) SyncJobDeleteRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Deletes a connector sync job.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link SyncJobDeleteRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture syncJobDelete(
- Function> fn) {
- return syncJobDelete(fn.apply(new SyncJobDeleteRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.sync_job_get
-
- /**
- * Returns the details about a connector sync job.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture syncJobGet(SyncJobGetRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) SyncJobGetRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Returns the details about a connector sync job.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link SyncJobGetRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture syncJobGet(
- Function> fn) {
- return syncJobGet(fn.apply(new SyncJobGetRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.sync_job_list
-
- /**
- * Lists all connector sync jobs.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture syncJobList(SyncJobListRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) SyncJobListRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Lists all connector sync jobs.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link SyncJobListRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture syncJobList(
- Function> fn) {
- return syncJobList(fn.apply(new SyncJobListRequest.Builder()).build());
- }
-
- /**
- * Lists all connector sync jobs.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture syncJobList() {
- return this.transport.performRequestAsync(new SyncJobListRequest.Builder().build(),
- SyncJobListRequest._ENDPOINT, this.transportOptions);
- }
-
- // ----- Endpoint: connector.sync_job_post
-
- /**
- * Creates a connector sync job.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture syncJobPost(SyncJobPostRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) SyncJobPostRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Creates a connector sync job.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link SyncJobPostRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture syncJobPost(
- Function> fn) {
- return syncJobPost(fn.apply(new SyncJobPostRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_active_filtering
-
- /**
- * Activates the draft filtering rules if they are in a validated state.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateActiveFiltering(
- UpdateActiveFilteringRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) UpdateActiveFilteringRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Activates the draft filtering rules if they are in a validated state.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link UpdateActiveFilteringRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture updateActiveFiltering(
- Function> fn) {
- return updateActiveFiltering(fn.apply(new UpdateActiveFilteringRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_api_key_id
-
- /**
- * Updates the API key id and/or API key secret id fields in the connector
- * document.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateApiKeyId(UpdateApiKeyIdRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) UpdateApiKeyIdRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the API key id and/or API key secret id fields in the connector
- * document.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link UpdateApiKeyIdRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture updateApiKeyId(
- Function> fn) {
- return updateApiKeyId(fn.apply(new UpdateApiKeyIdRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_configuration
-
- /**
- * Updates the connector configuration.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateConfiguration(UpdateConfigurationRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) UpdateConfigurationRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the connector configuration.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link UpdateConfigurationRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture updateConfiguration(
- Function> fn) {
- return updateConfiguration(fn.apply(new UpdateConfigurationRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_error
-
- /**
- * Updates the error field in the connector document.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateError(UpdateErrorRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) UpdateErrorRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the error field in the connector document.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link UpdateErrorRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture updateError(
- Function> fn) {
- return updateError(fn.apply(new UpdateErrorRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_filtering
-
- /**
- * Updates the filtering field in the connector document.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateFiltering(UpdateFilteringRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) UpdateFilteringRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the filtering field in the connector document.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link UpdateFilteringRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture updateFiltering(
- Function> fn) {
- return updateFiltering(fn.apply(new UpdateFilteringRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_filtering_validation
-
- /**
- * Updates the validation info of the draft filtering rules.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateFilteringValidation(
- UpdateFilteringValidationRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint endpoint = (JsonEndpoint) UpdateFilteringValidationRequest._ENDPOINT;
-
- return this.transport.performRequestAsync(request, endpoint, this.transportOptions);
- }
-
- /**
- * Updates the validation info of the draft filtering rules.
- *
- * @param fn
- * a function that initializes a builder to create the
- * {@link UpdateFilteringValidationRequest}
- * @see Documentation
- * on elastic.co
- */
-
- public final CompletableFuture updateFilteringValidation(
- Function> fn) {
- return updateFilteringValidation(fn.apply(new UpdateFilteringValidationRequest.Builder()).build());
- }
-
- // ----- Endpoint: connector.update_index_name
-
- /**
- * Updates the index name of the connector.
- *
- * @see Documentation
- * on elastic.co
- */
-
- public CompletableFuture updateIndexName(UpdateIndexNameRequest request) {
- @SuppressWarnings("unchecked")
- JsonEndpoint