Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
403 changes: 399 additions & 4 deletions sdk/confluent/azure-resourcemanager-confluent/CHANGELOG.md

Large diffs are not rendered by default.

8 changes: 3 additions & 5 deletions sdk/confluent/azure-resourcemanager-confluent/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

Azure Resource Manager Confluent client library for Java.

This package contains Microsoft Azure SDK for Confluent Management SDK. Package tag package-2024-02. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
This package contains Microsoft Azure SDK for Confluent Management SDK. Package api-version 2025-08-18-preview. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).

## We'd love to hear your feedback

Expand Down Expand Up @@ -52,15 +52,15 @@ Azure subscription ID can be configured via `AZURE_SUBSCRIPTION_ID` environment
Assuming the use of the `DefaultAzureCredential` credential class, the client can be authenticated using the following code:

```java
AzureProfile profile = new AzureProfile(AzureEnvironment.AZURE);
AzureProfile profile = new AzureProfile(AzureCloud.AZURE_PUBLIC_CLOUD);
TokenCredential credential = new DefaultAzureCredentialBuilder()
.authorityHost(profile.getEnvironment().getActiveDirectoryEndpoint())
.build();
ConfluentManager manager = ConfluentManager
.authenticate(credential, profile);
```

The sample code assumes global Azure. Please change `AzureEnvironment.AZURE` variable if otherwise.
The sample code assumes global Azure. Please change the `AzureCloud.AZURE_PUBLIC_CLOUD` variable if otherwise.

See [Authentication][authenticate] for more options.

Expand Down Expand Up @@ -100,5 +100,3 @@ This project has adopted the [Microsoft Open Source Code of Conduct][coc]. For m
[cg]: https://github.com/Azure/azure-sdk-for-java/blob/main/CONTRIBUTING.md
[coc]: https://opensource.microsoft.com/codeofconduct/
[coc_faq]: https://opensource.microsoft.com/codeofconduct/faq/


1,174 changes: 947 additions & 227 deletions sdk/confluent/azure-resourcemanager-confluent/SAMPLE.md

Large diffs are not rendered by default.

6 changes: 3 additions & 3 deletions sdk/confluent/azure-resourcemanager-confluent/pom.xml
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
<!--
~ Copyright (c) Microsoft Corporation. All rights reserved.
~ Licensed under the MIT License.
~ Code generated by Microsoft (R) AutoRest Code Generator.
~ Code generated by Microsoft (R) TypeSpec Code Generator.
-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
Expand All @@ -18,7 +18,7 @@
<packaging>jar</packaging>

<name>Microsoft Azure SDK for Confluent Management</name>
<description>This package contains Microsoft Azure SDK for Confluent Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. Package tag package-2024-02.</description>
<description>This package contains Microsoft Azure SDK for Confluent Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. Package api-version 2025-08-18-preview.</description>
<url>https://github.com/Azure/azure-sdk-for-java</url>

<licenses>
Expand All @@ -45,7 +45,7 @@
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<jacoco.min.linecoverage>0</jacoco.min.linecoverage>
<jacoco.min.branchcoverage>0</jacoco.min.branchcoverage>
<spotless.skip>false</spotless.skip>
<revapi.skip>true</revapi.skip>
</properties>
<dependencies>
<dependency>
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
// Code generated by Microsoft (R) AutoRest Code Generator.
// Code generated by Microsoft (R) TypeSpec Code Generator.

package com.azure.resourcemanager.confluent;

Expand All @@ -22,40 +22,58 @@
import com.azure.core.http.policy.UserAgentPolicy;
import com.azure.core.management.profile.AzureProfile;
import com.azure.core.util.Configuration;
import com.azure.core.util.CoreUtils;
import com.azure.core.util.logging.ClientLogger;
import com.azure.resourcemanager.confluent.fluent.ConfluentManagementClient;
import com.azure.resourcemanager.confluent.implementation.AccessImpl;
import com.azure.resourcemanager.confluent.implementation.ClustersImpl;
import com.azure.resourcemanager.confluent.implementation.ConfluentManagementClientBuilder;
import com.azure.resourcemanager.confluent.implementation.ConnectorsImpl;
import com.azure.resourcemanager.confluent.implementation.EnvironmentsImpl;
import com.azure.resourcemanager.confluent.implementation.MarketplaceAgreementsImpl;
import com.azure.resourcemanager.confluent.implementation.OrganizationOperationsImpl;
import com.azure.resourcemanager.confluent.implementation.OrganizationsImpl;
import com.azure.resourcemanager.confluent.implementation.TopicsImpl;
import com.azure.resourcemanager.confluent.implementation.ValidationsImpl;
import com.azure.resourcemanager.confluent.models.Access;
import com.azure.resourcemanager.confluent.models.Clusters;
import com.azure.resourcemanager.confluent.models.Connectors;
import com.azure.resourcemanager.confluent.models.Environments;
import com.azure.resourcemanager.confluent.models.MarketplaceAgreements;
import com.azure.resourcemanager.confluent.models.OrganizationOperations;
import com.azure.resourcemanager.confluent.models.Organizations;
import com.azure.resourcemanager.confluent.models.Topics;
import com.azure.resourcemanager.confluent.models.Validations;
import java.time.Duration;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;

/**
* Entry point to ConfluentManager.
*/
public final class ConfluentManager {
private MarketplaceAgreements marketplaceAgreements;

private OrganizationOperations organizationOperations;

private Organizations organizations;

private Validations validations;

private Access access;

private Environments environments;

private Clusters clusters;

private Connectors connectors;

private Topics topics;

private MarketplaceAgreements marketplaceAgreements;

private Validations validations;

private final ConfluentManagementClient clientObject;

private ConfluentManager(HttpPipeline httpPipeline, AzureProfile profile, Duration defaultPollInterval) {
Expand Down Expand Up @@ -108,6 +126,9 @@ public static Configurable configure() {
*/
public static final class Configurable {
private static final ClientLogger LOGGER = new ClientLogger(Configurable.class);
private static final String SDK_VERSION = "version";
private static final Map<String, String> PROPERTIES
= CoreUtils.getProperties("azure-resourcemanager-confluent.properties");

private HttpClient httpClient;
private HttpLogOptions httpLogOptions;
Expand Down Expand Up @@ -215,12 +236,14 @@ public ConfluentManager authenticate(TokenCredential credential, AzureProfile pr
Objects.requireNonNull(credential, "'credential' cannot be null.");
Objects.requireNonNull(profile, "'profile' cannot be null.");

String clientVersion = PROPERTIES.getOrDefault(SDK_VERSION, "UnknownVersion");

StringBuilder userAgentBuilder = new StringBuilder();
userAgentBuilder.append("azsdk-java")
.append("-")
.append("com.azure.resourcemanager.confluent")
.append("/")
.append("1.2.0");
.append(clientVersion);
if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
userAgentBuilder.append(" (")
.append(Configuration.getGlobalConfiguration().get("java.version"))
Expand Down Expand Up @@ -266,18 +289,6 @@ public ConfluentManager authenticate(TokenCredential credential, AzureProfile pr
}
}

/**
* Gets the resource collection API of MarketplaceAgreements.
*
* @return Resource collection API of MarketplaceAgreements.
*/
public MarketplaceAgreements marketplaceAgreements() {
if (this.marketplaceAgreements == null) {
this.marketplaceAgreements = new MarketplaceAgreementsImpl(clientObject.getMarketplaceAgreements(), this);
}
return marketplaceAgreements;
}

/**
* Gets the resource collection API of OrganizationOperations.
*
Expand All @@ -303,18 +314,6 @@ public Organizations organizations() {
return organizations;
}

/**
* Gets the resource collection API of Validations.
*
* @return Resource collection API of Validations.
*/
public Validations validations() {
if (this.validations == null) {
this.validations = new ValidationsImpl(clientObject.getValidations(), this);
}
return validations;
}

/**
* Gets the resource collection API of Access.
*
Expand All @@ -327,6 +326,78 @@ public Access access() {
return access;
}

/**
* Gets the resource collection API of Environments. It manages SCEnvironmentRecord.
*
* @return Resource collection API of Environments.
*/
public Environments environments() {
if (this.environments == null) {
this.environments = new EnvironmentsImpl(clientObject.getEnvironments(), this);
}
return environments;
}

/**
* Gets the resource collection API of Clusters. It manages SCClusterRecord.
*
* @return Resource collection API of Clusters.
*/
public Clusters clusters() {
if (this.clusters == null) {
this.clusters = new ClustersImpl(clientObject.getClusters(), this);
}
return clusters;
}

/**
* Gets the resource collection API of Connectors. It manages ConnectorResource.
*
* @return Resource collection API of Connectors.
*/
public Connectors connectors() {
if (this.connectors == null) {
this.connectors = new ConnectorsImpl(clientObject.getConnectors(), this);
}
return connectors;
}

/**
* Gets the resource collection API of Topics. It manages TopicRecord.
*
* @return Resource collection API of Topics.
*/
public Topics topics() {
if (this.topics == null) {
this.topics = new TopicsImpl(clientObject.getTopics(), this);
}
return topics;
}

/**
* Gets the resource collection API of MarketplaceAgreements.
*
* @return Resource collection API of MarketplaceAgreements.
*/
public MarketplaceAgreements marketplaceAgreements() {
if (this.marketplaceAgreements == null) {
this.marketplaceAgreements = new MarketplaceAgreementsImpl(clientObject.getMarketplaceAgreements(), this);
}
return marketplaceAgreements;
}

/**
* Gets the resource collection API of Validations.
*
* @return Resource collection API of Validations.
*/
public Validations validations() {
if (this.validations == null) {
this.validations = new ValidationsImpl(clientObject.getValidations(), this);
}
return validations;
}

/**
* Gets wrapped service client ConfluentManagementClient providing direct access to the underlying auto-generated
* API implementation, based on Azure REST API.
Expand Down
Loading