{
private ClusterManagerBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ClusterManagerBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ClusterManagerBlockingStub(channel, callOptions);
}
/**
*
*
*
* Lists all clusters owned by a project in either the specified zone or all
* zones.
*
*/
public com.google.container.v1beta1.ListClustersResponse listClusters(
com.google.container.v1beta1.ListClustersRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListClustersMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the details for a specific cluster.
*
*/
public com.google.container.v1beta1.Cluster getCluster(
com.google.container.v1beta1.GetClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a cluster, consisting of the specified number and type of Google
* Compute Engine instances.
* By default, the cluster is created in the project's
* [default
* network](https://cloud.google.com/compute/docs/networks-and-firewalls#networks).
* One firewall is added for the cluster. After cluster creation,
* the Kubelet creates routes for each node to allow the containers
* on that node to communicate with all other instances in the
* cluster.
* Finally, an entry is added to the project's global metadata indicating
* which CIDR range the cluster is using.
*
*/
public com.google.container.v1beta1.Operation createCluster(
com.google.container.v1beta1.CreateClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the settings for a specific cluster.
*
*/
public com.google.container.v1beta1.Operation updateCluster(
com.google.container.v1beta1.UpdateClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the version and/or image type of a specific node pool.
*
*/
public com.google.container.v1beta1.Operation updateNodePool(
com.google.container.v1beta1.UpdateNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the autoscaling settings of a specific node pool.
*
*/
public com.google.container.v1beta1.Operation setNodePoolAutoscaling(
com.google.container.v1beta1.SetNodePoolAutoscalingRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetNodePoolAutoscalingMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the logging service for a specific cluster.
*
*/
public com.google.container.v1beta1.Operation setLoggingService(
com.google.container.v1beta1.SetLoggingServiceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetLoggingServiceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the monitoring service for a specific cluster.
*
*/
public com.google.container.v1beta1.Operation setMonitoringService(
com.google.container.v1beta1.SetMonitoringServiceRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetMonitoringServiceMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the addons for a specific cluster.
*
*/
public com.google.container.v1beta1.Operation setAddonsConfig(
com.google.container.v1beta1.SetAddonsConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetAddonsConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the locations for a specific cluster.
* Deprecated. Use
* [projects.locations.clusters.update](https://cloud.google.com/kubernetes-engine/docs/reference/rest/v1beta1/projects.locations.clusters/update)
* instead.
*
*/
@java.lang.Deprecated
public com.google.container.v1beta1.Operation setLocations(
com.google.container.v1beta1.SetLocationsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetLocationsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates the master for a specific cluster.
*
*/
public com.google.container.v1beta1.Operation updateMaster(
com.google.container.v1beta1.UpdateMasterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateMasterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets master auth materials. Currently supports changing the admin password
* or a specific cluster, either via password generation or explicitly setting
* the password.
*
*/
public com.google.container.v1beta1.Operation setMasterAuth(
com.google.container.v1beta1.SetMasterAuthRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetMasterAuthMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes the cluster, including the Kubernetes endpoint and all worker
* nodes.
* Firewalls and routes that were configured during cluster creation
* are also deleted.
* Other Google Compute Engine resources that might be in use by the cluster,
* such as load balancer resources, are not deleted if they weren't present
* when the cluster was initially created.
*
*/
public com.google.container.v1beta1.Operation deleteCluster(
com.google.container.v1beta1.DeleteClusterRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteClusterMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all operations in a project in the specified zone or all zones.
*
*/
public com.google.container.v1beta1.ListOperationsResponse listOperations(
com.google.container.v1beta1.ListOperationsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListOperationsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the specified operation.
*
*/
public com.google.container.v1beta1.Operation getOperation(
com.google.container.v1beta1.GetOperationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetOperationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Cancels the specified operation.
*
*/
public com.google.protobuf.Empty cancelOperation(
com.google.container.v1beta1.CancelOperationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCancelOperationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns configuration info about the Google Kubernetes Engine service.
*
*/
public com.google.container.v1beta1.ServerConfig getServerConfig(
com.google.container.v1beta1.GetServerConfigRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetServerConfigMethod(), getCallOptions(), request);
}
/**
*
*
*
* Gets the public component of the cluster signing keys in
* JSON Web Key format.
* This API is not yet intended for general use, and is not available for all
* clusters.
*
*/
public com.google.container.v1beta1.GetJSONWebKeysResponse getJSONWebKeys(
com.google.container.v1beta1.GetJSONWebKeysRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetJSONWebKeysMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists the node pools for a cluster.
*
*/
public com.google.container.v1beta1.ListNodePoolsResponse listNodePools(
com.google.container.v1beta1.ListNodePoolsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListNodePoolsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves the requested node pool.
*
*/
public com.google.container.v1beta1.NodePool getNodePool(
com.google.container.v1beta1.GetNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a node pool for a cluster.
*
*/
public com.google.container.v1beta1.Operation createNodePool(
com.google.container.v1beta1.CreateNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a node pool from a cluster.
*
*/
public com.google.container.v1beta1.Operation deleteNodePool(
com.google.container.v1beta1.DeleteNodePoolRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteNodePoolMethod(), getCallOptions(), request);
}
/**
*
*
*
* CompleteNodePoolUpgrade will signal an on-going node pool upgrade to
* complete.
*
*/
public com.google.protobuf.Empty completeNodePoolUpgrade(
com.google.container.v1beta1.CompleteNodePoolUpgradeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCompleteNodePoolUpgradeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Rolls back a previously Aborted or Failed NodePool upgrade.
* This makes no changes if the last upgrade successfully completed.
*
*/
public com.google.container.v1beta1.Operation rollbackNodePoolUpgrade(
com.google.container.v1beta1.RollbackNodePoolUpgradeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getRollbackNodePoolUpgradeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the NodeManagement options for a node pool.
*
*/
public com.google.container.v1beta1.Operation setNodePoolManagement(
com.google.container.v1beta1.SetNodePoolManagementRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetNodePoolManagementMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets labels on a cluster.
*
*/
public com.google.container.v1beta1.Operation setLabels(
com.google.container.v1beta1.SetLabelsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetLabelsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Enables or disables the ABAC authorization mechanism on a cluster.
*
*/
public com.google.container.v1beta1.Operation setLegacyAbac(
com.google.container.v1beta1.SetLegacyAbacRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetLegacyAbacMethod(), getCallOptions(), request);
}
/**
*
*
*
* Starts master IP rotation.
*
*/
public com.google.container.v1beta1.Operation startIPRotation(
com.google.container.v1beta1.StartIPRotationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getStartIPRotationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Completes master IP rotation.
*
*/
public com.google.container.v1beta1.Operation completeIPRotation(
com.google.container.v1beta1.CompleteIPRotationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCompleteIPRotationMethod(), getCallOptions(), request);
}
/**
*
*
*
* SetNodePoolSizeRequest sets the size of a node pool. The new size will be
* used for all replicas, including future replicas created by modifying
* [NodePool.locations][google.container.v1beta1.NodePool.locations].
*
*/
public com.google.container.v1beta1.Operation setNodePoolSize(
com.google.container.v1beta1.SetNodePoolSizeRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetNodePoolSizeMethod(), getCallOptions(), request);
}
/**
*
*
*
* Enables or disables Network Policy for a cluster.
*
*/
public com.google.container.v1beta1.Operation setNetworkPolicy(
com.google.container.v1beta1.SetNetworkPolicyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetNetworkPolicyMethod(), getCallOptions(), request);
}
/**
*
*
*
* Sets the maintenance policy for a cluster.
*
*/
public com.google.container.v1beta1.Operation setMaintenancePolicy(
com.google.container.v1beta1.SetMaintenancePolicyRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSetMaintenancePolicyMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists subnetworks that can be used for creating clusters in a project.
*
*/
public com.google.container.v1beta1.ListUsableSubnetworksResponse listUsableSubnetworks(
com.google.container.v1beta1.ListUsableSubnetworksRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListUsableSubnetworksMethod(), getCallOptions(), request);
}
/**
*
*
*
* Fetches locations that offer Google Kubernetes Engine.
*
*/
public com.google.container.v1beta1.ListLocationsResponse listLocations(
com.google.container.v1beta1.ListLocationsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListLocationsMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service ClusterManager.
*
*
* Google Kubernetes Engine Cluster Manager v1beta1
*
*/
public static final class ClusterManagerFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ClusterManagerFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ClusterManagerFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ClusterManagerFutureStub(channel, callOptions);
}
/**
*
*
*
* Lists all clusters owned by a project in either the specified zone or all
* zones.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.ListClustersResponse>
listClusters(com.google.container.v1beta1.ListClustersRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListClustersMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the details for a specific cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getCluster(com.google.container.v1beta1.GetClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a cluster, consisting of the specified number and type of Google
* Compute Engine instances.
* By default, the cluster is created in the project's
* [default
* network](https://cloud.google.com/compute/docs/networks-and-firewalls#networks).
* One firewall is added for the cluster. After cluster creation,
* the Kubelet creates routes for each node to allow the containers
* on that node to communicate with all other instances in the
* cluster.
* Finally, an entry is added to the project's global metadata indicating
* which CIDR range the cluster is using.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
createCluster(com.google.container.v1beta1.CreateClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the settings for a specific cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
updateCluster(com.google.container.v1beta1.UpdateClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the version and/or image type of a specific node pool.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
updateNodePool(com.google.container.v1beta1.UpdateNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the autoscaling settings of a specific node pool.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setNodePoolAutoscaling(com.google.container.v1beta1.SetNodePoolAutoscalingRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetNodePoolAutoscalingMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the logging service for a specific cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setLoggingService(com.google.container.v1beta1.SetLoggingServiceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetLoggingServiceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the monitoring service for a specific cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setMonitoringService(com.google.container.v1beta1.SetMonitoringServiceRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetMonitoringServiceMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the addons for a specific cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setAddonsConfig(com.google.container.v1beta1.SetAddonsConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetAddonsConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the locations for a specific cluster.
* Deprecated. Use
* [projects.locations.clusters.update](https://cloud.google.com/kubernetes-engine/docs/reference/rest/v1beta1/projects.locations.clusters/update)
* instead.
*
*/
@java.lang.Deprecated
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setLocations(com.google.container.v1beta1.SetLocationsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetLocationsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates the master for a specific cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
updateMaster(com.google.container.v1beta1.UpdateMasterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateMasterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets master auth materials. Currently supports changing the admin password
* or a specific cluster, either via password generation or explicitly setting
* the password.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setMasterAuth(com.google.container.v1beta1.SetMasterAuthRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetMasterAuthMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes the cluster, including the Kubernetes endpoint and all worker
* nodes.
* Firewalls and routes that were configured during cluster creation
* are also deleted.
* Other Google Compute Engine resources that might be in use by the cluster,
* such as load balancer resources, are not deleted if they weren't present
* when the cluster was initially created.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
deleteCluster(com.google.container.v1beta1.DeleteClusterRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteClusterMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all operations in a project in the specified zone or all zones.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.ListOperationsResponse>
listOperations(com.google.container.v1beta1.ListOperationsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListOperationsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the specified operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
getOperation(com.google.container.v1beta1.GetOperationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetOperationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Cancels the specified operation.
*
*/
public com.google.common.util.concurrent.ListenableFuture
cancelOperation(com.google.container.v1beta1.CancelOperationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCancelOperationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns configuration info about the Google Kubernetes Engine service.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.ServerConfig>
getServerConfig(com.google.container.v1beta1.GetServerConfigRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetServerConfigMethod(), getCallOptions()), request);
}
/**
*
*
*
* Gets the public component of the cluster signing keys in
* JSON Web Key format.
* This API is not yet intended for general use, and is not available for all
* clusters.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.GetJSONWebKeysResponse>
getJSONWebKeys(com.google.container.v1beta1.GetJSONWebKeysRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetJSONWebKeysMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists the node pools for a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.ListNodePoolsResponse>
listNodePools(com.google.container.v1beta1.ListNodePoolsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListNodePoolsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves the requested node pool.
*
*/
public com.google.common.util.concurrent.ListenableFuture
getNodePool(com.google.container.v1beta1.GetNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a node pool for a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
createNodePool(com.google.container.v1beta1.CreateNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a node pool from a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
deleteNodePool(com.google.container.v1beta1.DeleteNodePoolRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteNodePoolMethod(), getCallOptions()), request);
}
/**
*
*
*
* CompleteNodePoolUpgrade will signal an on-going node pool upgrade to
* complete.
*
*/
public com.google.common.util.concurrent.ListenableFuture
completeNodePoolUpgrade(
com.google.container.v1beta1.CompleteNodePoolUpgradeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCompleteNodePoolUpgradeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Rolls back a previously Aborted or Failed NodePool upgrade.
* This makes no changes if the last upgrade successfully completed.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
rollbackNodePoolUpgrade(
com.google.container.v1beta1.RollbackNodePoolUpgradeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getRollbackNodePoolUpgradeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the NodeManagement options for a node pool.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setNodePoolManagement(com.google.container.v1beta1.SetNodePoolManagementRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetNodePoolManagementMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets labels on a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setLabels(com.google.container.v1beta1.SetLabelsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetLabelsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Enables or disables the ABAC authorization mechanism on a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setLegacyAbac(com.google.container.v1beta1.SetLegacyAbacRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetLegacyAbacMethod(), getCallOptions()), request);
}
/**
*
*
*
* Starts master IP rotation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
startIPRotation(com.google.container.v1beta1.StartIPRotationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getStartIPRotationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Completes master IP rotation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
completeIPRotation(com.google.container.v1beta1.CompleteIPRotationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCompleteIPRotationMethod(), getCallOptions()), request);
}
/**
*
*
*
* SetNodePoolSizeRequest sets the size of a node pool. The new size will be
* used for all replicas, including future replicas created by modifying
* [NodePool.locations][google.container.v1beta1.NodePool.locations].
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setNodePoolSize(com.google.container.v1beta1.SetNodePoolSizeRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetNodePoolSizeMethod(), getCallOptions()), request);
}
/**
*
*
*
* Enables or disables Network Policy for a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setNetworkPolicy(com.google.container.v1beta1.SetNetworkPolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetNetworkPolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Sets the maintenance policy for a cluster.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.Operation>
setMaintenancePolicy(com.google.container.v1beta1.SetMaintenancePolicyRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSetMaintenancePolicyMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists subnetworks that can be used for creating clusters in a project.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.ListUsableSubnetworksResponse>
listUsableSubnetworks(com.google.container.v1beta1.ListUsableSubnetworksRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListUsableSubnetworksMethod(), getCallOptions()), request);
}
/**
*
*
*
* Fetches locations that offer Google Kubernetes Engine.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.container.v1beta1.ListLocationsResponse>
listLocations(com.google.container.v1beta1.ListLocationsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListLocationsMethod(), getCallOptions()), request);
}
}
private static final int METHODID_LIST_CLUSTERS = 0;
private static final int METHODID_GET_CLUSTER = 1;
private static final int METHODID_CREATE_CLUSTER = 2;
private static final int METHODID_UPDATE_CLUSTER = 3;
private static final int METHODID_UPDATE_NODE_POOL = 4;
private static final int METHODID_SET_NODE_POOL_AUTOSCALING = 5;
private static final int METHODID_SET_LOGGING_SERVICE = 6;
private static final int METHODID_SET_MONITORING_SERVICE = 7;
private static final int METHODID_SET_ADDONS_CONFIG = 8;
private static final int METHODID_SET_LOCATIONS = 9;
private static final int METHODID_UPDATE_MASTER = 10;
private static final int METHODID_SET_MASTER_AUTH = 11;
private static final int METHODID_DELETE_CLUSTER = 12;
private static final int METHODID_LIST_OPERATIONS = 13;
private static final int METHODID_GET_OPERATION = 14;
private static final int METHODID_CANCEL_OPERATION = 15;
private static final int METHODID_GET_SERVER_CONFIG = 16;
private static final int METHODID_GET_JSONWEB_KEYS = 17;
private static final int METHODID_LIST_NODE_POOLS = 18;
private static final int METHODID_GET_NODE_POOL = 19;
private static final int METHODID_CREATE_NODE_POOL = 20;
private static final int METHODID_DELETE_NODE_POOL = 21;
private static final int METHODID_COMPLETE_NODE_POOL_UPGRADE = 22;
private static final int METHODID_ROLLBACK_NODE_POOL_UPGRADE = 23;
private static final int METHODID_SET_NODE_POOL_MANAGEMENT = 24;
private static final int METHODID_SET_LABELS = 25;
private static final int METHODID_SET_LEGACY_ABAC = 26;
private static final int METHODID_START_IPROTATION = 27;
private static final int METHODID_COMPLETE_IPROTATION = 28;
private static final int METHODID_SET_NODE_POOL_SIZE = 29;
private static final int METHODID_SET_NETWORK_POLICY = 30;
private static final int METHODID_SET_MAINTENANCE_POLICY = 31;
private static final int METHODID_LIST_USABLE_SUBNETWORKS = 32;
private static final int METHODID_LIST_LOCATIONS = 33;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_LIST_CLUSTERS:
serviceImpl.listClusters(
(com.google.container.v1beta1.ListClustersRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_CLUSTER:
serviceImpl.getCluster(
(com.google.container.v1beta1.GetClusterRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_CREATE_CLUSTER:
serviceImpl.createCluster(
(com.google.container.v1beta1.CreateClusterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_CLUSTER:
serviceImpl.updateCluster(
(com.google.container.v1beta1.UpdateClusterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_NODE_POOL:
serviceImpl.updateNodePool(
(com.google.container.v1beta1.UpdateNodePoolRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_NODE_POOL_AUTOSCALING:
serviceImpl.setNodePoolAutoscaling(
(com.google.container.v1beta1.SetNodePoolAutoscalingRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_LOGGING_SERVICE:
serviceImpl.setLoggingService(
(com.google.container.v1beta1.SetLoggingServiceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_MONITORING_SERVICE:
serviceImpl.setMonitoringService(
(com.google.container.v1beta1.SetMonitoringServiceRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_ADDONS_CONFIG:
serviceImpl.setAddonsConfig(
(com.google.container.v1beta1.SetAddonsConfigRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_LOCATIONS:
serviceImpl.setLocations(
(com.google.container.v1beta1.SetLocationsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_MASTER:
serviceImpl.updateMaster(
(com.google.container.v1beta1.UpdateMasterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_MASTER_AUTH:
serviceImpl.setMasterAuth(
(com.google.container.v1beta1.SetMasterAuthRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_CLUSTER:
serviceImpl.deleteCluster(
(com.google.container.v1beta1.DeleteClusterRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_OPERATIONS:
serviceImpl.listOperations(
(com.google.container.v1beta1.ListOperationsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_OPERATION:
serviceImpl.getOperation(
(com.google.container.v1beta1.GetOperationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CANCEL_OPERATION:
serviceImpl.cancelOperation(
(com.google.container.v1beta1.CancelOperationRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_SERVER_CONFIG:
serviceImpl.getServerConfig(
(com.google.container.v1beta1.GetServerConfigRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_JSONWEB_KEYS:
serviceImpl.getJSONWebKeys(
(com.google.container.v1beta1.GetJSONWebKeysRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_NODE_POOLS:
serviceImpl.listNodePools(
(com.google.container.v1beta1.ListNodePoolsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_NODE_POOL:
serviceImpl.getNodePool(
(com.google.container.v1beta1.GetNodePoolRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_NODE_POOL:
serviceImpl.createNodePool(
(com.google.container.v1beta1.CreateNodePoolRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_NODE_POOL:
serviceImpl.deleteNodePool(
(com.google.container.v1beta1.DeleteNodePoolRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_COMPLETE_NODE_POOL_UPGRADE:
serviceImpl.completeNodePoolUpgrade(
(com.google.container.v1beta1.CompleteNodePoolUpgradeRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_ROLLBACK_NODE_POOL_UPGRADE:
serviceImpl.rollbackNodePoolUpgrade(
(com.google.container.v1beta1.RollbackNodePoolUpgradeRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_NODE_POOL_MANAGEMENT:
serviceImpl.setNodePoolManagement(
(com.google.container.v1beta1.SetNodePoolManagementRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_LABELS:
serviceImpl.setLabels(
(com.google.container.v1beta1.SetLabelsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_LEGACY_ABAC:
serviceImpl.setLegacyAbac(
(com.google.container.v1beta1.SetLegacyAbacRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_START_IPROTATION:
serviceImpl.startIPRotation(
(com.google.container.v1beta1.StartIPRotationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_COMPLETE_IPROTATION:
serviceImpl.completeIPRotation(
(com.google.container.v1beta1.CompleteIPRotationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_NODE_POOL_SIZE:
serviceImpl.setNodePoolSize(
(com.google.container.v1beta1.SetNodePoolSizeRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_NETWORK_POLICY:
serviceImpl.setNetworkPolicy(
(com.google.container.v1beta1.SetNetworkPolicyRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_SET_MAINTENANCE_POLICY:
serviceImpl.setMaintenancePolicy(
(com.google.container.v1beta1.SetMaintenancePolicyRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_USABLE_SUBNETWORKS:
serviceImpl.listUsableSubnetworks(
(com.google.container.v1beta1.ListUsableSubnetworksRequest) request,
(io.grpc.stub.StreamObserver<
com.google.container.v1beta1.ListUsableSubnetworksResponse>)
responseObserver);
break;
case METHODID_LIST_LOCATIONS:
serviceImpl.listLocations(
(com.google.container.v1beta1.ListLocationsRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getListClustersMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.ListClustersRequest,
com.google.container.v1beta1.ListClustersResponse>(
service, METHODID_LIST_CLUSTERS)))
.addMethod(
getGetClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.GetClusterRequest,
com.google.container.v1beta1.Cluster>(service, METHODID_GET_CLUSTER)))
.addMethod(
getCreateClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.CreateClusterRequest,
com.google.container.v1beta1.Operation>(service, METHODID_CREATE_CLUSTER)))
.addMethod(
getUpdateClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.UpdateClusterRequest,
com.google.container.v1beta1.Operation>(service, METHODID_UPDATE_CLUSTER)))
.addMethod(
getUpdateNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.UpdateNodePoolRequest,
com.google.container.v1beta1.Operation>(service, METHODID_UPDATE_NODE_POOL)))
.addMethod(
getSetNodePoolAutoscalingMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetNodePoolAutoscalingRequest,
com.google.container.v1beta1.Operation>(
service, METHODID_SET_NODE_POOL_AUTOSCALING)))
.addMethod(
getSetLoggingServiceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetLoggingServiceRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_LOGGING_SERVICE)))
.addMethod(
getSetMonitoringServiceMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetMonitoringServiceRequest,
com.google.container.v1beta1.Operation>(
service, METHODID_SET_MONITORING_SERVICE)))
.addMethod(
getSetAddonsConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetAddonsConfigRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_ADDONS_CONFIG)))
.addMethod(
getSetLocationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetLocationsRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_LOCATIONS)))
.addMethod(
getUpdateMasterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.UpdateMasterRequest,
com.google.container.v1beta1.Operation>(service, METHODID_UPDATE_MASTER)))
.addMethod(
getSetMasterAuthMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetMasterAuthRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_MASTER_AUTH)))
.addMethod(
getDeleteClusterMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.DeleteClusterRequest,
com.google.container.v1beta1.Operation>(service, METHODID_DELETE_CLUSTER)))
.addMethod(
getListOperationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.ListOperationsRequest,
com.google.container.v1beta1.ListOperationsResponse>(
service, METHODID_LIST_OPERATIONS)))
.addMethod(
getGetOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.GetOperationRequest,
com.google.container.v1beta1.Operation>(service, METHODID_GET_OPERATION)))
.addMethod(
getCancelOperationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.CancelOperationRequest, com.google.protobuf.Empty>(
service, METHODID_CANCEL_OPERATION)))
.addMethod(
getGetServerConfigMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.GetServerConfigRequest,
com.google.container.v1beta1.ServerConfig>(
service, METHODID_GET_SERVER_CONFIG)))
.addMethod(
getGetJSONWebKeysMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.GetJSONWebKeysRequest,
com.google.container.v1beta1.GetJSONWebKeysResponse>(
service, METHODID_GET_JSONWEB_KEYS)))
.addMethod(
getListNodePoolsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.ListNodePoolsRequest,
com.google.container.v1beta1.ListNodePoolsResponse>(
service, METHODID_LIST_NODE_POOLS)))
.addMethod(
getGetNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.GetNodePoolRequest,
com.google.container.v1beta1.NodePool>(service, METHODID_GET_NODE_POOL)))
.addMethod(
getCreateNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.CreateNodePoolRequest,
com.google.container.v1beta1.Operation>(service, METHODID_CREATE_NODE_POOL)))
.addMethod(
getDeleteNodePoolMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.DeleteNodePoolRequest,
com.google.container.v1beta1.Operation>(service, METHODID_DELETE_NODE_POOL)))
.addMethod(
getCompleteNodePoolUpgradeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.CompleteNodePoolUpgradeRequest,
com.google.protobuf.Empty>(service, METHODID_COMPLETE_NODE_POOL_UPGRADE)))
.addMethod(
getRollbackNodePoolUpgradeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.RollbackNodePoolUpgradeRequest,
com.google.container.v1beta1.Operation>(
service, METHODID_ROLLBACK_NODE_POOL_UPGRADE)))
.addMethod(
getSetNodePoolManagementMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetNodePoolManagementRequest,
com.google.container.v1beta1.Operation>(
service, METHODID_SET_NODE_POOL_MANAGEMENT)))
.addMethod(
getSetLabelsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetLabelsRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_LABELS)))
.addMethod(
getSetLegacyAbacMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetLegacyAbacRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_LEGACY_ABAC)))
.addMethod(
getStartIPRotationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.StartIPRotationRequest,
com.google.container.v1beta1.Operation>(service, METHODID_START_IPROTATION)))
.addMethod(
getCompleteIPRotationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.CompleteIPRotationRequest,
com.google.container.v1beta1.Operation>(service, METHODID_COMPLETE_IPROTATION)))
.addMethod(
getSetNodePoolSizeMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetNodePoolSizeRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_NODE_POOL_SIZE)))
.addMethod(
getSetNetworkPolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetNetworkPolicyRequest,
com.google.container.v1beta1.Operation>(service, METHODID_SET_NETWORK_POLICY)))
.addMethod(
getSetMaintenancePolicyMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.SetMaintenancePolicyRequest,
com.google.container.v1beta1.Operation>(
service, METHODID_SET_MAINTENANCE_POLICY)))
.addMethod(
getListUsableSubnetworksMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.ListUsableSubnetworksRequest,
com.google.container.v1beta1.ListUsableSubnetworksResponse>(
service, METHODID_LIST_USABLE_SUBNETWORKS)))
.addMethod(
getListLocationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.container.v1beta1.ListLocationsRequest,
com.google.container.v1beta1.ListLocationsResponse>(
service, METHODID_LIST_LOCATIONS)))
.build();
}
private abstract static class ClusterManagerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ClusterManagerBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.container.v1beta1.ClusterServiceProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("ClusterManager");
}
}
private static final class ClusterManagerFileDescriptorSupplier
extends ClusterManagerBaseDescriptorSupplier {
ClusterManagerFileDescriptorSupplier() {}
}
private static final class ClusterManagerMethodDescriptorSupplier
extends ClusterManagerBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ClusterManagerMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (ClusterManagerGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ClusterManagerFileDescriptorSupplier())
.addMethod(getListClustersMethod())
.addMethod(getGetClusterMethod())
.addMethod(getCreateClusterMethod())
.addMethod(getUpdateClusterMethod())
.addMethod(getUpdateNodePoolMethod())
.addMethod(getSetNodePoolAutoscalingMethod())
.addMethod(getSetLoggingServiceMethod())
.addMethod(getSetMonitoringServiceMethod())
.addMethod(getSetAddonsConfigMethod())
.addMethod(getSetLocationsMethod())
.addMethod(getUpdateMasterMethod())
.addMethod(getSetMasterAuthMethod())
.addMethod(getDeleteClusterMethod())
.addMethod(getListOperationsMethod())
.addMethod(getGetOperationMethod())
.addMethod(getCancelOperationMethod())
.addMethod(getGetServerConfigMethod())
.addMethod(getGetJSONWebKeysMethod())
.addMethod(getListNodePoolsMethod())
.addMethod(getGetNodePoolMethod())
.addMethod(getCreateNodePoolMethod())
.addMethod(getDeleteNodePoolMethod())
.addMethod(getCompleteNodePoolUpgradeMethod())
.addMethod(getRollbackNodePoolUpgradeMethod())
.addMethod(getSetNodePoolManagementMethod())
.addMethod(getSetLabelsMethod())
.addMethod(getSetLegacyAbacMethod())
.addMethod(getStartIPRotationMethod())
.addMethod(getCompleteIPRotationMethod())
.addMethod(getSetNodePoolSizeMethod())
.addMethod(getSetNetworkPolicyMethod())
.addMethod(getSetMaintenancePolicyMethod())
.addMethod(getListUsableSubnetworksMethod())
.addMethod(getListLocationsMethod())
.build();
}
}
}
return result;
}
}