Skip to content
Permalink
Browse files
feat: add AutoscalingPolicyServiceClient (#66)
  • Loading branch information
yoshi-automation committed Feb 3, 2020
1 parent 5321a0f commit b612d8e2ce9d133449a9eef8e760fe9f138e5a57
Showing with 2,710 additions and 1,528 deletions.
  1. +6 −1 .kokoro/linkage-monitor.sh
  2. +701 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/AutoscalingPolicyServiceClient.java
  3. +242 −0 ...e-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/AutoscalingPolicyServiceSettings.java
  4. +16 −0 google-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/package-info.java
  5. +75 −0 ...-cloud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/AutoscalingPolicyServiceStub.java
  6. +482 −0 ...ataproc/src/main/java/com/google/cloud/dataproc/v1/stub/AutoscalingPolicyServiceStubSettings.java
  7. +115 −0 .../src/main/java/com/google/cloud/dataproc/v1/stub/GrpcAutoscalingPolicyServiceCallableFactory.java
  8. +329 −0 ...ud-dataproc/src/main/java/com/google/cloud/dataproc/v1/stub/GrpcAutoscalingPolicyServiceStub.java
  9. +311 −0 ...cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/AutoscalingPolicyServiceClientTest.java
  10. +6 −1 google-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/ClusterControllerClientTest.java
  11. +6 −1 google-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/JobControllerClientTest.java
  12. +57 −0 google-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/MockAutoscalingPolicyService.java
  13. +135 −0 ...e-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/MockAutoscalingPolicyServiceImpl.java
  14. +6 −1 ...-cloud-dataproc/src/test/java/com/google/cloud/dataproc/v1/WorkflowTemplateServiceClientTest.java
  15. +215 −0 proto-google-cloud-dataproc-v1/src/main/java/com/google/cloud/dataproc/v1/AutoscalingPolicyName.java
  16. +2 −1 renovate.json
  17. +6 −1,523 synth.metadata
@@ -23,7 +23,12 @@ cd github/java-dataproc/
java -version
echo ${JOB_TYPE}

mvn install -DskipTests=true -Dmaven.javadoc.skip=true -Dgcloud.download.skip=true -B -V
mvn install -B -V \
-DskipTests=true \
-Dclirr.skip=true \
-Denforcer.skip=true \
-Dmaven.javadoc.skip=true \
-Dgcloud.download.skip=true

# Kokoro job cloud-opensource-java/ubuntu/linkage-monitor-gcs creates this JAR
JAR=linkage-monitor-latest-all-deps.jar

Large diffs are not rendered by default.

@@ -0,0 +1,242 @@
/*
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.google.cloud.dataproc.v1;

import static com.google.cloud.dataproc.v1.AutoscalingPolicyServiceClient.ListAutoscalingPoliciesPagedResponse;

import com.google.api.core.ApiFunction;
import com.google.api.core.BetaApi;
import com.google.api.gax.core.GoogleCredentialsProvider;
import com.google.api.gax.core.InstantiatingExecutorProvider;
import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider;
import com.google.api.gax.rpc.ApiClientHeaderProvider;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.ClientSettings;
import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.dataproc.v1.stub.AutoscalingPolicyServiceStubSettings;
import com.google.protobuf.Empty;
import java.io.IOException;
import java.util.List;
import javax.annotation.Generated;

// AUTO-GENERATED DOCUMENTATION AND CLASS
/**
* Settings class to configure an instance of {@link AutoscalingPolicyServiceClient}.
*
* <p>The default instance has everything set to sensible defaults:
*
* <ul>
* <li>The default service address (dataproc.googleapis.com) and default port (443) are used.
* <li>Credentials are acquired automatically through Application Default Credentials.
* <li>Retries are configured for idempotent methods but not for non-idempotent methods.
* </ul>
*
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
* build() is called, the tree of builders is called to create the complete settings object.
*
* <p>For example, to set the total timeout of createAutoscalingPolicy to 30 seconds:
*
* <pre>
* <code>
* AutoscalingPolicyServiceSettings.Builder autoscalingPolicyServiceSettingsBuilder =
* AutoscalingPolicyServiceSettings.newBuilder();
* autoscalingPolicyServiceSettingsBuilder.createAutoscalingPolicySettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30));
* AutoscalingPolicyServiceSettings autoscalingPolicyServiceSettings = autoscalingPolicyServiceSettingsBuilder.build();
* </code>
* </pre>
*/
@Generated("by gapic-generator")
@BetaApi
public class AutoscalingPolicyServiceSettings
extends ClientSettings<AutoscalingPolicyServiceSettings> {
/** Returns the object with the settings used for calls to createAutoscalingPolicy. */
public UnaryCallSettings<CreateAutoscalingPolicyRequest, AutoscalingPolicy>
createAutoscalingPolicySettings() {
return ((AutoscalingPolicyServiceStubSettings) getStubSettings())
.createAutoscalingPolicySettings();
}

/** Returns the object with the settings used for calls to updateAutoscalingPolicy. */
public UnaryCallSettings<UpdateAutoscalingPolicyRequest, AutoscalingPolicy>
updateAutoscalingPolicySettings() {
return ((AutoscalingPolicyServiceStubSettings) getStubSettings())
.updateAutoscalingPolicySettings();
}

/** Returns the object with the settings used for calls to getAutoscalingPolicy. */
public UnaryCallSettings<GetAutoscalingPolicyRequest, AutoscalingPolicy>
getAutoscalingPolicySettings() {
return ((AutoscalingPolicyServiceStubSettings) getStubSettings())
.getAutoscalingPolicySettings();
}

/** Returns the object with the settings used for calls to listAutoscalingPolicies. */
public PagedCallSettings<
ListAutoscalingPoliciesRequest,
ListAutoscalingPoliciesResponse,
ListAutoscalingPoliciesPagedResponse>
listAutoscalingPoliciesSettings() {
return ((AutoscalingPolicyServiceStubSettings) getStubSettings())
.listAutoscalingPoliciesSettings();
}

/** Returns the object with the settings used for calls to deleteAutoscalingPolicy. */
public UnaryCallSettings<DeleteAutoscalingPolicyRequest, Empty>
deleteAutoscalingPolicySettings() {
return ((AutoscalingPolicyServiceStubSettings) getStubSettings())
.deleteAutoscalingPolicySettings();
}

public static final AutoscalingPolicyServiceSettings create(
AutoscalingPolicyServiceStubSettings stub) throws IOException {
return new AutoscalingPolicyServiceSettings.Builder(stub.toBuilder()).build();
}

/** Returns a builder for the default ExecutorProvider for this service. */
public static InstantiatingExecutorProvider.Builder defaultExecutorProviderBuilder() {
return AutoscalingPolicyServiceStubSettings.defaultExecutorProviderBuilder();
}

/** Returns the default service endpoint. */
public static String getDefaultEndpoint() {
return AutoscalingPolicyServiceStubSettings.getDefaultEndpoint();
}

/** Returns the default service scopes. */
public static List<String> getDefaultServiceScopes() {
return AutoscalingPolicyServiceStubSettings.getDefaultServiceScopes();
}

/** Returns a builder for the default credentials for this service. */
public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() {
return AutoscalingPolicyServiceStubSettings.defaultCredentialsProviderBuilder();
}

/** Returns a builder for the default ChannelProvider for this service. */
public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
return AutoscalingPolicyServiceStubSettings.defaultGrpcTransportProviderBuilder();
}

public static TransportChannelProvider defaultTransportChannelProvider() {
return AutoscalingPolicyServiceStubSettings.defaultTransportChannelProvider();
}

@BetaApi("The surface for customizing headers is not stable yet and may change in the future.")
public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() {
return AutoscalingPolicyServiceStubSettings.defaultApiClientHeaderProviderBuilder();
}

/** Returns a new builder for this class. */
public static Builder newBuilder() {
return Builder.createDefault();
}

/** Returns a new builder for this class. */
public static Builder newBuilder(ClientContext clientContext) {
return new Builder(clientContext);
}

/** Returns a builder containing all the values of this settings class. */
public Builder toBuilder() {
return new Builder(this);
}

protected AutoscalingPolicyServiceSettings(Builder settingsBuilder) throws IOException {
super(settingsBuilder);
}

/** Builder for AutoscalingPolicyServiceSettings. */
public static class Builder
extends ClientSettings.Builder<AutoscalingPolicyServiceSettings, Builder> {
protected Builder() throws IOException {
this((ClientContext) null);
}

protected Builder(ClientContext clientContext) {
super(AutoscalingPolicyServiceStubSettings.newBuilder(clientContext));
}

private static Builder createDefault() {
return new Builder(AutoscalingPolicyServiceStubSettings.newBuilder());
}

protected Builder(AutoscalingPolicyServiceSettings settings) {
super(settings.getStubSettings().toBuilder());
}

protected Builder(AutoscalingPolicyServiceStubSettings.Builder stubSettings) {
super(stubSettings);
}

public AutoscalingPolicyServiceStubSettings.Builder getStubSettingsBuilder() {
return ((AutoscalingPolicyServiceStubSettings.Builder) getStubSettings());
}

// NEXT_MAJOR_VER: remove 'throws Exception'
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* <p>Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
ApiFunction<UnaryCallSettings.Builder<?, ?>, Void> settingsUpdater) throws Exception {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
}

/** Returns the builder for the settings used for calls to createAutoscalingPolicy. */
public UnaryCallSettings.Builder<CreateAutoscalingPolicyRequest, AutoscalingPolicy>
createAutoscalingPolicySettings() {
return getStubSettingsBuilder().createAutoscalingPolicySettings();
}

/** Returns the builder for the settings used for calls to updateAutoscalingPolicy. */
public UnaryCallSettings.Builder<UpdateAutoscalingPolicyRequest, AutoscalingPolicy>
updateAutoscalingPolicySettings() {
return getStubSettingsBuilder().updateAutoscalingPolicySettings();
}

/** Returns the builder for the settings used for calls to getAutoscalingPolicy. */
public UnaryCallSettings.Builder<GetAutoscalingPolicyRequest, AutoscalingPolicy>
getAutoscalingPolicySettings() {
return getStubSettingsBuilder().getAutoscalingPolicySettings();
}

/** Returns the builder for the settings used for calls to listAutoscalingPolicies. */
public PagedCallSettings.Builder<
ListAutoscalingPoliciesRequest,
ListAutoscalingPoliciesResponse,
ListAutoscalingPoliciesPagedResponse>
listAutoscalingPoliciesSettings() {
return getStubSettingsBuilder().listAutoscalingPoliciesSettings();
}

/** Returns the builder for the settings used for calls to deleteAutoscalingPolicy. */
public UnaryCallSettings.Builder<DeleteAutoscalingPolicyRequest, Empty>
deleteAutoscalingPolicySettings() {
return getStubSettingsBuilder().deleteAutoscalingPolicySettings();
}

@Override
public AutoscalingPolicyServiceSettings build() throws IOException {
return new AutoscalingPolicyServiceSettings(this);
}
}
}
@@ -69,6 +69,22 @@
* }
* </code>
* </pre>
*
* ============================== AutoscalingPolicyServiceClient ==============================
*
* <p>Service Description: The API interface for managing autoscaling policies in the Dataproc API.
*
* <p>Sample for AutoscalingPolicyServiceClient:
*
* <pre>
* <code>
* try (AutoscalingPolicyServiceClient autoscalingPolicyServiceClient = AutoscalingPolicyServiceClient.create()) {
* String formattedParent = RegionName.format("[PROJECT]", "[REGION]");
* AutoscalingPolicy policy = AutoscalingPolicy.newBuilder().build();
* AutoscalingPolicy response = autoscalingPolicyServiceClient.createAutoscalingPolicy(formattedParent, policy);
* }
* </code>
* </pre>
*/
@Generated("by gapic-generator")
package com.google.cloud.dataproc.v1;
@@ -0,0 +1,75 @@
/*
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.google.cloud.dataproc.v1.stub;

import static com.google.cloud.dataproc.v1.AutoscalingPolicyServiceClient.ListAutoscalingPoliciesPagedResponse;

import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.dataproc.v1.AutoscalingPolicy;
import com.google.cloud.dataproc.v1.CreateAutoscalingPolicyRequest;
import com.google.cloud.dataproc.v1.DeleteAutoscalingPolicyRequest;
import com.google.cloud.dataproc.v1.GetAutoscalingPolicyRequest;
import com.google.cloud.dataproc.v1.ListAutoscalingPoliciesRequest;
import com.google.cloud.dataproc.v1.ListAutoscalingPoliciesResponse;
import com.google.cloud.dataproc.v1.UpdateAutoscalingPolicyRequest;
import com.google.protobuf.Empty;
import javax.annotation.Generated;

// AUTO-GENERATED DOCUMENTATION AND CLASS
/**
* Base stub class for Google Cloud Dataproc API.
*
* <p>This class is for advanced usage and reflects the underlying API directly.
*/
@Generated("by gapic-generator")
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public abstract class AutoscalingPolicyServiceStub implements BackgroundResource {

public UnaryCallable<CreateAutoscalingPolicyRequest, AutoscalingPolicy>
createAutoscalingPolicyCallable() {
throw new UnsupportedOperationException("Not implemented: createAutoscalingPolicyCallable()");
}

public UnaryCallable<UpdateAutoscalingPolicyRequest, AutoscalingPolicy>
updateAutoscalingPolicyCallable() {
throw new UnsupportedOperationException("Not implemented: updateAutoscalingPolicyCallable()");
}

public UnaryCallable<GetAutoscalingPolicyRequest, AutoscalingPolicy>
getAutoscalingPolicyCallable() {
throw new UnsupportedOperationException("Not implemented: getAutoscalingPolicyCallable()");
}

public UnaryCallable<ListAutoscalingPoliciesRequest, ListAutoscalingPoliciesPagedResponse>
listAutoscalingPoliciesPagedCallable() {
throw new UnsupportedOperationException(
"Not implemented: listAutoscalingPoliciesPagedCallable()");
}

public UnaryCallable<ListAutoscalingPoliciesRequest, ListAutoscalingPoliciesResponse>
listAutoscalingPoliciesCallable() {
throw new UnsupportedOperationException("Not implemented: listAutoscalingPoliciesCallable()");
}

public UnaryCallable<DeleteAutoscalingPolicyRequest, Empty> deleteAutoscalingPolicyCallable() {
throw new UnsupportedOperationException("Not implemented: deleteAutoscalingPolicyCallable()");
}

@Override
public abstract void close();
}

0 comments on commit b612d8e

Please sign in to comment.