Skip to content

Commit

Permalink
chore: update grpc version (#47)
Browse files Browse the repository at this point in the history
Source-Author: Google APIs <noreply@google.com>
Source-Date: Tue Jun 23 11:09:31 2020 -0700
Source-Repo: googleapis/googleapis
Source-Sha: 4e8f1142ff921de8d5ad757bce9f2c09dab6ff1b
Source-Link: googleapis/googleapis@4e8f114

* chore: update grpc to v1.30.0

PiperOrigin-RevId: 317949519
  • Loading branch information
yoshi-automation authored Jun 29, 2020
1 parent 182ea86 commit ac37509
Show file tree
Hide file tree
Showing 25 changed files with 1,644 additions and 228 deletions.

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
"""Client and server classes corresponding to protobuf-defined services."""
import grpc

from google.cloud.dataproc_v1.proto import (
Expand All @@ -9,15 +10,15 @@

class AutoscalingPolicyServiceStub(object):
"""The API interface for managing autoscaling policies in the
Dataproc API.
"""
Dataproc API.
"""

def __init__(self, channel):
"""Constructor.
Args:
channel: A grpc.Channel.
"""
Args:
channel: A grpc.Channel.
"""
self.CreateAutoscalingPolicy = channel.unary_unary(
"/google.cloud.dataproc.v1.AutoscalingPolicyService/CreateAutoscalingPolicy",
request_serializer=google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.CreateAutoscalingPolicyRequest.SerializeToString,
Expand Down Expand Up @@ -47,44 +48,44 @@ def __init__(self, channel):

class AutoscalingPolicyServiceServicer(object):
"""The API interface for managing autoscaling policies in the
Dataproc API.
"""
Dataproc API.
"""

def CreateAutoscalingPolicy(self, request, context):
"""Creates new autoscaling policy.
"""
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def UpdateAutoscalingPolicy(self, request, context):
"""Updates (replaces) autoscaling policy.
Disabled check for update_mask, because all updates will be full
replacements.
"""
Disabled check for update_mask, because all updates will be full
replacements.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def GetAutoscalingPolicy(self, request, context):
"""Retrieves autoscaling policy.
"""
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def ListAutoscalingPolicies(self, request, context):
"""Lists autoscaling policies in the project.
"""
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")

def DeleteAutoscalingPolicy(self, request, context):
"""Deletes an autoscaling policy. It is an error to delete an autoscaling
policy that is in use by one or more clusters.
"""
policy that is in use by one or more clusters.
"""
context.set_code(grpc.StatusCode.UNIMPLEMENTED)
context.set_details("Method not implemented!")
raise NotImplementedError("Method not implemented!")
Expand Down Expand Up @@ -122,3 +123,145 @@ def add_AutoscalingPolicyServiceServicer_to_server(servicer, server):
"google.cloud.dataproc.v1.AutoscalingPolicyService", rpc_method_handlers
)
server.add_generic_rpc_handlers((generic_handler,))


# This class is part of an EXPERIMENTAL API.
class AutoscalingPolicyService(object):
"""The API interface for managing autoscaling policies in the
Dataproc API.
"""

@staticmethod
def CreateAutoscalingPolicy(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
"/google.cloud.dataproc.v1.AutoscalingPolicyService/CreateAutoscalingPolicy",
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.CreateAutoscalingPolicyRequest.SerializeToString,
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.AutoscalingPolicy.FromString,
options,
channel_credentials,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

@staticmethod
def UpdateAutoscalingPolicy(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
"/google.cloud.dataproc.v1.AutoscalingPolicyService/UpdateAutoscalingPolicy",
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.UpdateAutoscalingPolicyRequest.SerializeToString,
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.AutoscalingPolicy.FromString,
options,
channel_credentials,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

@staticmethod
def GetAutoscalingPolicy(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
"/google.cloud.dataproc.v1.AutoscalingPolicyService/GetAutoscalingPolicy",
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.GetAutoscalingPolicyRequest.SerializeToString,
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.AutoscalingPolicy.FromString,
options,
channel_credentials,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

@staticmethod
def ListAutoscalingPolicies(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
"/google.cloud.dataproc.v1.AutoscalingPolicyService/ListAutoscalingPolicies",
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.ListAutoscalingPoliciesRequest.SerializeToString,
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.ListAutoscalingPoliciesResponse.FromString,
options,
channel_credentials,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

@staticmethod
def DeleteAutoscalingPolicy(
request,
target,
options=(),
channel_credentials=None,
call_credentials=None,
compression=None,
wait_for_ready=None,
timeout=None,
metadata=None,
):
return grpc.experimental.unary_unary(
request,
target,
"/google.cloud.dataproc.v1.AutoscalingPolicyService/DeleteAutoscalingPolicy",
google_dot_cloud_dot_dataproc__v1_dot_proto_dot_autoscaling__policies__pb2.DeleteAutoscalingPolicyRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
options,
channel_credentials,
call_credentials,
compression,
wait_for_ready,
timeout,
metadata,
)

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit ac37509

Please sign in to comment.