diff --git a/sdk/appconfiguration/azure-data-appconfiguration/assets.json b/sdk/appconfiguration/azure-data-appconfiguration/assets.json
index 483c204715e3..a33a4464a944 100644
--- a/sdk/appconfiguration/azure-data-appconfiguration/assets.json
+++ b/sdk/appconfiguration/azure-data-appconfiguration/assets.json
@@ -2,5 +2,5 @@
"AssetsRepo": "Azure/azure-sdk-assets",
"AssetsRepoPrefixPath": "java",
"TagPrefix": "java/appconfiguration/azure-data-appconfiguration",
- "Tag": "java/appconfiguration/azure-data-appconfiguration_5ae4f3bbf8"
+ "Tag": "java/appconfiguration/azure-data-appconfiguration_3dbe0483cd"
}
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/swagger/pom.xml b/sdk/appconfiguration/azure-data-appconfiguration/customization/pom.xml
similarity index 85%
rename from sdk/appconfiguration/azure-data-appconfiguration/swagger/pom.xml
rename to sdk/appconfiguration/azure-data-appconfiguration/customization/pom.xml
index a2b237785f67..072119cc2800 100644
--- a/sdk/appconfiguration/azure-data-appconfiguration/swagger/pom.xml
+++ b/sdk/appconfiguration/azure-data-appconfiguration/customization/pom.xml
@@ -12,10 +12,10 @@
Microsoft Azure App Configuration client for Java
- This package contains client functionality for Microsoft Azure App Configuration
+ This package contains client customization for Microsoft Azure App Configuration
com.azure.tools
- azure-data-appconfiguration-autorest-customization
+ azure-data-appconfiguration-customization
1.0.0-beta.1
jar
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/customization/src/main/java/AppConfigurationCustomizations.java b/sdk/appconfiguration/azure-data-appconfiguration/customization/src/main/java/AppConfigurationCustomizations.java
new file mode 100644
index 000000000000..e7e334e7ab03
--- /dev/null
+++ b/sdk/appconfiguration/azure-data-appconfiguration/customization/src/main/java/AppConfigurationCustomizations.java
@@ -0,0 +1,190 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+import org.slf4j.Logger;
+
+import com.azure.autorest.customization.Customization;
+import com.azure.autorest.customization.Editor;
+import com.azure.autorest.customization.LibraryCustomization;
+
+/**
+ * Removes generated public client surface so the hand-written ConfigurationClient,
+ * ConfigurationAsyncClient, ConfigurationClientBuilder, and ConfigurationServiceVersion
+ * in com.azure.data.appconfiguration are not overwritten by tsp-client update.
+ * The generated implementation client under com.azure.data.appconfiguration.implementation
+ * is preserved and used by the hand-written public classes.
+ *
+ * Also promotes the generated private *SinglePage / *SinglePageAsync / *NextSinglePage
+ * methods on AzureAppConfigurationImpl to public so the hand-written paging code in
+ * ConfigurationClient and ConfigurationAsyncClient can drive pagination directly
+ * (needed for per-page conditional ETag matching).
+ */
+public class AppConfigurationCustomizations extends Customization {
+
+ private static final String ROOT_FILE_PATH = "src/main/java/com/azure/data/appconfiguration/";
+
+ // typespec-java emits the impl as AzureAppConfigurationImpl. The hand-written public client code
+ // references ConfigurationClientImpl, so we rename the generated class+file in customization.
+ private static final String GENERATED_IMPL_PATH
+ = ROOT_FILE_PATH + "implementation/AzureAppConfigurationImpl.java";
+ private static final String IMPL_CLIENT_PATH
+ = ROOT_FILE_PATH + "implementation/ConfigurationClientImpl.java";
+
+ private static final String[] FILES_TO_REMOVE = new String[] {
+ // The public client surface (ConfigurationClient/AsyncClient/Builder/ServiceVersion) is hand-written.
+ // Drop the codegen-emitted Azure*-prefixed copies so the hand-written versions survive regeneration.
+ "AzureAppConfigurationServiceVersion.java",
+ "AzureAppConfigurationClient.java",
+ "AzureAppConfigurationAsyncClient.java",
+ "AzureAppConfigurationBuilder.java"
+ };
+
+ // Matches: " private Mono> fooSinglePageAsync("
+ // " private PagedResponse fooSinglePage("
+ // " private Mono> fooNextSinglePageAsync("
+ // " private PagedResponse fooNextSinglePage("
+ private static final Pattern SINGLE_PAGE_METHOD = Pattern.compile(
+ "(^|\\n)(\\s*)private(\\s+(?:Mono>|PagedResponse)\\s+\\w*SinglePage\\w*\\s*\\()");
+
+ // Matches the createSnapshotWithResponse / createSnapshotWithResponseAsync helpers we need to drive the LRO
+ // ourselves from CreateSnapshotUtilClient (typespec-java generates them as private).
+ private static final Pattern CREATE_SNAPSHOT_HELPER = Pattern.compile(
+ "(^|\\n)(\\s*)private(\\s+(?:Mono>|Response)\\s+createSnapshotWithResponse\\w*\\s*\\()");
+
+ @Override
+ public void customize(LibraryCustomization customization, Logger logger) {
+ Editor editor = customization.getRawEditor();
+ for (String fileName : FILES_TO_REMOVE) {
+ String path = ROOT_FILE_PATH + fileName;
+ if (editor.getContents().containsKey(path)) {
+ editor.removeFile(path);
+ logger.info("Removed generated file {}", path);
+ } else {
+ logger.info("Generated file {} not present; skipping removal.", path);
+ }
+ }
+ renameGeneratedImpl(editor, logger);
+ promoteSinglePageMethodsToPublic(editor, logger);
+ patchModuleInfo(editor, logger);
+ addKeyValueSetKey(editor, logger);
+ }
+
+ // typespec-java emits implementation/AzureAppConfigurationImpl.java with class AzureAppConfigurationImpl
+ // and references to AzureAppConfigurationServiceVersion. The hand-written public client surface
+ // (ConfigurationClient/AsyncClient/Builder) targets ConfigurationClientImpl + ConfigurationServiceVersion,
+ // so rewrite both the class name and the service-version type, and move the file to the expected path.
+ private static void renameGeneratedImpl(Editor editor, Logger logger) {
+ String content = editor.getContents().get(GENERATED_IMPL_PATH);
+ if (content == null) {
+ logger.info("{} not present; skipping impl rename.", GENERATED_IMPL_PATH);
+ return;
+ }
+ // Order matters: rewrite the longer ServiceVersion token first so the bare
+ // "AzureAppConfigurationService" rename below doesn't partially clobber it.
+ String renamed = content
+ .replace("AzureAppConfigurationServiceVersion", "ConfigurationServiceVersion")
+ .replace("AzureAppConfigurationImpl", "ConfigurationClientImpl")
+ .replace("AzureAppConfigurationService", "ConfigurationClientService");
+ editor.addFile(IMPL_CLIENT_PATH, renamed);
+ editor.removeFile(GENERATED_IMPL_PATH);
+ logger.info("Renamed generated impl {} -> {} (class AzureAppConfigurationImpl -> ConfigurationClientImpl).",
+ GENERATED_IMPL_PATH, IMPL_CLIENT_PATH);
+ }
+
+ // The TypeSpec @key decorator drops the setter for KeyValue.key. We still need to populate it on
+ // the request body for set/put operations, so add the setter back via customization.
+ private static void addKeyValueSetKey(Editor editor, Logger logger) {
+ String path = ROOT_FILE_PATH + "implementation/models/KeyValue.java";
+ String content = editor.getContents().get(path);
+ if (content == null) {
+ logger.warn("{} not present; skipping setKey injection.", path);
+ return;
+ }
+ if (content.contains("public KeyValue setKey(")) {
+ logger.info("KeyValue.setKey already present; no patch needed.");
+ return;
+ }
+ String marker = " public String getKey() {";
+ int idx = content.indexOf(marker);
+ if (idx < 0) {
+ logger.warn("Could not find getKey() in KeyValue; skipping setKey injection.");
+ return;
+ }
+ String setter = " /**\n"
+ + " * Set the key property: The key of the key-value.\n"
+ + " *\n"
+ + " * @param key the key value to set.\n"
+ + " * @return the KeyValue object itself.\n"
+ + " */\n"
+ + " public KeyValue setKey(String key) {\n"
+ + " this.key = key;\n"
+ + " return this;\n"
+ + " }\n\n";
+ String updated = content.substring(0, idx) + setter + content.substring(idx);
+ editor.replaceFile(path, updated);
+ logger.info("Injected KeyValue.setKey(String).");
+ }
+
+ private static void patchModuleInfo(Editor editor, Logger logger) {
+ String path = "src/main/java/module-info.java";
+ String content = editor.getContents().get(path);
+ if (content == null) {
+ logger.warn("{} not present; skipping module-info patch.", path);
+ return;
+ }
+ String updated = content;
+ if (!updated.contains("exports com.azure.data.appconfiguration.models;")) {
+ updated = updated.replace(
+ "exports com.azure.data.appconfiguration;",
+ "exports com.azure.data.appconfiguration;\n exports com.azure.data.appconfiguration.models;");
+ }
+ if (!updated.contains("opens com.azure.data.appconfiguration.models to com.azure.core;")) {
+ updated = updated.replace(
+ "opens com.azure.data.appconfiguration.implementation.models to com.azure.core;",
+ "opens com.azure.data.appconfiguration.implementation.models to com.azure.core;\n"
+ + " opens com.azure.data.appconfiguration.models to com.azure.core;");
+ }
+ if (!updated.equals(content)) {
+ editor.replaceFile(path, updated);
+ logger.info("Patched module-info.java to export and open com.azure.data.appconfiguration.models.");
+ } else {
+ logger.info("module-info.java already exports models package; no patch needed.");
+ }
+ }
+
+ // The generated impl references typespec-generated AzureAppConfigurationServiceVersion which we delete.
+ // The rename in renameGeneratedImpl handles rewriting this.
+
+ private static void promoteSinglePageMethodsToPublic(Editor editor, Logger logger) {
+ String content = editor.getContents().get(IMPL_CLIENT_PATH);
+ if (content == null) {
+ logger.warn("{} not present; skipping single-page visibility promotion.", IMPL_CLIENT_PATH);
+ return;
+ }
+ content = promote(content, SINGLE_PAGE_METHOD, "single-page", logger);
+ content = promote(content, CREATE_SNAPSHOT_HELPER, "createSnapshotWithResponse", logger);
+ editor.replaceFile(IMPL_CLIENT_PATH, content);
+ }
+
+ private static String promote(String content, Pattern pattern, String label, Logger logger) {
+ Matcher matcher = pattern.matcher(content);
+ StringBuffer sb = new StringBuffer();
+ int count = 0;
+ while (matcher.find()) {
+ matcher.appendReplacement(sb,
+ Matcher.quoteReplacement(matcher.group(1) + matcher.group(2) + "public" + matcher.group(3)));
+ count++;
+ }
+ matcher.appendTail(sb);
+ if (count > 0) {
+ logger.info("Promoted {} {} method(s) on ConfigurationClientImpl from private to public.",
+ count, label);
+ } else {
+ logger.info("No private {} methods found on ConfigurationClientImpl to promote.", label);
+ }
+ return sb.toString();
+ }
+}
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationAsyncClient.java b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationAsyncClient.java
index 63d8223a6dc4..f81992d7e3fe 100644
--- a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationAsyncClient.java
+++ b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationAsyncClient.java
@@ -14,18 +14,17 @@
import com.azure.core.http.rest.PagedFlux;
import com.azure.core.http.rest.PagedResponse;
import com.azure.core.http.rest.Response;
-import com.azure.core.http.rest.ResponseBase;
import com.azure.core.http.rest.SimpleResponse;
import com.azure.core.util.Context;
import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.PollOperationDetails;
import com.azure.core.util.polling.PollerFlux;
-import com.azure.data.appconfiguration.implementation.AzureAppConfigurationImpl;
+import com.azure.data.appconfiguration.implementation.ConfigurationClientImpl;
import com.azure.data.appconfiguration.implementation.ConfigurationSettingDeserializationHelper;
import com.azure.data.appconfiguration.implementation.CreateSnapshotUtilClient;
+import com.azure.data.appconfiguration.implementation.ImplBridge;
import com.azure.data.appconfiguration.implementation.SyncTokenPolicy;
import com.azure.data.appconfiguration.implementation.Utility;
-import com.azure.data.appconfiguration.implementation.models.GetKeyValueHeaders;
import com.azure.data.appconfiguration.implementation.models.KeyValue;
import com.azure.data.appconfiguration.models.ConfigurationSetting;
import com.azure.data.appconfiguration.models.ConfigurationSnapshot;
@@ -295,10 +294,10 @@
@ServiceClient(
builder = ConfigurationClientBuilder.class,
isAsync = true,
- serviceInterfaces = AzureAppConfigurationImpl.AzureAppConfigurationService.class)
+ serviceInterfaces = ConfigurationClientImpl.ConfigurationClientService.class)
public final class ConfigurationAsyncClient {
private static final ClientLogger LOGGER = new ClientLogger(ConfigurationAsyncClient.class);
- private final AzureAppConfigurationImpl serviceClient;
+ private final ConfigurationClientImpl serviceClient;
private final SyncTokenPolicy syncTokenPolicy;
final CreateSnapshotUtilClient createSnapshotUtilClient;
@@ -307,11 +306,11 @@ public final class ConfigurationAsyncClient {
* Creates a ConfigurationAsyncClient that sends requests to the configuration service at {@code serviceEndpoint}.
* Each service call goes through the {@code pipeline}.
*
- * @param serviceClient The {@link AzureAppConfigurationImpl} that the client routes its request through.
+ * @param serviceClient The {@link ConfigurationClientImpl} that the client routes its request through.
* @param syncTokenPolicy {@link SyncTokenPolicy} to be used to update the external synchronization token to ensure
* service requests receive up-to-date values.
*/
- ConfigurationAsyncClient(AzureAppConfigurationImpl serviceClient, SyncTokenPolicy syncTokenPolicy) {
+ ConfigurationAsyncClient(ConfigurationClientImpl serviceClient, SyncTokenPolicy syncTokenPolicy) {
this.serviceClient = serviceClient;
this.syncTokenPolicy = syncTokenPolicy;
this.createSnapshotUtilClient = new CreateSnapshotUtilClient(serviceClient);
@@ -430,9 +429,9 @@ public Mono> addConfigurationSettingWithResponse(
// This service method call is similar to setConfigurationSetting except we're passing If-Not-Match = "*".
// If the service finds any existing configuration settings, then its e-tag will match and the service will
// return an error.
- return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> serviceClient
- .putKeyValueWithResponseAsync(settingInternal.getKey(), settingInternal.getLabel(), null, ETAG_ANY,
- toKeyValue(settingInternal), context)
+ return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> ImplBridge
+ .putKeyValueWithResponseAsync(serviceClient, settingInternal.getKey(), settingInternal.getLabel(), null,
+ ETAG_ANY, toKeyValue(settingInternal), context)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithResponse)));
}
@@ -572,8 +571,8 @@ public Mono setConfigurationSetting(ConfigurationSetting s
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> setConfigurationSettingWithResponse(ConfigurationSetting setting,
boolean ifUnchanged) {
- return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> serviceClient
- .putKeyValueWithResponseAsync(settingInternal.getKey(), settingInternal.getLabel(),
+ return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> ImplBridge
+ .putKeyValueWithResponseAsync(serviceClient, settingInternal.getKey(), settingInternal.getLabel(),
getETag(ifUnchanged, settingInternal), null, toKeyValue(settingInternal), context)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithResponse)));
}
@@ -716,20 +715,19 @@ public Mono getConfigurationSetting(ConfigurationSetting s
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getConfigurationSettingWithResponse(ConfigurationSetting setting,
OffsetDateTime acceptDateTime, boolean ifChanged) {
- return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> serviceClient
- .getKeyValueWithResponseAsync(settingInternal.getKey(), settingInternal.getLabel(),
- acceptDateTime == null ? null : acceptDateTime.toString(), null, getETag(ifChanged, settingInternal),
- null, context)
- .onErrorResume(HttpResponseException.class,
- (Function>>) throwable -> {
- HttpResponseException e = (HttpResponseException) throwable;
- HttpResponse httpResponse = e.getResponse();
- if (httpResponse.getStatusCode() == 304) {
- return Mono.just(new ResponseBase(httpResponse.getRequest(),
- httpResponse.getStatusCode(), httpResponse.getHeaders(), null, null));
- }
- return Mono.error(throwable);
- })
+ return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> ImplBridge
+ .getKeyValueWithResponseAsync(serviceClient, settingInternal.getKey(), settingInternal.getLabel(),
+ acceptDateTime == null ? null : acceptDateTime.toString(), null /* syncToken */, null /* ifMatch */,
+ getETag(ifChanged, settingInternal) /* ifNoneMatch */, null /* fields */, context)
+ .onErrorResume(HttpResponseException.class, (Function>>) throwable -> {
+ HttpResponseException e = (HttpResponseException) throwable;
+ HttpResponse httpResponse = e.getResponse();
+ if (httpResponse.getStatusCode() == 304) {
+ return Mono.just(new SimpleResponse<>(httpResponse.getRequest(), httpResponse.getStatusCode(),
+ httpResponse.getHeaders(), null));
+ }
+ return Mono.error(throwable);
+ })
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithResponse)));
}
@@ -849,8 +847,8 @@ public Mono deleteConfigurationSetting(ConfigurationSettin
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> deleteConfigurationSettingWithResponse(ConfigurationSetting setting,
boolean ifUnchanged) {
- return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> serviceClient
- .deleteKeyValueWithResponseAsync(settingInternal.getKey(), settingInternal.getLabel(),
+ return withContext(context -> validateSettingAsync(setting).flatMap(settingInternal -> ImplBridge
+ .deleteKeyValueWithResponseAsync(serviceClient, settingInternal.getKey(), settingInternal.getLabel(),
getETag(ifUnchanged, settingInternal), context)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithResponse)));
}
@@ -1000,8 +998,8 @@ public Mono> setReadOnlyWithResponse(Configuratio
final String key = settingInternal.getKey();
final String label = settingInternal.getLabel();
return (isReadOnly
- ? serviceClient.putLockWithResponseAsync(key, label, null, null, context)
- : serviceClient.deleteLockWithResponseAsync(key, label, null, null, context))
+ ? ImplBridge.putLockWithResponseAsync(serviceClient, key, label, null, null, context)
+ : ImplBridge.deleteLockWithResponseAsync(serviceClient, key, label, null, null, context))
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithResponse);
}));
}
@@ -1037,14 +1035,14 @@ public PagedFlux listConfigurationSettings(SettingSelector
final List matchConditionsList = selector == null ? null : selector.getMatchConditions();
final List tagsFilter = selector == null ? null : selector.getTagsFilter();
AtomicInteger pageETagIndex = new AtomicInteger(0);
- return new PagedFlux<>(() -> withContext(context -> serviceClient
- .getKeyValuesSinglePageAsync(keyFilter, labelFilter, null, acceptDateTime, settingFields, null, null,
- getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context)
+ return new PagedFlux<>(() -> withContext(context -> ImplBridge
+ .getKeyValuesSinglePageAsync(serviceClient, keyFilter, labelFilter, null, acceptDateTime, settingFields,
+ null, null, getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context)
.onErrorResume(HttpResponseException.class,
(Function>>) Utility::handleNotModifiedErrorToValidResponse)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithPagedResponse)),
- nextLink -> withContext(context -> serviceClient
- .getKeyValuesNextSinglePageAsync(nextLink, acceptDateTime, null,
+ nextLink -> withContext(context -> ImplBridge
+ .getKeyValuesNextSinglePageAsync(serviceClient, nextLink, acceptDateTime, null,
getPageETag(matchConditionsList, pageETagIndex), context)
.onErrorResume(HttpResponseException.class,
(Function>>) Utility::handleNotModifiedErrorToValidResponse)
@@ -1086,15 +1084,15 @@ public PagedFlux checkConfigurationSettings(SettingSelecto
final List matchConditionsList = selector == null ? null : selector.getMatchConditions();
final List tagsFilter = selector == null ? null : selector.getTagsFilter();
AtomicInteger pageETagIndex = new AtomicInteger(0);
- return new PagedFlux<>(() -> withContext(context -> serviceClient
- .checkKeyValuesWithResponseAsync(keyFilter, labelFilter, null, acceptDateTime, settingFields, null, null,
- getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context)
+ return new PagedFlux<>(() -> withContext(context -> ImplBridge
+ .checkKeyValuesWithResponseAsync(serviceClient, keyFilter, labelFilter, null, acceptDateTime, settingFields,
+ null, null, getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context)
.map(Utility::toHeadPagedResponse)
.onErrorResume(HttpResponseException.class,
(Function>>) Utility::handleHeadNotModifiedErrorToValidResponse)),
- afterToken -> withContext(context -> serviceClient
- .checkKeyValuesWithResponseAsync(keyFilter, labelFilter, afterToken, acceptDateTime, settingFields,
- null, null, getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context)
+ afterToken -> withContext(context -> ImplBridge
+ .checkKeyValuesWithResponseAsync(serviceClient, keyFilter, labelFilter, afterToken, acceptDateTime,
+ settingFields, null, null, getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context)
.map(Utility::toHeadPagedResponse)
.onErrorResume(HttpResponseException.class,
(Function>>) Utility::handleHeadNotModifiedErrorToValidResponse)));
@@ -1156,12 +1154,13 @@ public PagedFlux listConfigurationSettingsForSnapshot(Stri
public PagedFlux listConfigurationSettingsForSnapshot(String snapshotName,
List fields) {
return new PagedFlux<>(
- () -> withContext(context -> serviceClient
- .getKeyValuesSinglePageAsync(null, null, null, null, fields, snapshotName, null, null, null, context)
+ () -> withContext(context -> ImplBridge
+ .getKeyValuesSinglePageAsync(serviceClient, null, null, null, null, fields, snapshotName, null, null,
+ null, context)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithPagedResponse)),
- nextLink -> withContext(
- context -> serviceClient.getKeyValuesNextSinglePageAsync(nextLink, null, null, null, context)
- .map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithPagedResponse)));
+ nextLink -> withContext(context -> ImplBridge
+ .getKeyValuesNextSinglePageAsync(serviceClient, nextLink, null, null, null, context)
+ .map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithPagedResponse)));
}
/**
@@ -1198,11 +1197,12 @@ public PagedFlux listRevisions(SettingSelector selector) {
final List settingFields = selector == null ? null : toSettingFieldsList(selector.getFields());
List tags = selector == null ? null : selector.getTagsFilter();
return new PagedFlux<>(
- () -> withContext(context -> serviceClient
- .getRevisionsSinglePageAsync(keyFilter, labelFilter, null, acceptDateTime, settingFields, tags, context)
+ () -> withContext(context -> ImplBridge
+ .getRevisionsSinglePageAsync(serviceClient, keyFilter, labelFilter, null, acceptDateTime, settingFields,
+ tags, context)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithPagedResponse)),
nextLink -> withContext(
- context -> serviceClient.getRevisionsNextSinglePageAsync(nextLink, acceptDateTime, context)
+ context -> ImplBridge.getRevisionsNextSinglePageAsync(serviceClient, nextLink, acceptDateTime, context)
.map(ConfigurationSettingDeserializationHelper::toConfigurationSettingWithPagedResponse)));
}
@@ -1299,8 +1299,7 @@ public Mono getSnapshot(String snapshotName) {
@ServiceMethod(returns = ReturnType.SINGLE)
public Mono> getSnapshotWithResponse(String snapshotName,
List fields) {
- return serviceClient.getSnapshotWithResponseAsync(snapshotName, null, null, fields, Context.NONE)
- .map(response -> new SimpleResponse<>(response, response.getValue()));
+ return ImplBridge.getSnapshotWithResponseAsync(serviceClient, snapshotName, null, null, fields, Context.NONE);
}
/**
@@ -1449,11 +1448,12 @@ public Mono> recoverSnapshotWithResponse(String
public PagedFlux listSnapshots(SnapshotSelector selector) {
try {
return new PagedFlux<>(
- () -> withContext(context -> serviceClient.getSnapshotsSinglePageAsync(
+ () -> withContext(context -> ImplBridge.getSnapshotsSinglePageAsync(serviceClient,
selector == null ? null : selector.getNameFilter(), null,
selector == null ? null : selector.getFields(), selector == null ? null : selector.getStatus(),
context)),
- nextLink -> withContext(context -> serviceClient.getSnapshotsNextSinglePageAsync(nextLink, context)));
+ nextLink -> withContext(
+ context -> ImplBridge.getSnapshotsNextSinglePageAsync(serviceClient, nextLink, context)));
} catch (RuntimeException ex) {
return new PagedFlux<>(() -> monoError(LOGGER, ex));
}
@@ -1511,7 +1511,7 @@ public PagedFlux listLabels(SettingLabelSelector selector) {
? null
: selector.getAcceptDateTime() == null ? null : selector.getAcceptDateTime().toString();
final List labelFields = selector == null ? null : selector.getFields();
- return serviceClient.getLabelsAsync(labelNameFilter, null, acceptDatetime, labelFields);
+ return ImplBridge.getLabelsAsync(serviceClient, labelNameFilter, null, acceptDatetime, labelFields);
}
/**
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClient.java b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClient.java
index a069509d06e1..c85f5590c31b 100644
--- a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClient.java
+++ b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClient.java
@@ -16,19 +16,15 @@
import com.azure.core.http.rest.PagedResponse;
import com.azure.core.http.rest.Response;
import com.azure.core.http.rest.ResponseBase;
-import com.azure.core.http.rest.SimpleResponse;
import com.azure.core.util.Context;
import com.azure.core.util.logging.ClientLogger;
import com.azure.core.util.polling.PollOperationDetails;
import com.azure.core.util.polling.SyncPoller;
-import com.azure.data.appconfiguration.implementation.AzureAppConfigurationImpl;
+import com.azure.data.appconfiguration.implementation.ConfigurationClientImpl;
import com.azure.data.appconfiguration.implementation.CreateSnapshotUtilClient;
+import com.azure.data.appconfiguration.implementation.ImplBridge;
import com.azure.data.appconfiguration.implementation.SyncTokenPolicy;
-import com.azure.data.appconfiguration.implementation.models.DeleteKeyValueHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetKeyValueHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetSnapshotHeaders;
import com.azure.data.appconfiguration.implementation.models.KeyValue;
-import com.azure.data.appconfiguration.implementation.models.PutKeyValueHeaders;
import com.azure.data.appconfiguration.models.ConfigurationSetting;
import com.azure.data.appconfiguration.models.ConfigurationSnapshot;
import com.azure.data.appconfiguration.models.ConfigurationSnapshotStatus;
@@ -296,10 +292,10 @@
*/
@ServiceClient(
builder = ConfigurationClientBuilder.class,
- serviceInterfaces = AzureAppConfigurationImpl.AzureAppConfigurationService.class)
+ serviceInterfaces = ConfigurationClientImpl.ConfigurationClientService.class)
public final class ConfigurationClient {
private static final ClientLogger LOGGER = new ClientLogger(ConfigurationClient.class);
- private final AzureAppConfigurationImpl serviceClient;
+ private final ConfigurationClientImpl serviceClient;
private final SyncTokenPolicy syncTokenPolicy;
final CreateSnapshotUtilClient createSnapshotUtilClient;
@@ -308,11 +304,11 @@ public final class ConfigurationClient {
* Creates a ConfigurationClient that sends requests to the configuration service at {@code serviceEndpoint}. Each
* service call goes through the {@code pipeline}.
*
- * @param serviceClient The {@link AzureAppConfigurationImpl} that the client routes its request through.
+ * @param serviceClient The {@link ConfigurationClientImpl} that the client routes its request through.
* @param syncTokenPolicy {@link SyncTokenPolicy} to be used to update the external synchronization token to ensure
* service requests receive up-to-date values.
*/
- ConfigurationClient(AzureAppConfigurationImpl serviceClient, SyncTokenPolicy syncTokenPolicy) {
+ ConfigurationClient(ConfigurationClientImpl serviceClient, SyncTokenPolicy syncTokenPolicy) {
this.serviceClient = serviceClient;
this.syncTokenPolicy = syncTokenPolicy;
this.createSnapshotUtilClient = new CreateSnapshotUtilClient(serviceClient);
@@ -435,8 +431,8 @@ public Response addConfigurationSettingWithResponse(Config
// This service method call is similar to setConfigurationSetting except we're passing If-Not-Match = "*".
// If the service finds any existing configuration settings, then its e-tag will match and the service will
// return an error.
- final ResponseBase response = serviceClient.putKeyValueWithResponse(
- setting.getKey(), setting.getLabel(), null, ETAG_ANY, toKeyValue(setting), context);
+ final Response response = ImplBridge.putKeyValueWithResponse(serviceClient, setting.getKey(),
+ setting.getLabel(), null, ETAG_ANY, toKeyValue(setting), context);
return toConfigurationSettingWithResponse(response);
}
@@ -580,8 +576,8 @@ public ConfigurationSetting setConfigurationSetting(ConfigurationSetting setting
public Response setConfigurationSettingWithResponse(ConfigurationSetting setting,
boolean ifUnchanged, Context context) {
validateSetting(setting);
- final ResponseBase response = serviceClient.putKeyValueWithResponse(
- setting.getKey(), setting.getLabel(), getETag(ifUnchanged, setting), null, toKeyValue(setting), context);
+ final Response response = ImplBridge.putKeyValueWithResponse(serviceClient, setting.getKey(),
+ setting.getLabel(), getETag(ifUnchanged, setting), null, toKeyValue(setting), context);
return toConfigurationSettingWithResponse(response);
}
@@ -724,9 +720,9 @@ public Response getConfigurationSettingWithResponse(Config
OffsetDateTime acceptDateTime, boolean ifChanged, Context context) {
validateSetting(setting);
try {
- final ResponseBase response = serviceClient.getKeyValueWithResponse(
- setting.getKey(), setting.getLabel(), acceptDateTime == null ? null : acceptDateTime.toString(), null,
- getETag(ifChanged, setting), null, context);
+ final Response response = ImplBridge.getKeyValueWithResponse(serviceClient, setting.getKey(),
+ setting.getLabel(), acceptDateTime == null ? null : acceptDateTime.toString(), null /* syncToken */,
+ null /* ifMatch */, getETag(ifChanged, setting) /* ifNoneMatch */, null /* fields */, context);
return toConfigurationSettingWithResponse(response);
} catch (HttpResponseException ex) {
final HttpResponse httpResponse = ex.getResponse();
@@ -850,8 +846,8 @@ public ConfigurationSetting deleteConfigurationSetting(ConfigurationSetting sett
public Response deleteConfigurationSettingWithResponse(ConfigurationSetting setting,
boolean ifUnchanged, Context context) {
validateSetting(setting);
- final ResponseBase response = serviceClient
- .deleteKeyValueWithResponse(setting.getKey(), setting.getLabel(), getETag(ifUnchanged, setting), context);
+ final Response response = ImplBridge.deleteKeyValueWithResponse(serviceClient, setting.getKey(),
+ setting.getLabel(), getETag(ifUnchanged, setting), context);
return toConfigurationSettingWithResponse(response);
}
@@ -996,8 +992,10 @@ public Response setReadOnlyWithResponse(ConfigurationSetti
final String label = setting.getLabel();
return isReadOnly
- ? toConfigurationSettingWithResponse(serviceClient.putLockWithResponse(key, label, null, null, context))
- : toConfigurationSettingWithResponse(serviceClient.deleteLockWithResponse(key, label, null, null, context));
+ ? toConfigurationSettingWithResponse(
+ ImplBridge.putLockWithResponse(serviceClient, key, label, null, null, context))
+ : toConfigurationSettingWithResponse(
+ ImplBridge.deleteLockWithResponse(serviceClient, key, label, null, null, context));
}
/**
@@ -1064,8 +1062,9 @@ public PagedIterable listConfigurationSettings(SettingSele
return new PagedIterable<>(() -> {
PagedResponse pagedResponse;
try {
- pagedResponse = serviceClient.getKeyValuesSinglePage(keyFilter, labelFilter, null, acceptDateTime,
- settingFields, null, null, getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context);
+ pagedResponse = ImplBridge.getKeyValuesSinglePage(serviceClient, keyFilter, labelFilter, null,
+ acceptDateTime, settingFields, null, null, getPageETag(matchConditionsList, pageETagIndex),
+ tagsFilter, context);
} catch (HttpResponseException ex) {
return handleNotModifiedErrorToValidResponse(ex, LOGGER);
}
@@ -1073,7 +1072,7 @@ public PagedIterable listConfigurationSettings(SettingSele
}, nextLink -> {
PagedResponse pagedResponse;
try {
- pagedResponse = serviceClient.getKeyValuesNextSinglePage(nextLink, acceptDateTime, null,
+ pagedResponse = ImplBridge.getKeyValuesNextSinglePage(serviceClient, nextLink, acceptDateTime, null,
getPageETag(matchConditionsList, pageETagIndex), context);
} catch (HttpResponseException ex) {
return handleNotModifiedErrorToValidResponse(ex, LOGGER);
@@ -1153,17 +1152,17 @@ public PagedIterable checkConfigurationSettings(SettingSel
AtomicInteger pageETagIndex = new AtomicInteger(0);
return new PagedIterable<>(() -> {
try {
- return toHeadPagedResponse(serviceClient.checkKeyValuesWithResponse(keyFilter, labelFilter, null,
- acceptDateTime, settingFields, null, null, getPageETag(matchConditionsList, pageETagIndex),
+ return toHeadPagedResponse(ImplBridge.checkKeyValuesWithResponse(serviceClient, keyFilter, labelFilter,
+ null, acceptDateTime, settingFields, null, null, getPageETag(matchConditionsList, pageETagIndex),
tagsFilter, context));
} catch (HttpResponseException ex) {
return handleHeadNotModifiedErrorToValidResponse(ex, LOGGER);
}
}, afterToken -> {
try {
- return toHeadPagedResponse(serviceClient.checkKeyValuesWithResponse(keyFilter, labelFilter, afterToken,
- acceptDateTime, settingFields, null, null, getPageETag(matchConditionsList, pageETagIndex),
- tagsFilter, context));
+ return toHeadPagedResponse(ImplBridge.checkKeyValuesWithResponse(serviceClient, keyFilter, labelFilter,
+ afterToken, acceptDateTime, settingFields, null, null,
+ getPageETag(matchConditionsList, pageETagIndex), tagsFilter, context));
} catch (HttpResponseException ex) {
return handleHeadNotModifiedErrorToValidResponse(ex, LOGGER);
}
@@ -1227,12 +1226,12 @@ public PagedIterable listConfigurationSettingsForSnapshot(
public PagedIterable listConfigurationSettingsForSnapshot(String snapshotName,
List fields, Context context) {
return new PagedIterable<>(() -> {
- final PagedResponse pagedResponse = serviceClient.getKeyValuesSinglePage(null, null, null, null,
- fields, snapshotName, null, null, null, context);
+ final PagedResponse pagedResponse = ImplBridge.getKeyValuesSinglePage(serviceClient, null, null,
+ null, null, fields, snapshotName, null, null, null, context);
return toConfigurationSettingWithPagedResponse(pagedResponse);
}, nextLink -> {
final PagedResponse pagedResponse
- = serviceClient.getKeyValuesNextSinglePage(nextLink, null, null, null, context);
+ = ImplBridge.getKeyValuesNextSinglePage(serviceClient, nextLink, null, null, null, context);
return toConfigurationSettingWithPagedResponse(pagedResponse);
});
}
@@ -1304,14 +1303,14 @@ public PagedIterable listRevisions(SettingSelector selecto
public PagedIterable listRevisions(SettingSelector selector, Context context) {
final String acceptDateTime = selector == null ? null : selector.getAcceptDateTime();
return new PagedIterable<>(() -> {
- final PagedResponse pagedResponse = serviceClient.getRevisionsSinglePage(
+ final PagedResponse pagedResponse = ImplBridge.getRevisionsSinglePage(serviceClient,
selector == null ? null : selector.getKeyFilter(), selector == null ? null : selector.getLabelFilter(),
null, acceptDateTime, selector == null ? null : toSettingFieldsList(selector.getFields()),
selector == null ? null : selector.getTagsFilter(), context);
return toConfigurationSettingWithPagedResponse(pagedResponse);
}, nextLink -> {
final PagedResponse pagedResponse
- = serviceClient.getRevisionsNextSinglePage(nextLink, acceptDateTime, context);
+ = ImplBridge.getRevisionsNextSinglePage(serviceClient, nextLink, acceptDateTime, context);
return toConfigurationSettingWithPagedResponse(pagedResponse);
});
}
@@ -1408,9 +1407,7 @@ public ConfigurationSnapshot getSnapshot(String snapshotName) {
@ServiceMethod(returns = ReturnType.SINGLE)
public Response getSnapshotWithResponse(String snapshotName, List fields,
Context context) {
- final ResponseBase response
- = serviceClient.getSnapshotWithResponse(snapshotName, null, null, fields, context);
- return new SimpleResponse<>(response, response.getValue());
+ return ImplBridge.getSnapshotWithResponse(serviceClient, snapshotName, null, null, fields, context);
}
/**
@@ -1579,11 +1576,10 @@ public PagedIterable listSnapshots(SnapshotSelector selec
*/
@ServiceMethod(returns = ReturnType.COLLECTION)
public PagedIterable listSnapshots(SnapshotSelector selector, Context context) {
- return new PagedIterable<>(
- () -> serviceClient.getSnapshotsSinglePage(selector == null ? null : selector.getNameFilter(), null,
- selector == null ? null : selector.getFields(), selector == null ? null : selector.getStatus(),
- context),
- nextLink -> serviceClient.getSnapshotsNextSinglePage(nextLink, context));
+ return new PagedIterable<>(() -> ImplBridge.getSnapshotsSinglePage(serviceClient,
+ selector == null ? null : selector.getNameFilter(), null, selector == null ? null : selector.getFields(),
+ selector == null ? null : selector.getStatus(), context),
+ nextLink -> ImplBridge.getSnapshotsNextSinglePage(serviceClient, nextLink, context));
}
/**
@@ -1667,7 +1663,7 @@ public PagedIterable listLabels(SettingLabelSelector selector, Con
? null
: selector.getAcceptDateTime() == null ? null : selector.getAcceptDateTime().toString();
final List labelFields = selector == null ? null : selector.getFields();
- return serviceClient.getLabels(labelNameFilter, null, acceptDatetime, labelFields, context);
+ return ImplBridge.getLabels(serviceClient, labelNameFilter, null, acceptDatetime, labelFields, context);
}
/**
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClientBuilder.java b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClientBuilder.java
index 26a0b21942b4..96b7d5a2e1af 100644
--- a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClientBuilder.java
+++ b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/ConfigurationClientBuilder.java
@@ -49,7 +49,7 @@
import com.azure.core.util.tracing.Tracer;
import com.azure.core.util.tracing.TracerProvider;
import com.azure.data.appconfiguration.implementation.AudiencePolicy;
-import com.azure.data.appconfiguration.implementation.AzureAppConfigurationImpl;
+import com.azure.data.appconfiguration.implementation.ConfigurationClientImpl;
import static com.azure.data.appconfiguration.implementation.ClientConstants.APP_CONFIG_TRACING_NAMESPACE_VALUE;
import com.azure.data.appconfiguration.implementation.ConfigurationClientCredentials;
import com.azure.data.appconfiguration.implementation.ConfigurationCredentialsPolicy;
@@ -208,7 +208,7 @@ public ConfigurationAsyncClient buildAsyncClient() {
* @throws IllegalArgumentException if {@code tokenCredential} is not null. App Configuration builder support single
* authentication per builder instance.
*/
- private AzureAppConfigurationImpl buildInnerClient(SyncTokenPolicy syncTokenPolicy) {
+ private ConfigurationClientImpl buildInnerClient(SyncTokenPolicy syncTokenPolicy) {
String endpointLocal = endpoint;
ConfigurationClientCredentials credentialsLocal = null;
TokenCredential tokenCredentialLocal = null;
@@ -238,7 +238,7 @@ private AzureAppConfigurationImpl buildInnerClient(SyncTokenPolicy syncTokenPoli
? createDefaultHttpPipeline(syncTokenPolicy, credentialsLocal, tokenCredentialLocal)
: pipeline;
- return new AzureAppConfigurationImpl(buildPipeline, null, endpointLocal, serviceVersion.getVersion());
+ return new ConfigurationClientImpl(buildPipeline, endpointLocal, serviceVersion);
}
private HttpPipeline createDefaultHttpPipeline(SyncTokenPolicy syncTokenPolicy,
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/implementation/AzureAppConfigurationImpl.java b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/implementation/AzureAppConfigurationImpl.java
deleted file mode 100644
index b8f328c6c3d8..000000000000
--- a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/implementation/AzureAppConfigurationImpl.java
+++ /dev/null
@@ -1,7240 +0,0 @@
-// Copyright (c) Microsoft Corporation. All rights reserved.
-// Licensed under the MIT License.
-// Code generated by Microsoft (R) AutoRest Code Generator.
-
-package com.azure.data.appconfiguration.implementation;
-
-import com.azure.core.annotation.BodyParam;
-import com.azure.core.annotation.Delete;
-import com.azure.core.annotation.ExpectedResponses;
-import com.azure.core.annotation.Get;
-import com.azure.core.annotation.Head;
-import com.azure.core.annotation.HeaderParam;
-import com.azure.core.annotation.Host;
-import com.azure.core.annotation.HostParam;
-import com.azure.core.annotation.Patch;
-import com.azure.core.annotation.PathParam;
-import com.azure.core.annotation.Put;
-import com.azure.core.annotation.QueryParam;
-import com.azure.core.annotation.ReturnType;
-import com.azure.core.annotation.ServiceInterface;
-import com.azure.core.annotation.ServiceMethod;
-import com.azure.core.annotation.UnexpectedResponseExceptionType;
-import com.azure.core.exception.HttpResponseException;
-import com.azure.core.http.HttpPipeline;
-import com.azure.core.http.HttpPipelineBuilder;
-import com.azure.core.http.policy.RetryPolicy;
-import com.azure.core.http.policy.UserAgentPolicy;
-import com.azure.core.http.rest.PagedFlux;
-import com.azure.core.http.rest.PagedIterable;
-import com.azure.core.http.rest.PagedResponse;
-import com.azure.core.http.rest.PagedResponseBase;
-import com.azure.core.http.rest.Response;
-import com.azure.core.http.rest.ResponseBase;
-import com.azure.core.http.rest.RestProxy;
-import com.azure.core.util.Context;
-import com.azure.core.util.FluxUtil;
-import com.azure.core.util.serializer.JacksonAdapter;
-import com.azure.core.util.serializer.SerializerAdapter;
-import com.azure.data.appconfiguration.implementation.models.CheckKeyValueHeaders;
-import com.azure.data.appconfiguration.implementation.models.CheckKeyValuesHeaders;
-import com.azure.data.appconfiguration.implementation.models.CheckKeysHeaders;
-import com.azure.data.appconfiguration.implementation.models.CheckLabelsHeaders;
-import com.azure.data.appconfiguration.implementation.models.CheckRevisionsHeaders;
-import com.azure.data.appconfiguration.implementation.models.CheckSnapshotHeaders;
-import com.azure.data.appconfiguration.implementation.models.CheckSnapshotsHeaders;
-import com.azure.data.appconfiguration.implementation.models.CreateSnapshotHeaders;
-import com.azure.data.appconfiguration.implementation.models.DeleteKeyValueHeaders;
-import com.azure.data.appconfiguration.implementation.models.DeleteLockHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetKeyValueHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetKeyValuesHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetKeyValuesNextHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetKeysHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetKeysNextHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetLabelsHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetLabelsNextHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetRevisionsHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetRevisionsNextHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetSnapshotHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetSnapshotsHeaders;
-import com.azure.data.appconfiguration.implementation.models.GetSnapshotsNextHeaders;
-import com.azure.data.appconfiguration.implementation.models.Key;
-import com.azure.data.appconfiguration.implementation.models.KeyListResult;
-import com.azure.data.appconfiguration.implementation.models.KeyValue;
-import com.azure.data.appconfiguration.implementation.models.KeyValueListResult;
-import com.azure.data.appconfiguration.implementation.models.LabelListResult;
-import com.azure.data.appconfiguration.implementation.models.OperationDetails;
-import com.azure.data.appconfiguration.implementation.models.PutKeyValueHeaders;
-import com.azure.data.appconfiguration.implementation.models.PutLockHeaders;
-import com.azure.data.appconfiguration.implementation.models.SnapshotListResult;
-import com.azure.data.appconfiguration.implementation.models.SnapshotUpdateParameters;
-import com.azure.data.appconfiguration.implementation.models.UpdateSnapshotHeaders;
-import com.azure.data.appconfiguration.models.ConfigurationSnapshot;
-import com.azure.data.appconfiguration.models.ConfigurationSnapshotStatus;
-import com.azure.data.appconfiguration.models.SettingFields;
-import com.azure.data.appconfiguration.models.SettingLabel;
-import com.azure.data.appconfiguration.models.SettingLabelFields;
-import com.azure.data.appconfiguration.models.SnapshotFields;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
-import java.util.stream.Collectors;
-import reactor.core.publisher.Mono;
-
-/**
- * Initializes a new instance of the AzureAppConfiguration type.
- */
-public final class AzureAppConfigurationImpl {
- /**
- * The proxy service used to perform REST calls.
- */
- private final AzureAppConfigurationService service;
-
- /**
- * Used to guarantee real-time consistency between requests.
- */
- private final String syncToken;
-
- /**
- * Gets Used to guarantee real-time consistency between requests.
- *
- * @return the syncToken value.
- */
- public String getSyncToken() {
- return this.syncToken;
- }
-
- /**
- * The endpoint of the App Configuration instance to send requests to.
- */
- private final String endpoint;
-
- /**
- * Gets The endpoint of the App Configuration instance to send requests to.
- *
- * @return the endpoint value.
- */
- public String getEndpoint() {
- return this.endpoint;
- }
-
- /**
- * Api Version.
- */
- private final String apiVersion;
-
- /**
- * Gets Api Version.
- *
- * @return the apiVersion value.
- */
- public String getApiVersion() {
- return this.apiVersion;
- }
-
- /**
- * The HTTP pipeline to send requests through.
- */
- private final HttpPipeline httpPipeline;
-
- /**
- * Gets The HTTP pipeline to send requests through.
- *
- * @return the httpPipeline value.
- */
- public HttpPipeline getHttpPipeline() {
- return this.httpPipeline;
- }
-
- /**
- * The serializer to serialize an object into a string.
- */
- private final SerializerAdapter serializerAdapter;
-
- /**
- * Gets The serializer to serialize an object into a string.
- *
- * @return the serializerAdapter value.
- */
- public SerializerAdapter getSerializerAdapter() {
- return this.serializerAdapter;
- }
-
- /**
- * Initializes an instance of AzureAppConfiguration client.
- *
- * @param syncToken Used to guarantee real-time consistency between requests.
- * @param endpoint The endpoint of the App Configuration instance to send requests to.
- * @param apiVersion Api Version.
- */
- public AzureAppConfigurationImpl(String syncToken, String endpoint, String apiVersion) {
- this(new HttpPipelineBuilder().policies(new UserAgentPolicy(), new RetryPolicy()).build(),
- JacksonAdapter.createDefaultSerializerAdapter(), syncToken, endpoint, apiVersion);
- }
-
- /**
- * Initializes an instance of AzureAppConfiguration client.
- *
- * @param httpPipeline The HTTP pipeline to send requests through.
- * @param syncToken Used to guarantee real-time consistency between requests.
- * @param endpoint The endpoint of the App Configuration instance to send requests to.
- * @param apiVersion Api Version.
- */
- public AzureAppConfigurationImpl(HttpPipeline httpPipeline, String syncToken, String endpoint, String apiVersion) {
- this(httpPipeline, JacksonAdapter.createDefaultSerializerAdapter(), syncToken, endpoint, apiVersion);
- }
-
- /**
- * Initializes an instance of AzureAppConfiguration client.
- *
- * @param httpPipeline The HTTP pipeline to send requests through.
- * @param serializerAdapter The serializer to serialize an object into a string.
- * @param syncToken Used to guarantee real-time consistency between requests.
- * @param endpoint The endpoint of the App Configuration instance to send requests to.
- * @param apiVersion Api Version.
- */
- public AzureAppConfigurationImpl(HttpPipeline httpPipeline, SerializerAdapter serializerAdapter, String syncToken,
- String endpoint, String apiVersion) {
- this.httpPipeline = httpPipeline;
- this.serializerAdapter = serializerAdapter;
- this.syncToken = syncToken;
- this.endpoint = endpoint;
- this.apiVersion = apiVersion;
- this.service
- = RestProxy.create(AzureAppConfigurationService.class, this.httpPipeline, this.getSerializerAdapter());
- }
-
- /**
- * The interface defining all the services for AzureAppConfiguration to be used by the proxy service to perform REST
- * calls.
- */
- @Host("{endpoint}")
- @ServiceInterface(name = "AzureAppConfiguration")
- public interface AzureAppConfigurationService {
- @Get("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeys(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("Accept") String accept,
- Context context);
-
- @Get("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeysNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("Accept") String accept,
- Context context);
-
- @Get("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getKeysSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("Accept") String accept,
- Context context);
-
- @Get("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getKeysNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("Accept") String accept,
- Context context);
-
- @Head("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkKeys(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, Context context);
-
- @Head("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkKeysNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, Context context);
-
- @Head("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkKeysSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, Context context);
-
- @Head("/keys")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkKeysNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, Context context);
-
- @Get("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeyValues(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeyValuesNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getKeyValuesSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getKeyValuesNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Head("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkKeyValues(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Head("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkKeyValuesNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Head("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkKeyValuesSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Head("/kv")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkKeyValuesNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select, @QueryParam("snapshot") String snapshot,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Get("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeyValue(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeyValueNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getKeyValueSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getKeyValueNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Put("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> putKeyValue(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") KeyValue entity, @HeaderParam("Accept") String accept, Context context);
-
- @Put("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> putKeyValueNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") KeyValue entity, @HeaderParam("Accept") String accept, Context context);
-
- @Put("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase putKeyValueSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") KeyValue entity, @HeaderParam("Accept") String accept, Context context);
-
- @Put("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response putKeyValueNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") KeyValue entity, @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/kv/{key}")
- @ExpectedResponses({ 200, 204 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> deleteKeyValue(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/kv/{key}")
- @ExpectedResponses({ 200, 204 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> deleteKeyValueNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/kv/{key}")
- @ExpectedResponses({ 200, 204 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase deleteKeyValueSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/kv/{key}")
- @ExpectedResponses({ 200, 204 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response deleteKeyValueNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("Accept") String accept, Context context);
-
- @Head("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkKeyValue(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select, Context context);
-
- @Head("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkKeyValueNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select, Context context);
-
- @Head("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkKeyValueSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select, Context context);
-
- @Head("/kv/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkKeyValueNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select, Context context);
-
- @Get("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getSnapshots(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @QueryParam("$Select") String select, @QueryParam("status") String status,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getSnapshotsNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @QueryParam("$Select") String select, @QueryParam("status") String status,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getSnapshotsSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @QueryParam("$Select") String select, @QueryParam("status") String status,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getSnapshotsNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @QueryParam("$Select") String select, @QueryParam("status") String status,
- @HeaderParam("Accept") String accept, Context context);
-
- @Head("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkSnapshots(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, Context context);
-
- @Head("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkSnapshotsNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, Context context);
-
- @Head("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkSnapshotsSync(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, Context context);
-
- @Head("/snapshots")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkSnapshotsNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, Context context);
-
- @Get("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getSnapshot(
- @HostParam("endpoint") String endpoint, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @PathParam("name") String name,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @QueryParam("$Select") String select, @HeaderParam("Accept") String accept, Context context);
-
- @Get("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getSnapshotNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @PathParam("name") String name, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getSnapshotSync(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @PathParam("name") String name, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getSnapshotNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @PathParam("name") String name, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Put("/snapshots/{name}")
- @ExpectedResponses({ 201 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> createSnapshot(
- @HostParam("endpoint") String endpoint, @PathParam("name") String name,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @BodyParam("application/json") ConfigurationSnapshot entity, @HeaderParam("Accept") String accept,
- Context context);
-
- @Put("/snapshots/{name}")
- @ExpectedResponses({ 201 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> createSnapshotNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @BodyParam("application/json") ConfigurationSnapshot entity,
- @HeaderParam("Accept") String accept, Context context);
-
- @Put("/snapshots/{name}")
- @ExpectedResponses({ 201 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase createSnapshotSync(
- @HostParam("endpoint") String endpoint, @PathParam("name") String name,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @BodyParam("application/json") ConfigurationSnapshot entity, @HeaderParam("Accept") String accept,
- Context context);
-
- @Put("/snapshots/{name}")
- @ExpectedResponses({ 201 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response createSnapshotNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @BodyParam("application/json") ConfigurationSnapshot entity,
- @HeaderParam("Accept") String accept, Context context);
-
- @Patch("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> updateSnapshot(
- @HostParam("endpoint") String endpoint, @PathParam("name") String name,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") SnapshotUpdateParameters entity, @HeaderParam("Accept") String accept,
- Context context);
-
- @Patch("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> updateSnapshotNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") SnapshotUpdateParameters entity, @HeaderParam("Accept") String accept,
- Context context);
-
- @Patch("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase updateSnapshotSync(
- @HostParam("endpoint") String endpoint, @PathParam("name") String name,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") SnapshotUpdateParameters entity, @HeaderParam("Accept") String accept,
- Context context);
-
- @Patch("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response updateSnapshotNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch,
- @BodyParam("application/json") SnapshotUpdateParameters entity, @HeaderParam("Accept") String accept,
- Context context);
-
- @Head("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkSnapshot(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, Context context);
-
- @Head("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkSnapshotNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, Context context);
-
- @Head("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkSnapshotSync(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, Context context);
-
- @Head("/snapshots/{name}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkSnapshotNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @HeaderParam("If-Match") String ifMatch,
- @HeaderParam("If-None-Match") String ifNoneMatch, Context context);
-
- @Get("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getLabels(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getLabelsNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getLabelsSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getLabelsNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- @HeaderParam("Accept") String accept, Context context);
-
- @Head("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkLabels(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- Context context);
-
- @Head("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkLabelsNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- Context context);
-
- @Head("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkLabelsSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- Context context);
-
- @Head("/labels")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkLabelsNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("name") String name, @HeaderParam("Sync-Token") String syncToken,
- @QueryParam("api-version") String apiVersion, @QueryParam("After") String after,
- @HeaderParam("Accept-Datetime") String acceptDatetime, @QueryParam("$Select") String select,
- Context context);
-
- @Put("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> putLock(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Put("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> putLockNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Put("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase putLockSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Put("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response putLockNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> deleteLock(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> deleteLockNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase deleteLockSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Delete("/locks/{key}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response deleteLockNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @PathParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getRevisions(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getRevisionsNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getRevisionsSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getRevisionsNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags,
- @HeaderParam("Accept") String accept, Context context);
-
- @Head("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkRevisions(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Head("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> checkRevisionsNoCustomHeaders(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Head("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase checkRevisionsSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Head("/revisions")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response checkRevisionsNoCustomHeadersSync(@HostParam("endpoint") String endpoint,
- @QueryParam("key") String key, @QueryParam("label") String label,
- @HeaderParam("Sync-Token") String syncToken, @QueryParam("api-version") String apiVersion,
- @QueryParam("After") String after, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @QueryParam("$Select") String select,
- @QueryParam(value = "tags", multipleQueryParams = true) List tags, Context context);
-
- @Get("/operations")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getOperationDetails(@HostParam("endpoint") String endpoint,
- @QueryParam("api-version") String apiVersion, @QueryParam("snapshot") String snapshot,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("/operations")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getOperationDetailsSync(@HostParam("endpoint") String endpoint,
- @QueryParam("api-version") String apiVersion, @QueryParam("snapshot") String snapshot,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeysNext(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeysNextNoCustomHeaders(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getKeysNextSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getKeysNextNoCustomHeadersSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeyValuesNext(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getKeyValuesNextNoCustomHeaders(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getKeyValuesNextSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getKeyValuesNextNoCustomHeadersSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("If-Match") String ifMatch, @HeaderParam("If-None-Match") String ifNoneMatch,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getSnapshotsNext(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getSnapshotsNextNoCustomHeaders(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getSnapshotsNextSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getSnapshotsNextNoCustomHeadersSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getLabelsNext(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getLabelsNextNoCustomHeaders(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getLabelsNextSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getLabelsNextNoCustomHeadersSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getRevisionsNext(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Mono> getRevisionsNextNoCustomHeaders(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- ResponseBase getRevisionsNextSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
-
- @Get("{nextLink}")
- @ExpectedResponses({ 200 })
- @UnexpectedResponseExceptionType(HttpResponseException.class)
- Response getRevisionsNextNoCustomHeadersSync(
- @PathParam(value = "nextLink", encoded = true) String nextLink, @HostParam("endpoint") String endpoint,
- @HeaderParam("Sync-Token") String syncToken, @HeaderParam("Accept-Datetime") String acceptDatetime,
- @HeaderParam("Accept") String accept, Context context);
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeysSinglePageAsync(String name, String after, String acceptDatetime) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- return FluxUtil
- .withContext(context -> service.getKeys(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(),
- after, acceptDatetime, accept, context))
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), res.getDeserializedHeaders()));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeysSinglePageAsync(String name, String after, String acceptDatetime,
- Context context) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- return service
- .getKeys(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(), after, acceptDatetime, accept,
- context)
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), res.getDeserializedHeaders()));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeysAsync(String name, String after, String acceptDatetime) {
- return new PagedFlux<>(() -> getKeysSinglePageAsync(name, after, acceptDatetime),
- nextLink -> getKeysNextSinglePageAsync(nextLink, acceptDatetime));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeysAsync(String name, String after, String acceptDatetime, Context context) {
- return new PagedFlux<>(() -> getKeysSinglePageAsync(name, after, acceptDatetime, context),
- nextLink -> getKeysNextSinglePageAsync(nextLink, acceptDatetime, context));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeysNoCustomHeadersSinglePageAsync(String name, String after,
- String acceptDatetime) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- return FluxUtil
- .withContext(context -> service.getKeysNoCustomHeaders(this.getEndpoint(), name, this.getSyncToken(),
- this.getApiVersion(), after, acceptDatetime, accept, context))
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), null));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeysNoCustomHeadersSinglePageAsync(String name, String after,
- String acceptDatetime, Context context) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- return service
- .getKeysNoCustomHeaders(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(), after,
- acceptDatetime, accept, context)
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), null));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeysNoCustomHeadersAsync(String name, String after, String acceptDatetime) {
- return new PagedFlux<>(() -> getKeysNoCustomHeadersSinglePageAsync(name, after, acceptDatetime),
- nextLink -> getKeysNextSinglePageAsync(nextLink, acceptDatetime));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeysNoCustomHeadersAsync(String name, String after, String acceptDatetime,
- Context context) {
- return new PagedFlux<>(() -> getKeysNoCustomHeadersSinglePageAsync(name, after, acceptDatetime, context),
- nextLink -> getKeysNextSinglePageAsync(nextLink, acceptDatetime, context));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public PagedResponse getKeysSinglePage(String name, String after, String acceptDatetime) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- ResponseBase res = service.getKeysSync(this.getEndpoint(), name,
- this.getSyncToken(), this.getApiVersion(), after, acceptDatetime, accept, Context.NONE);
- return new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), res.getDeserializedHeaders());
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public PagedResponse getKeysSinglePage(String name, String after, String acceptDatetime, Context context) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- ResponseBase res = service.getKeysSync(this.getEndpoint(), name,
- this.getSyncToken(), this.getApiVersion(), after, acceptDatetime, accept, context);
- return new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), res.getDeserializedHeaders());
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedIterable}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedIterable getKeys(String name, String after, String acceptDatetime) {
- return new PagedIterable<>(() -> getKeysSinglePage(name, after, acceptDatetime),
- nextLink -> getKeysNextSinglePage(nextLink, acceptDatetime));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedIterable}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedIterable getKeys(String name, String after, String acceptDatetime, Context context) {
- return new PagedIterable<>(() -> getKeysSinglePage(name, after, acceptDatetime, context),
- nextLink -> getKeysNextSinglePage(nextLink, acceptDatetime, context));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public PagedResponse getKeysNoCustomHeadersSinglePage(String name, String after, String acceptDatetime) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- Response res = service.getKeysNoCustomHeadersSync(this.getEndpoint(), name, this.getSyncToken(),
- this.getApiVersion(), after, acceptDatetime, accept, Context.NONE);
- return new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), null);
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys along with {@link PagedResponse}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public PagedResponse getKeysNoCustomHeadersSinglePage(String name, String after, String acceptDatetime,
- Context context) {
- final String accept = "application/vnd.microsoft.appconfig.keyset+json, application/problem+json";
- Response res = service.getKeysNoCustomHeadersSync(this.getEndpoint(), name, this.getSyncToken(),
- this.getApiVersion(), after, acceptDatetime, accept, context);
- return new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), null);
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedIterable}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedIterable getKeysNoCustomHeaders(String name, String after, String acceptDatetime) {
- return new PagedIterable<>(() -> getKeysNoCustomHeadersSinglePage(name, after, acceptDatetime),
- nextLink -> getKeysNextSinglePage(nextLink, acceptDatetime));
- }
-
- /**
- * Gets a list of keys.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of keys as paginated response with {@link PagedIterable}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedIterable getKeysNoCustomHeaders(String name, String after, String acceptDatetime,
- Context context) {
- return new PagedIterable<>(() -> getKeysNoCustomHeadersSinglePage(name, after, acceptDatetime, context),
- nextLink -> getKeysNextSinglePage(nextLink, acceptDatetime, context));
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the {@link ResponseBase} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> checkKeysWithResponseAsync(String name, String after,
- String acceptDatetime) {
- return FluxUtil.withContext(context -> checkKeysWithResponseAsync(name, after, acceptDatetime, context));
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the {@link ResponseBase} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> checkKeysWithResponseAsync(String name, String after,
- String acceptDatetime, Context context) {
- return service.checkKeys(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(), after,
- acceptDatetime, context);
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return A {@link Mono} that completes when a successful response is received.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono checkKeysAsync(String name, String after, String acceptDatetime) {
- return checkKeysWithResponseAsync(name, after, acceptDatetime).flatMap(ignored -> Mono.empty());
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return A {@link Mono} that completes when a successful response is received.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono checkKeysAsync(String name, String after, String acceptDatetime, Context context) {
- return checkKeysWithResponseAsync(name, after, acceptDatetime, context).flatMap(ignored -> Mono.empty());
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the {@link Response} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> checkKeysNoCustomHeadersWithResponseAsync(String name, String after,
- String acceptDatetime) {
- return FluxUtil
- .withContext(context -> checkKeysNoCustomHeadersWithResponseAsync(name, after, acceptDatetime, context));
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the {@link Response} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> checkKeysNoCustomHeadersWithResponseAsync(String name, String after,
- String acceptDatetime, Context context) {
- return service.checkKeysNoCustomHeaders(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(),
- after, acceptDatetime, context);
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the {@link ResponseBase}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public ResponseBase checkKeysWithResponse(String name, String after, String acceptDatetime,
- Context context) {
- return service.checkKeysSync(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(), after,
- acceptDatetime, context);
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public void checkKeys(String name, String after, String acceptDatetime) {
- checkKeysWithResponse(name, after, acceptDatetime, Context.NONE);
- }
-
- /**
- * Requests the headers and status of the given resource.
- *
- * @param name A filter for the name of the returned keys.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return the {@link Response}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Response checkKeysNoCustomHeadersWithResponse(String name, String after, String acceptDatetime,
- Context context) {
- return service.checkKeysNoCustomHeadersSync(this.getEndpoint(), name, this.getSyncToken(), this.getApiVersion(),
- after, acceptDatetime, context);
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeyValuesSinglePageAsync(String key, String label, String after,
- String acceptDatetime, List select, String snapshot, String ifMatch, String ifNoneMatch,
- List tags) {
- final String accept = "application/vnd.microsoft.appconfig.kvset+json, application/problem+json";
- String selectConverted = (select == null)
- ? null
- : select.stream()
- .map(paramItemValue -> Objects.toString(paramItemValue, ""))
- .collect(Collectors.joining(","));
- List tagsConverted = (tags == null)
- ? new ArrayList<>()
- : tags.stream().map(item -> Objects.toString(item, "")).collect(Collectors.toList());
- return FluxUtil
- .withContext(context -> service.getKeyValues(this.getEndpoint(), key, label, this.getSyncToken(),
- this.getApiVersion(), after, acceptDatetime, selectConverted, snapshot, ifMatch, ifNoneMatch,
- tagsConverted, accept, context))
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), res.getDeserializedHeaders()));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeyValuesSinglePageAsync(String key, String label, String after,
- String acceptDatetime, List select, String snapshot, String ifMatch, String ifNoneMatch,
- List tags, Context context) {
- final String accept = "application/vnd.microsoft.appconfig.kvset+json, application/problem+json";
- String selectConverted = (select == null)
- ? null
- : select.stream()
- .map(paramItemValue -> Objects.toString(paramItemValue, ""))
- .collect(Collectors.joining(","));
- List tagsConverted = (tags == null)
- ? new ArrayList<>()
- : tags.stream().map(item -> Objects.toString(item, "")).collect(Collectors.toList());
- return service
- .getKeyValues(this.getEndpoint(), key, label, this.getSyncToken(), this.getApiVersion(), after,
- acceptDatetime, selectConverted, snapshot, ifMatch, ifNoneMatch, tagsConverted, accept, context)
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), res.getDeserializedHeaders()));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeyValuesAsync(String key, String label, String after, String acceptDatetime,
- List select, String snapshot, String ifMatch, String ifNoneMatch, List tags) {
- return new PagedFlux<>(() -> getKeyValuesSinglePageAsync(key, label, after, acceptDatetime, select, snapshot,
- ifMatch, ifNoneMatch, tags),
- nextLink -> getKeyValuesNextSinglePageAsync(nextLink, acceptDatetime, ifMatch, ifNoneMatch));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeyValuesAsync(String key, String label, String after, String acceptDatetime,
- List select, String snapshot, String ifMatch, String ifNoneMatch, List tags,
- Context context) {
- return new PagedFlux<>(
- () -> getKeyValuesSinglePageAsync(key, label, after, acceptDatetime, select, snapshot, ifMatch, ifNoneMatch,
- tags, context),
- nextLink -> getKeyValuesNextSinglePageAsync(nextLink, acceptDatetime, ifMatch, ifNoneMatch, context));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeyValuesNoCustomHeadersSinglePageAsync(String key, String label,
- String after, String acceptDatetime, List select, String snapshot, String ifMatch,
- String ifNoneMatch, List tags) {
- final String accept = "application/vnd.microsoft.appconfig.kvset+json, application/problem+json";
- String selectConverted = (select == null)
- ? null
- : select.stream()
- .map(paramItemValue -> Objects.toString(paramItemValue, ""))
- .collect(Collectors.joining(","));
- List tagsConverted = (tags == null)
- ? new ArrayList<>()
- : tags.stream().map(item -> Objects.toString(item, "")).collect(Collectors.toList());
- return FluxUtil
- .withContext(context -> service.getKeyValuesNoCustomHeaders(this.getEndpoint(), key, label,
- this.getSyncToken(), this.getApiVersion(), after, acceptDatetime, selectConverted, snapshot, ifMatch,
- ifNoneMatch, tagsConverted, accept, context))
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), null));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values along with {@link PagedResponse} on successful completion of {@link Mono}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public Mono> getKeyValuesNoCustomHeadersSinglePageAsync(String key, String label,
- String after, String acceptDatetime, List select, String snapshot, String ifMatch,
- String ifNoneMatch, List tags, Context context) {
- final String accept = "application/vnd.microsoft.appconfig.kvset+json, application/problem+json";
- String selectConverted = (select == null)
- ? null
- : select.stream()
- .map(paramItemValue -> Objects.toString(paramItemValue, ""))
- .collect(Collectors.joining(","));
- List tagsConverted = (tags == null)
- ? new ArrayList<>()
- : tags.stream().map(item -> Objects.toString(item, "")).collect(Collectors.toList());
- return service
- .getKeyValuesNoCustomHeaders(this.getEndpoint(), key, label, this.getSyncToken(), this.getApiVersion(),
- after, acceptDatetime, selectConverted, snapshot, ifMatch, ifNoneMatch, tagsConverted, accept, context)
- .map(res -> new PagedResponseBase<>(res.getRequest(), res.getStatusCode(), res.getHeaders(),
- res.getValue().getItems(), res.getValue().getNextLink(), null));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeyValuesNoCustomHeadersAsync(String key, String label, String after,
- String acceptDatetime, List select, String snapshot, String ifMatch, String ifNoneMatch,
- List tags) {
- return new PagedFlux<>(
- () -> getKeyValuesNoCustomHeadersSinglePageAsync(key, label, after, acceptDatetime, select, snapshot,
- ifMatch, ifNoneMatch, tags),
- nextLink -> getKeyValuesNextSinglePageAsync(nextLink, acceptDatetime, ifMatch, ifNoneMatch));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param context The context to associate with this operation.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values as paginated response with {@link PagedFlux}.
- */
- @ServiceMethod(returns = ReturnType.COLLECTION)
- public PagedFlux getKeyValuesNoCustomHeadersAsync(String key, String label, String after,
- String acceptDatetime, List select, String snapshot, String ifMatch, String ifNoneMatch,
- List tags, Context context) {
- return new PagedFlux<>(
- () -> getKeyValuesNoCustomHeadersSinglePageAsync(key, label, after, acceptDatetime, select, snapshot,
- ifMatch, ifNoneMatch, tags, context),
- nextLink -> getKeyValuesNextSinglePageAsync(nextLink, acceptDatetime, ifMatch, ifNoneMatch, context));
- }
-
- /**
- * Gets a list of key-values.
- *
- * @param key A filter used to match keys. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param label A filter used to match labels. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @param after Instructs the server to return elements that appear after the element referred to by the specified
- * token.
- * @param acceptDatetime Requests the server to respond with the state of the resource at the specified time.
- * @param select Used to select what fields are present in the returned resource(s).
- * @param snapshot A filter used get key-values for a snapshot. The value should be the name of the snapshot. Not
- * valid when used with 'key' and 'label' filters.
- * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the value provided.
- * @param ifNoneMatch Used to perform an operation only if the targeted resource's etag does not match the value
- * provided.
- * @param tags A filter used to query by tags. Syntax reference: https://aka.ms/azconfig/docs/keyvaluefiltering.
- * @throws IllegalArgumentException thrown if parameters fail the validation.
- * @throws HttpResponseException thrown if the request is rejected by server.
- * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
- * @return a list of key-values along with {@link PagedResponse}.
- */
- @ServiceMethod(returns = ReturnType.SINGLE)
- public PagedResponse getKeyValuesSinglePage(String key, String label, String after, String acceptDatetime,
- List select, String snapshot, String ifMatch, String ifNoneMatch, List