diff --git a/sdk/appconfiguration/azure-data-appconfiguration/CHANGELOG.md b/sdk/appconfiguration/azure-data-appconfiguration/CHANGELOG.md
index 2280c4074741..b878b6284ab8 100644
--- a/sdk/appconfiguration/azure-data-appconfiguration/CHANGELOG.md
+++ b/sdk/appconfiguration/azure-data-appconfiguration/CHANGELOG.md
@@ -4,11 +4,204 @@
### Features Added
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+* `models.Snapshot` was added
+
+* `models.OperationDetails` was added
+
+* `AzureAppConfigurationClient` was added
+
+* `models.KeyValueFields` was added
+
+* `implementation.OperationLocationPollingStrategy` was added
+
+* `AzureAppConfigurationServiceVersion` was added
+
+* `models.Label` was added
+
+* `models.Key` was added
+
+* `models.CompositionType` was added
+
+* `models.OperationState` was added
+
+* `implementation.AzureAppConfigurationClientImpl$AzureAppConfigurationClientService` was added
+
+* `models.KeyValue` was added
+
+* `AzureAppConfigurationAsyncClient` was added
+
+* `implementation.SyncOperationLocationPollingStrategy` was added
+
+* `AzureAppConfigurationClientBuilder` was added
+
+* `models.LabelFields` was added
+
+* `implementation.AzureAppConfigurationClientImpl` was added
+
+* `models.KeyValueFilter` was added
+
+* `models.SnapshotStatus` was added
+
+#### `implementation.AzureAppConfigurationImpl$AzureAppConfigurationService` was modified
+
+* `deleteKeyValueNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValueNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkSnapshotsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNextNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNextNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkSnapshotNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNextNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeysNextNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getRevisionsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,com.azure.core.util.Context)` was added
+* `checkSnapshotNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeyValueNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeyValueNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `deleteLockNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `putLockNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkRevisionsNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getSnapshotNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `createSnapshotNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,models.ConfigurationSnapshot,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeysNextNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNextNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValueNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeysNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeyValuesNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeysNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,com.azure.core.util.Context)` was added
+* `updateSnapshotNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.SnapshotUpdateParameters,java.lang.String,com.azure.core.util.Context)` was added
+* `checkRevisionsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getRevisionsNextNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeysNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeyValuesNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeysNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkLabelsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `createSnapshotNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,models.ConfigurationSnapshot,java.lang.String,com.azure.core.util.Context)` was added
+* `checkLabelsNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `deleteKeyValueNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `deleteLockNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `putLockNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `putKeyValueNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.KeyValue,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,com.azure.core.util.Context)` was added
+* `getRevisionsNextNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `updateSnapshotNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.SnapshotUpdateParameters,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNextNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkSnapshotsNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNextNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `putKeyValueNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.KeyValue,java.lang.String,com.azure.core.util.Context)` was added
+* `getRevisionsNoCustomHeadersSync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,com.azure.core.util.Context)` was added
+
+#### `implementation.AzureAppConfigurationImpl` was modified
+
+* `getKeyValuesNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `checkLabelsNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeysNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `checkLabelsNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `deleteKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String)` was added
+* `getLabelsNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `getKeysNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String)` was added
+* `checkSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String)` was added
+* `getRevisionsNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `putKeyValueNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.KeyValue,com.azure.core.util.Context)` was added
+* `checkKeysNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeyValuesNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `deleteLockNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `createSnapshotNoCustomHeadersWithResponse(java.lang.String,models.ConfigurationSnapshot,com.azure.core.util.Context)` was added
+* `putLockNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String)` was added
+* `checkRevisionsNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `getSnapshotsNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `getRevisionsNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeaders(java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `putLockNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `putKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.KeyValue)` was added
+* `deleteKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `getSnapshotsNextNoCustomHeadersSinglePage(java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `getLabelsNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `checkRevisionsNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `getKeyValuesNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeadersAsync(java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `checkLabelsNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `checkKeysNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String)` was added
+* `getRevisionsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `getRevisionsNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `deleteKeyValueNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `putLockNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkSnapshotsNoCustomHeadersWithResponse(java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeadersAsync(java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `getLabelsNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `checkSnapshotsNoCustomHeadersWithResponseAsync(java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `updateSnapshotNoCustomHeadersWithResponse(java.lang.String,implementation.models.SnapshotUpdateParameters,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeysNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String)` was added
+* `createSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,models.ConfigurationSnapshot,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getRevisionsNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `checkKeyValueNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getRevisionsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `createSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,models.ConfigurationSnapshot)` was added
+* `getRevisionsNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String)` was added
+* `getSnapshotsNoCustomHeaders(java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `getLabelsNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `getRevisionsNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `getLabelsNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `checkKeysNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getRevisionsNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String)` was added
+* `checkKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getLabelsNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String)` was added
+* `getKeysNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String)` was added
+* `getRevisionsNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `getRevisionsNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `checkSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `updateSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,implementation.models.SnapshotUpdateParameters,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.util.List,java.util.List)` was added
+* `getSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `checkSnapshotsNoCustomHeadersWithResponseAsync(java.lang.String)` was added
+* `getKeysNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getLabelsNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeysNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeyValuesNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,java.lang.String)` was added
+* `getKeyValuesNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `getSnapshotsNextNoCustomHeadersSinglePageAsync(java.lang.String)` was added
+* `getSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
+* `getKeysNoCustomHeaders(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getSnapshotsNextNoCustomHeadersSinglePageAsync(java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValuesNoCustomHeadersAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getKeysNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String,java.lang.String)` was added
+* `getKeysNextNoCustomHeadersSinglePageAsync(java.lang.String,java.lang.String)` was added
+* `getRevisionsNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `deleteLockNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String)` was added
+* `getKeysNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String)` was added
+* `getKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `updateSnapshotNoCustomHeadersWithResponseAsync(java.lang.String,implementation.models.SnapshotUpdateParameters,java.lang.String,java.lang.String)` was added
+* `getKeysNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeysNoCustomHeadersSinglePage(java.lang.String,java.lang.String,java.lang.String)` was added
+* `getLabelsNextNoCustomHeadersSinglePage(java.lang.String,java.lang.String)` was added
+* `getSnapshotNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `deleteLockNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `checkSnapshotNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,com.azure.core.util.Context)` was added
+* `getKeyValueNoCustomHeadersWithResponse(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `checkKeyValuesNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List,com.azure.core.util.Context)` was added
+* `getSnapshotsNextNoCustomHeadersSinglePage(java.lang.String)` was added
+* `checkRevisionsNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.util.List,com.azure.core.util.Context)` was added
+* `putKeyValueNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,implementation.models.KeyValue,com.azure.core.util.Context)` was added
+* `checkKeyValuesNoCustomHeadersWithResponseAsync(java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.util.List,java.lang.String,java.lang.String,java.lang.String,java.util.List)` was added
## 1.7.3 (2024-12-04)
diff --git a/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/AzureAppConfigurationAsyncClient.java b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/AzureAppConfigurationAsyncClient.java
new file mode 100644
index 000000000000..2c9082aa61fd
--- /dev/null
+++ b/sdk/appconfiguration/azure-data-appconfiguration/src/main/java/com/azure/data/appconfiguration/AzureAppConfigurationAsyncClient.java
@@ -0,0 +1,2530 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+// Code generated by Microsoft (R) TypeSpec Code Generator.
+
+package com.azure.data.appconfiguration;
+
+import com.azure.core.annotation.Generated;
+import com.azure.core.annotation.ReturnType;
+import com.azure.core.annotation.ServiceClient;
+import com.azure.core.annotation.ServiceMethod;
+import com.azure.core.exception.ClientAuthenticationException;
+import com.azure.core.exception.HttpResponseException;
+import com.azure.core.exception.ResourceModifiedException;
+import com.azure.core.exception.ResourceNotFoundException;
+import com.azure.core.http.HttpHeaderName;
+import com.azure.core.http.MatchConditions;
+import com.azure.core.http.rest.PagedFlux;
+import com.azure.core.http.rest.PagedResponse;
+import com.azure.core.http.rest.PagedResponseBase;
+import com.azure.core.http.rest.RequestOptions;
+import com.azure.core.http.rest.Response;
+import com.azure.core.util.BinaryData;
+import com.azure.core.util.FluxUtil;
+import com.azure.core.util.polling.PollerFlux;
+import com.azure.data.appconfiguration.implementation.AzureAppConfigurationClientImpl;
+import com.azure.data.appconfiguration.models.Key;
+import com.azure.data.appconfiguration.models.KeyValue;
+import com.azure.data.appconfiguration.models.KeyValueFields;
+import com.azure.data.appconfiguration.models.Label;
+import com.azure.data.appconfiguration.models.LabelFields;
+import com.azure.data.appconfiguration.models.OperationDetails;
+import com.azure.data.appconfiguration.models.Snapshot;
+import com.azure.data.appconfiguration.models.SnapshotFields;
+import com.azure.data.appconfiguration.models.SnapshotStatus;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * Initializes a new instance of the asynchronous AzureAppConfigurationClient type.
+ */
+@ServiceClient(builder = AzureAppConfigurationClientBuilder.class, isAsync = true)
+public final class AzureAppConfigurationAsyncClient {
+ @Generated
+ private final AzureAppConfigurationClientImpl serviceClient;
+
+ /**
+ * Initializes an instance of AzureAppConfigurationAsyncClient class.
+ *
+ * @param serviceClient the service client implementation.
+ */
+ @Generated
+ AzureAppConfigurationAsyncClient(AzureAppConfigurationClientImpl serviceClient) {
+ this.serviceClient = serviceClient;
+ }
+
+ /**
+ * Gets a list of keys.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
name
String
No
A filter for the name of the returned keys.
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a list of keys as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getKeys(String accept, RequestOptions requestOptions) {
+ return this.serviceClient.getKeysAsync(accept, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
name
String
No
A filter for the name of the returned keys.
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkKeysWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.checkKeysWithResponseAsync(requestOptions);
+ }
+
+ /**
+ * Gets a list of key-values.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
key
String
No
A filter used to match keys. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering
+ *
label
String
No
A filter used to match labels. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
snapshot
String
No
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.
+ *
tags
List<String>
No
A filter used to query by tags. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering. Call {@link RequestOptions#addQueryParam} to add string to
+ * array.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a list of key-values as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getKeyValues(String accept, RequestOptions requestOptions) {
+ return this.serviceClient.getKeyValuesAsync(accept, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
key
String
No
A filter used to match keys. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering
+ *
label
String
No
A filter used to match labels. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
snapshot
String
No
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.
+ *
tags
List<String>
No
A filter used to query by tags. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering. Call {@link RequestOptions#addQueryParam} to add string to
+ * array.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkKeyValuesWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.checkKeyValuesWithResponseAsync(requestOptions);
+ }
+
+ /**
+ * Gets a single key-value.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
label
String
No
The label of the key-value to retrieve.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param key The key of the key-value.
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a single key-value along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getKeyValueWithResponse(String key, String accept,
+ RequestOptions requestOptions) {
+ return this.serviceClient.getKeyValueWithResponseAsync(key, accept, requestOptions);
+ }
+
+ /**
+ * Creates a key-value.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
label
String
No
The label of the key-value to create.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param key The key of the key-value to create.
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a key-value pair representing application settings along with {@link Response} on successful completion
+ * of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putKeyValueWithResponse(String key, String accept,
+ RequestOptions requestOptions) {
+ // Convenience API is not generated, as operation 'putKeyValue' is multiple content-type
+ return this.serviceClient.putKeyValueWithResponseAsync(key, accept, requestOptions);
+ }
+
+ /**
+ * Deletes a key-value.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
label
String
No
The label of the key-value to delete.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param key The key of the key-value to delete.
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a key-value pair representing application settings along with {@link Response} on successful completion
+ * of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> deleteKeyValueWithResponse(String key, String accept,
+ RequestOptions requestOptions) {
+ return this.serviceClient.deleteKeyValueWithResponseAsync(key, accept, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
label
String
No
The label of the key-value to retrieve.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param key The key of the key-value to retrieve.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkKeyValueWithResponse(String key, RequestOptions requestOptions) {
+ return this.serviceClient.checkKeyValueWithResponseAsync(key, requestOptions);
+ }
+
+ /**
+ * Gets a list of key-value snapshots.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
name
String
No
A filter for the name of the returned snapshots.
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
status
List<String>
No
Used to filter returned snapshots by their status
+ * property. In the form of "," separated string.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a list of key-value snapshots as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getSnapshots(String accept, RequestOptions requestOptions) {
+ return this.serviceClient.getSnapshotsAsync(accept, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkSnapshotsWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.checkSnapshotsWithResponseAsync(requestOptions);
+ }
+
+ /**
+ * Gets a single key-value snapshot.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param name The name of the snapshot.
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a single key-value snapshot along with {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getSnapshotWithResponse(String name, String accept,
+ RequestOptions requestOptions) {
+ return this.serviceClient.getSnapshotWithResponseAsync(name, accept, requestOptions);
+ }
+
+ /**
+ * Gets the state of a long running operation.
+ *
+ *
+ * @param snapshot Snapshot identifier for the long running operation.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the state of a long running operation along with {@link Response} on successful completion of
+ * {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> getOperationDetailsWithResponse(String snapshot, RequestOptions requestOptions) {
+ return this.serviceClient.getOperationDetailsWithResponseAsync(snapshot, requestOptions);
+ }
+
+ /**
+ * Creates a key-value snapshot.
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param contentType Content-Type header. Allowed values: "application/vnd.microsoft.appconfig.snapshot+json",
+ * "application/json".
+ * @param name The name of the key-value snapshot to create.
+ * @param accept The accept parameter.
+ * @param entity The key-value snapshot to create.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link PollerFlux} for polling of a snapshot is a named, immutable subset of an App Configuration
+ * store's key-values.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.LONG_RUNNING_OPERATION)
+ public PollerFlux beginCreateSnapshot(String contentType, String name, String accept,
+ BinaryData entity, RequestOptions requestOptions) {
+ // Convenience API is not generated, as operation 'createSnapshot' is multiple content-type
+ return this.serviceClient.beginCreateSnapshotAsync(contentType, name, accept, entity, requestOptions);
+ }
+
+ /**
+ * Updates the state of a key-value snapshot.
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param contentType Content-Type header. Allowed values: "application/merge-patch+json", "application/json".
+ * @param name The name of the key-value snapshot to update.
+ * @param accept The accept parameter.
+ * @param entity The parameters used to update the snapshot.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a snapshot is a named, immutable subset of an App Configuration store's key-values along with
+ * {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> updateSnapshotWithResponse(String contentType, String name, String accept,
+ BinaryData entity, RequestOptions requestOptions) {
+ // Convenience API is not generated, as operation 'updateSnapshot' is multiple content-type
+ return this.serviceClient.updateSnapshotWithResponseAsync(contentType, name, accept, entity, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param name The name of the key-value snapshot to check.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkSnapshotWithResponse(String name, RequestOptions requestOptions) {
+ return this.serviceClient.checkSnapshotWithResponseAsync(name, requestOptions);
+ }
+
+ /**
+ * Gets a list of labels.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
name
String
No
A filter for the name of the returned labels.
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a list of labels as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getLabels(String accept, RequestOptions requestOptions) {
+ return this.serviceClient.getLabelsAsync(accept, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
name
String
No
A filter for the name of the returned labels.
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkLabelsWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.checkLabelsWithResponseAsync(requestOptions);
+ }
+
+ /**
+ * Locks a key-value.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
label
String
No
The label, if any, of the key-value to lock.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param key The key of the key-value to lock.
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a key-value pair representing application settings along with {@link Response} on successful completion
+ * of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> putLockWithResponse(String key, String accept, RequestOptions requestOptions) {
+ return this.serviceClient.putLockWithResponseAsync(key, accept, requestOptions);
+ }
+
+ /**
+ * Unlocks a key-value.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
label
String
No
The label, if any, of the key-value to unlock.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
If-Match
String
No
Used to perform an operation only if the targeted resource's
+ * etag matches the
+ * value provided.
+ *
If-None-Match
String
No
Used to perform an operation only if the targeted
+ * resource's etag does not
+ * match the value provided.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param key The key of the key-value to unlock.
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a key-value pair representing application settings along with {@link Response} on successful completion
+ * of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> deleteLockWithResponse(String key, String accept, RequestOptions requestOptions) {
+ return this.serviceClient.deleteLockWithResponseAsync(key, accept, requestOptions);
+ }
+
+ /**
+ * Gets a list of key-value revisions.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
key
String
No
A filter used to match keys. Syntax reference:
+ * https://aka.ms/azconfig/docs/restapirevisions
+ *
label
String
No
A filter used to match labels. Syntax reference:
+ * https://aka.ms/azconfig/docs/restapirevisions
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
tags
List<String>
No
A filter used to query by tags. Syntax reference:
+ * https://aka.ms/azconfig/docs/restapirevisions. Call {@link RequestOptions#addQueryParam} to add string to
+ * array.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ *
+ * @param accept The accept parameter.
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return a list of key-value revisions as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getRevisions(String accept, RequestOptions requestOptions) {
+ return this.serviceClient.getRevisionsAsync(accept, requestOptions);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
Query Parameters
+ *
+ *
Query Parameters
+ *
Name
Type
Required
Description
+ *
key
String
No
A filter used to match keys. Syntax reference:
+ * https://aka.ms/azconfig/docs/restapirevisions
+ *
label
String
No
A filter used to match labels. Syntax reference:
+ * https://aka.ms/azconfig/docs/restapirevisions
+ *
After
String
No
Instructs the server to return elements that appear after the
+ * element referred
+ * to by the specified token.
+ *
$Select
List<String>
No
Used to select what fields are present in the
+ * returned resource(s). In the form of "," separated string.
+ *
tags
List<String>
No
A filter used to query by tags. Syntax reference:
+ * https://aka.ms/azconfig/docs/restapirevisions. Call {@link RequestOptions#addQueryParam} to add string to
+ * array.
+ *
+ * You can add these to a request with {@link RequestOptions#addQueryParam}
+ *
Header Parameters
+ *
+ *
Header Parameters
+ *
Name
Type
Required
Description
+ *
Sync-Token
String
No
Used to guarantee real-time consistency between
+ * requests.
+ *
Accept-Datetime
String
No
Requests the server to respond with the state of the
+ * resource at the specified
+ * time.
+ *
+ * You can add these to a request with {@link RequestOptions#addHeader}
+ *
+ * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @return the {@link Response} on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono> checkRevisionsWithResponse(RequestOptions requestOptions) {
+ return this.serviceClient.checkRevisionsWithResponseAsync(requestOptions);
+ }
+
+ /**
+ * Gets a list of keys.
+ *
+ * @param accept The accept parameter.
+ * @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 syncToken Used to guarantee real-time consistency between requests.
+ * @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 ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getKeys(String accept, String name, String after, String syncToken, String acceptDatetime) {
+ // Generated convenience method for getKeys
+ RequestOptions requestOptions = new RequestOptions();
+ if (name != null) {
+ requestOptions.addQueryParam("name", name, false);
+ }
+ if (after != null) {
+ requestOptions.addQueryParam("After", after, false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (acceptDatetime != null) {
+ requestOptions.setHeader(HttpHeaderName.ACCEPT_DATETIME, acceptDatetime);
+ }
+ PagedFlux pagedFluxResponse = getKeys(accept, requestOptions);
+ return PagedFlux.create(() -> (continuationTokenParam, pageSizeParam) -> {
+ Flux> flux = (continuationTokenParam == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationTokenParam).take(1);
+ return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
+ pagedResponse.getValue()
+ .stream()
+ .map(protocolMethodData -> protocolMethodData.toObject(Key.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(), null));
+ });
+ }
+
+ /**
+ * Gets a list of keys.
+ *
+ * @param accept The accept parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getKeys(String accept) {
+ // Generated convenience method for getKeys
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = getKeys(accept, requestOptions);
+ return PagedFlux.create(() -> (continuationTokenParam, pageSizeParam) -> {
+ Flux> flux = (continuationTokenParam == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationTokenParam).take(1);
+ return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
+ pagedResponse.getValue()
+ .stream()
+ .map(protocolMethodData -> protocolMethodData.toObject(Key.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(), null));
+ });
+ }
+
+ /**
+ * 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 syncToken Used to guarantee real-time consistency between requests.
+ * @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 ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkKeys(String name, String after, String syncToken, String acceptDatetime) {
+ // Generated convenience method for checkKeysWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ if (name != null) {
+ requestOptions.addQueryParam("name", name, false);
+ }
+ if (after != null) {
+ requestOptions.addQueryParam("After", after, false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (acceptDatetime != null) {
+ requestOptions.setHeader(HttpHeaderName.ACCEPT_DATETIME, acceptDatetime);
+ }
+ return checkKeysWithResponse(requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkKeys() {
+ // Generated convenience method for checkKeysWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return checkKeysWithResponse(requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Gets a list of key-values.
+ *
+ * @param accept The accept parameter.
+ * @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 syncToken Used to guarantee real-time consistency between requests.
+ * @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 tags A filter used to query by tags. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering.
+ * @param matchConditions Specifies HTTP options for conditional requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getKeyValues(String accept, String key, String label, String syncToken, String after,
+ String acceptDatetime, List select, String snapshot, List tags,
+ MatchConditions matchConditions) {
+ // Generated convenience method for getKeyValues
+ RequestOptions requestOptions = new RequestOptions();
+ String ifMatch = matchConditions == null ? null : matchConditions.getIfMatch();
+ String ifNoneMatch = matchConditions == null ? null : matchConditions.getIfNoneMatch();
+ if (key != null) {
+ requestOptions.addQueryParam("key", key, false);
+ }
+ if (label != null) {
+ requestOptions.addQueryParam("label", label, false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (after != null) {
+ requestOptions.addQueryParam("After", after, false);
+ }
+ if (acceptDatetime != null) {
+ requestOptions.setHeader(HttpHeaderName.ACCEPT_DATETIME, acceptDatetime);
+ }
+ if (select != null) {
+ requestOptions.addQueryParam("$Select",
+ select.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (snapshot != null) {
+ requestOptions.addQueryParam("snapshot", snapshot, false);
+ }
+ if (tags != null) {
+ for (String paramItemValue : tags) {
+ if (paramItemValue != null) {
+ requestOptions.addQueryParam("tags", paramItemValue, false);
+ }
+ }
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ if (ifNoneMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_NONE_MATCH, ifNoneMatch);
+ }
+ PagedFlux pagedFluxResponse = getKeyValues(accept, requestOptions);
+ return PagedFlux.create(() -> (continuationTokenParam, pageSizeParam) -> {
+ Flux> flux = (continuationTokenParam == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationTokenParam).take(1);
+ return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
+ pagedResponse.getValue()
+ .stream()
+ .map(protocolMethodData -> protocolMethodData.toObject(KeyValue.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(), null));
+ });
+ }
+
+ /**
+ * Gets a list of key-values.
+ *
+ * @param accept The accept parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getKeyValues(String accept) {
+ // Generated convenience method for getKeyValues
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = getKeyValues(accept, requestOptions);
+ return PagedFlux.create(() -> (continuationTokenParam, pageSizeParam) -> {
+ Flux> flux = (continuationTokenParam == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationTokenParam).take(1);
+ return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
+ pagedResponse.getValue()
+ .stream()
+ .map(protocolMethodData -> protocolMethodData.toObject(KeyValue.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(), null));
+ });
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @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 syncToken Used to guarantee real-time consistency between requests.
+ * @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 tags A filter used to query by tags. Syntax reference:
+ * https://aka.ms/azconfig/docs/keyvaluefiltering.
+ * @param matchConditions Specifies HTTP options for conditional requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkKeyValues(String key, String label, String syncToken, String after, String acceptDatetime,
+ List select, String snapshot, List tags, MatchConditions matchConditions) {
+ // Generated convenience method for checkKeyValuesWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ String ifMatch = matchConditions == null ? null : matchConditions.getIfMatch();
+ String ifNoneMatch = matchConditions == null ? null : matchConditions.getIfNoneMatch();
+ if (key != null) {
+ requestOptions.addQueryParam("key", key, false);
+ }
+ if (label != null) {
+ requestOptions.addQueryParam("label", label, false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (after != null) {
+ requestOptions.addQueryParam("After", after, false);
+ }
+ if (acceptDatetime != null) {
+ requestOptions.setHeader(HttpHeaderName.ACCEPT_DATETIME, acceptDatetime);
+ }
+ if (select != null) {
+ requestOptions.addQueryParam("$Select",
+ select.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (snapshot != null) {
+ requestOptions.addQueryParam("snapshot", snapshot, false);
+ }
+ if (tags != null) {
+ for (String paramItemValue : tags) {
+ if (paramItemValue != null) {
+ requestOptions.addQueryParam("tags", paramItemValue, false);
+ }
+ }
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ if (ifNoneMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_NONE_MATCH, ifNoneMatch);
+ }
+ return checkKeyValuesWithResponse(requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkKeyValues() {
+ // Generated convenience method for checkKeyValuesWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return checkKeyValuesWithResponse(requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Gets a single key-value.
+ *
+ * @param key The key of the key-value.
+ * @param accept The accept parameter.
+ * @param label The label of the key-value to retrieve.
+ * @param select Used to select what fields are present in the returned resource(s).
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @param acceptDatetime Requests the server to respond with the state of the resource at the specified
+ * time.
+ * @param matchConditions Specifies HTTP options for conditional requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a single key-value on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getKeyValue(String key, String accept, String label, List select,
+ String syncToken, String acceptDatetime, MatchConditions matchConditions) {
+ // Generated convenience method for getKeyValueWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ String ifMatch = matchConditions == null ? null : matchConditions.getIfMatch();
+ String ifNoneMatch = matchConditions == null ? null : matchConditions.getIfNoneMatch();
+ if (label != null) {
+ requestOptions.addQueryParam("label", label, false);
+ }
+ if (select != null) {
+ requestOptions.addQueryParam("$Select",
+ select.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (acceptDatetime != null) {
+ requestOptions.setHeader(HttpHeaderName.ACCEPT_DATETIME, acceptDatetime);
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ if (ifNoneMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_NONE_MATCH, ifNoneMatch);
+ }
+ return getKeyValueWithResponse(key, accept, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(KeyValue.class));
+ }
+
+ /**
+ * Gets a single key-value.
+ *
+ * @param key The key of the key-value.
+ * @param accept The accept parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a single key-value on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getKeyValue(String key, String accept) {
+ // Generated convenience method for getKeyValueWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getKeyValueWithResponse(key, accept, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(KeyValue.class));
+ }
+
+ /**
+ * Deletes a key-value.
+ *
+ * @param key The key of the key-value to delete.
+ * @param accept The accept parameter.
+ * @param label The label of the key-value to delete.
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @param ifMatch Used to perform an operation only if the targeted resource's etag matches the
+ * value provided.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a key-value pair representing application settings on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono deleteKeyValue(String key, String accept, String label, String syncToken, String ifMatch) {
+ // Generated convenience method for deleteKeyValueWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ if (label != null) {
+ requestOptions.addQueryParam("label", label, false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ return deleteKeyValueWithResponse(key, accept, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(KeyValue.class));
+ }
+
+ /**
+ * Deletes a key-value.
+ *
+ * @param key The key of the key-value to delete.
+ * @param accept The accept parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a key-value pair representing application settings on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono deleteKeyValue(String key, String accept) {
+ // Generated convenience method for deleteKeyValueWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return deleteKeyValueWithResponse(key, accept, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(KeyValue.class));
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @param key The key of the key-value to retrieve.
+ * @param label The label of the key-value to retrieve.
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @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 matchConditions Specifies HTTP options for conditional requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkKeyValue(String key, String label, String syncToken, String acceptDatetime,
+ List select, MatchConditions matchConditions) {
+ // Generated convenience method for checkKeyValueWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ String ifMatch = matchConditions == null ? null : matchConditions.getIfMatch();
+ String ifNoneMatch = matchConditions == null ? null : matchConditions.getIfNoneMatch();
+ if (label != null) {
+ requestOptions.addQueryParam("label", label, false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (acceptDatetime != null) {
+ requestOptions.setHeader(HttpHeaderName.ACCEPT_DATETIME, acceptDatetime);
+ }
+ if (select != null) {
+ requestOptions.addQueryParam("$Select",
+ select.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ if (ifNoneMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_NONE_MATCH, ifNoneMatch);
+ }
+ return checkKeyValueWithResponse(key, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @param key The key of the key-value to retrieve.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkKeyValue(String key) {
+ // Generated convenience method for checkKeyValueWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return checkKeyValueWithResponse(key, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Gets a list of key-value snapshots.
+ *
+ * @param accept The accept parameter.
+ * @param name A filter for the name of the returned snapshots.
+ * @param after Instructs the server to return elements that appear after the element referred
+ * to by the specified token.
+ * @param select Used to select what fields are present in the returned resource(s).
+ * @param status Used to filter returned snapshots by their status property.
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a list of key-value snapshots as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getSnapshots(String accept, String name, String after, List select,
+ List status, String syncToken) {
+ // Generated convenience method for getSnapshots
+ RequestOptions requestOptions = new RequestOptions();
+ if (name != null) {
+ requestOptions.addQueryParam("name", name, false);
+ }
+ if (after != null) {
+ requestOptions.addQueryParam("After", after, false);
+ }
+ if (select != null) {
+ requestOptions.addQueryParam("$Select",
+ select.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (status != null) {
+ requestOptions.addQueryParam("status",
+ status.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ PagedFlux pagedFluxResponse = getSnapshots(accept, requestOptions);
+ return PagedFlux.create(() -> (continuationTokenParam, pageSizeParam) -> {
+ Flux> flux = (continuationTokenParam == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationTokenParam).take(1);
+ return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
+ pagedResponse.getValue()
+ .stream()
+ .map(protocolMethodData -> protocolMethodData.toObject(Snapshot.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(), null));
+ });
+ }
+
+ /**
+ * Gets a list of key-value snapshots.
+ *
+ * @param accept The accept parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a list of key-value snapshots as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux getSnapshots(String accept) {
+ // Generated convenience method for getSnapshots
+ RequestOptions requestOptions = new RequestOptions();
+ PagedFlux pagedFluxResponse = getSnapshots(accept, requestOptions);
+ return PagedFlux.create(() -> (continuationTokenParam, pageSizeParam) -> {
+ Flux> flux = (continuationTokenParam == null)
+ ? pagedFluxResponse.byPage().take(1)
+ : pagedFluxResponse.byPage(continuationTokenParam).take(1);
+ return flux.map(pagedResponse -> new PagedResponseBase(pagedResponse.getRequest(),
+ pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
+ pagedResponse.getValue()
+ .stream()
+ .map(protocolMethodData -> protocolMethodData.toObject(Snapshot.class))
+ .collect(Collectors.toList()),
+ pagedResponse.getContinuationToken(), null));
+ });
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @param after Instructs the server to return elements that appear after the element referred
+ * to by the specified token.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkSnapshots(String syncToken, String after) {
+ // Generated convenience method for checkSnapshotsWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (after != null) {
+ requestOptions.addQueryParam("After", after, false);
+ }
+ return checkSnapshotsWithResponse(requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkSnapshots() {
+ // Generated convenience method for checkSnapshotsWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return checkSnapshotsWithResponse(requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Gets a single key-value snapshot.
+ *
+ * @param name The name of the snapshot.
+ * @param accept The accept parameter.
+ * @param select Used to select what fields are present in the returned resource(s).
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @param matchConditions Specifies HTTP options for conditional requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a single key-value snapshot on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getSnapshot(String name, String accept, List select, String syncToken,
+ MatchConditions matchConditions) {
+ // Generated convenience method for getSnapshotWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ String ifMatch = matchConditions == null ? null : matchConditions.getIfMatch();
+ String ifNoneMatch = matchConditions == null ? null : matchConditions.getIfNoneMatch();
+ if (select != null) {
+ requestOptions.addQueryParam("$Select",
+ select.stream()
+ .map(paramItemValue -> Objects.toString(paramItemValue, ""))
+ .collect(Collectors.joining(",")),
+ false);
+ }
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ if (ifNoneMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_NONE_MATCH, ifNoneMatch);
+ }
+ return getSnapshotWithResponse(name, accept, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(Snapshot.class));
+ }
+
+ /**
+ * Gets a single key-value snapshot.
+ *
+ * @param name The name of the snapshot.
+ * @param accept The accept parameter.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a single key-value snapshot on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getSnapshot(String name, String accept) {
+ // Generated convenience method for getSnapshotWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getSnapshotWithResponse(name, accept, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(Snapshot.class));
+ }
+
+ /**
+ * Gets the state of a long running operation.
+ *
+ * @param snapshot Snapshot identifier for the long running operation.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return the state of a long running operation on successful completion of {@link Mono}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono getOperationDetails(String snapshot) {
+ // Generated convenience method for getOperationDetailsWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return getOperationDetailsWithResponse(snapshot, requestOptions).flatMap(FluxUtil::toMono)
+ .map(protocolMethodData -> protocolMethodData.toObject(OperationDetails.class));
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @param name The name of the key-value snapshot to check.
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @param matchConditions Specifies HTTP options for conditional requests.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkSnapshot(String name, String syncToken, MatchConditions matchConditions) {
+ // Generated convenience method for checkSnapshotWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ String ifMatch = matchConditions == null ? null : matchConditions.getIfMatch();
+ String ifNoneMatch = matchConditions == null ? null : matchConditions.getIfNoneMatch();
+ if (syncToken != null) {
+ requestOptions.setHeader(HttpHeaderName.fromString("Sync-Token"), syncToken);
+ }
+ if (ifMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_MATCH, ifMatch);
+ }
+ if (ifNoneMatch != null) {
+ requestOptions.setHeader(HttpHeaderName.IF_NONE_MATCH, ifNoneMatch);
+ }
+ return checkSnapshotWithResponse(name, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Requests the headers and status of the given resource.
+ *
+ * @param name The name of the key-value snapshot to check.
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @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.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.SINGLE)
+ public Mono checkSnapshot(String name) {
+ // Generated convenience method for checkSnapshotWithResponse
+ RequestOptions requestOptions = new RequestOptions();
+ return checkSnapshotWithResponse(name, requestOptions).flatMap(FluxUtil::toMono);
+ }
+
+ /**
+ * Gets a list of labels.
+ *
+ * @param accept The accept parameter.
+ * @param name A filter for the name of the returned labels.
+ * @param syncToken Used to guarantee real-time consistency between requests.
+ * @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).
+ * @throws IllegalArgumentException thrown if parameters fail the validation.
+ * @throws HttpResponseException thrown if the request is rejected by server.
+ * @throws ClientAuthenticationException thrown if the request is rejected by server on status code 401.
+ * @throws ResourceNotFoundException thrown if the request is rejected by server on status code 404.
+ * @throws ResourceModifiedException thrown if the request is rejected by server on status code 409.
+ * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
+ * @return a list of labels as paginated response with {@link PagedFlux}.
+ */
+ @Generated
+ @ServiceMethod(returns = ReturnType.COLLECTION)
+ public PagedFlux