# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc

from google.cloud.functions.v1beta2 import functions_pb2 as google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2
from google.longrunning import operations_pb2 as google_dot_longrunning_dot_operations__pb2


class CloudFunctionsServiceStub(object):
  """A service that application uses to manipulate triggers and functions.
  """

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.ListFunctions = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/ListFunctions',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsResponse.FromString,
        )
    self.GetFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/GetFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GetFunctionRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CloudFunction.FromString,
        )
    self.CreateFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/CreateFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CreateFunctionRequest.SerializeToString,
        response_deserializer=google_dot_longrunning_dot_operations__pb2.Operation.FromString,
        )
    self.UpdateFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/UpdateFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.UpdateFunctionRequest.SerializeToString,
        response_deserializer=google_dot_longrunning_dot_operations__pb2.Operation.FromString,
        )
    self.DeleteFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/DeleteFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.DeleteFunctionRequest.SerializeToString,
        response_deserializer=google_dot_longrunning_dot_operations__pb2.Operation.FromString,
        )
    self.CallFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/CallFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionResponse.FromString,
        )
    self.GenerateUploadUrl = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateUploadUrl',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlResponse.FromString,
        )
    self.GenerateDownloadUrl = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateDownloadUrl',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlResponse.FromString,
        )


class CloudFunctionsServiceServicer(object):
  """A service that application uses to manipulate triggers and functions.
  """

  def ListFunctions(self, request, context):
    """Returns a list of functions that belong to the requested project.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def GetFunction(self, request, context):
    """Returns a function with the given name from the requested project.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def CreateFunction(self, request, context):
    """Creates a new function. If a function with the given name already exists in
    the specified project, the long running operation will return
    `ALREADY_EXISTS` error.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def UpdateFunction(self, request, context):
    """Updates existing function.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def DeleteFunction(self, request, context):
    """Deletes a function with the given name from the specified project. If the
    given function is used by some trigger, the trigger will be updated to
    remove this function.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def CallFunction(self, request, context):
    """Synchronously invokes a deployed Cloud Function. To be used for testing
    purposes as very limited traffic is allowed. For more information on
    the actual limits refer to [API Calls](
    https://cloud.google.com/functions/quotas#rate_limits).
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def GenerateUploadUrl(self, request, context):
    """Returns a signed URL for uploading a function source code.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    Once the function source code upload is complete, the used signed
    URL should be provided in CreateFunction or UpdateFunction request
    as a reference to the function source code.

    When uploading source code to the generated signed URL, please follow
    these restrictions:

    * Source file type should be a zip file.
    * Source file size should not exceed 100MB limit.
    * No credentials should be attached - the signed URLs provide access to the
    target bucket using internal service identity; if credentials were
    attached, the identity from the credentials would be used, but that
    identity does not have permissions to upload files to the URL.

    When making a HTTP PUT request, these two headers need to be specified:

    * `content-type: application/zip`
    * `x-goog-content-length-range: 0,104857600`

    And this header SHOULD NOT be specified:

    * `Authorization: Bearer YOUR_TOKEN`
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def GenerateDownloadUrl(self, request, context):
    """Returns a signed URL for downloading deployed function source code.
    The URL is only valid for a limited period and should be used within
    minutes after generation.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_CloudFunctionsServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'ListFunctions': grpc.unary_unary_rpc_method_handler(
          servicer.ListFunctions,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsResponse.SerializeToString,
      ),
      'GetFunction': grpc.unary_unary_rpc_method_handler(
          servicer.GetFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GetFunctionRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CloudFunction.SerializeToString,
      ),
      'CreateFunction': grpc.unary_unary_rpc_method_handler(
          servicer.CreateFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CreateFunctionRequest.FromString,
          response_serializer=google_dot_longrunning_dot_operations__pb2.Operation.SerializeToString,
      ),
      'UpdateFunction': grpc.unary_unary_rpc_method_handler(
          servicer.UpdateFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.UpdateFunctionRequest.FromString,
          response_serializer=google_dot_longrunning_dot_operations__pb2.Operation.SerializeToString,
      ),
      'DeleteFunction': grpc.unary_unary_rpc_method_handler(
          servicer.DeleteFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.DeleteFunctionRequest.FromString,
          response_serializer=google_dot_longrunning_dot_operations__pb2.Operation.SerializeToString,
      ),
      'CallFunction': grpc.unary_unary_rpc_method_handler(
          servicer.CallFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionResponse.SerializeToString,
      ),
      'GenerateUploadUrl': grpc.unary_unary_rpc_method_handler(
          servicer.GenerateUploadUrl,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlResponse.SerializeToString,
      ),
      'GenerateDownloadUrl': grpc.unary_unary_rpc_method_handler(
          servicer.GenerateDownloadUrl,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'google.cloud.functions.v1beta2.CloudFunctionsService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))

e1f6f27f231289669be21359aa213cf070921ae3
<mask token>


class CloudFunctionsServiceStub(object):
    <mask token>
    <mask token>


class CloudFunctionsServiceServicer(object):
    """A service that application uses to manipulate triggers and functions.
  """

    def ListFunctions(self, request, context):
        """Returns a list of functions that belong to the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetFunction(self, request, context):
        """Returns a function with the given name from the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CreateFunction(self, request, context):
        """Creates a new function. If a function with the given name already exists in
    the specified project, the long running operation will return
    `ALREADY_EXISTS` error.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def UpdateFunction(self, request, context):
        """Updates existing function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def DeleteFunction(self, request, context):
        """Deletes a function with the given name from the specified project. If the
    given function is used by some trigger, the trigger will be updated to
    remove this function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CallFunction(self, request, context):
        """Synchronously invokes a deployed Cloud Function. To be used for testing
    purposes as very limited traffic is allowed. For more information on
    the actual limits refer to [API Calls](
    https://cloud.google.com/functions/quotas#rate_limits).
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateUploadUrl(self, request, context):
        """Returns a signed URL for uploading a function source code.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    Once the function source code upload is complete, the used signed
    URL should be provided in CreateFunction or UpdateFunction request
    as a reference to the function source code.

    When uploading source code to the generated signed URL, please follow
    these restrictions:

    * Source file type should be a zip file.
    * Source file size should not exceed 100MB limit.
    * No credentials should be attached - the signed URLs provide access to the
    target bucket using internal service identity; if credentials were
    attached, the identity from the credentials would be used, but that
    identity does not have permissions to upload files to the URL.

    When making a HTTP PUT request, these two headers need to be specified:

    * `content-type: application/zip`
    * `x-goog-content-length-range: 0,104857600`

    And this header SHOULD NOT be specified:

    * `Authorization: Bearer YOUR_TOKEN`
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateDownloadUrl(self, request, context):
        """Returns a signed URL for downloading deployed function source code.
    The URL is only valid for a limited period and should be used within
    minutes after generation.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

<mask token>


class CloudFunctionsServiceStub(object):
    <mask token>

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.ListFunctions = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/ListFunctions'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            ListFunctionsRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            ListFunctionsResponse.FromString)
        self.GetFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GetFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GetFunctionRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CloudFunction.FromString)
        self.CreateFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/CreateFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CreateFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.UpdateFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/UpdateFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            UpdateFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.DeleteFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/DeleteFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            DeleteFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.CallFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/CallFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CallFunctionRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CallFunctionResponse.FromString)
        self.GenerateUploadUrl = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateUploadUrl'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateUploadUrlRequest.SerializeToString,
            response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateUploadUrlResponse.FromString)
        self.GenerateDownloadUrl = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateDownloadUrl'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateDownloadUrlRequest.SerializeToString,
            response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateDownloadUrlResponse.FromString)


class CloudFunctionsServiceServicer(object):
    """A service that application uses to manipulate triggers and functions.
  """

    def ListFunctions(self, request, context):
        """Returns a list of functions that belong to the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetFunction(self, request, context):
        """Returns a function with the given name from the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CreateFunction(self, request, context):
        """Creates a new function. If a function with the given name already exists in
    the specified project, the long running operation will return
    `ALREADY_EXISTS` error.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def UpdateFunction(self, request, context):
        """Updates existing function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def DeleteFunction(self, request, context):
        """Deletes a function with the given name from the specified project. If the
    given function is used by some trigger, the trigger will be updated to
    remove this function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CallFunction(self, request, context):
        """Synchronously invokes a deployed Cloud Function. To be used for testing
    purposes as very limited traffic is allowed. For more information on
    the actual limits refer to [API Calls](
    https://cloud.google.com/functions/quotas#rate_limits).
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateUploadUrl(self, request, context):
        """Returns a signed URL for uploading a function source code.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    Once the function source code upload is complete, the used signed
    URL should be provided in CreateFunction or UpdateFunction request
    as a reference to the function source code.

    When uploading source code to the generated signed URL, please follow
    these restrictions:

    * Source file type should be a zip file.
    * Source file size should not exceed 100MB limit.
    * No credentials should be attached - the signed URLs provide access to the
    target bucket using internal service identity; if credentials were
    attached, the identity from the credentials would be used, but that
    identity does not have permissions to upload files to the URL.

    When making a HTTP PUT request, these two headers need to be specified:

    * `content-type: application/zip`
    * `x-goog-content-length-range: 0,104857600`

    And this header SHOULD NOT be specified:

    * `Authorization: Bearer YOUR_TOKEN`
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateDownloadUrl(self, request, context):
        """Returns a signed URL for downloading deployed function source code.
    The URL is only valid for a limited period and should be used within
    minutes after generation.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

<mask token>


class CloudFunctionsServiceStub(object):
    """A service that application uses to manipulate triggers and functions.
  """

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.ListFunctions = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/ListFunctions'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            ListFunctionsRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            ListFunctionsResponse.FromString)
        self.GetFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GetFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GetFunctionRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CloudFunction.FromString)
        self.CreateFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/CreateFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CreateFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.UpdateFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/UpdateFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            UpdateFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.DeleteFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/DeleteFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            DeleteFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.CallFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/CallFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CallFunctionRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CallFunctionResponse.FromString)
        self.GenerateUploadUrl = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateUploadUrl'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateUploadUrlRequest.SerializeToString,
            response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateUploadUrlResponse.FromString)
        self.GenerateDownloadUrl = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateDownloadUrl'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateDownloadUrlRequest.SerializeToString,
            response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateDownloadUrlResponse.FromString)


class CloudFunctionsServiceServicer(object):
    """A service that application uses to manipulate triggers and functions.
  """

    def ListFunctions(self, request, context):
        """Returns a list of functions that belong to the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetFunction(self, request, context):
        """Returns a function with the given name from the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CreateFunction(self, request, context):
        """Creates a new function. If a function with the given name already exists in
    the specified project, the long running operation will return
    `ALREADY_EXISTS` error.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def UpdateFunction(self, request, context):
        """Updates existing function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def DeleteFunction(self, request, context):
        """Deletes a function with the given name from the specified project. If the
    given function is used by some trigger, the trigger will be updated to
    remove this function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CallFunction(self, request, context):
        """Synchronously invokes a deployed Cloud Function. To be used for testing
    purposes as very limited traffic is allowed. For more information on
    the actual limits refer to [API Calls](
    https://cloud.google.com/functions/quotas#rate_limits).
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateUploadUrl(self, request, context):
        """Returns a signed URL for uploading a function source code.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    Once the function source code upload is complete, the used signed
    URL should be provided in CreateFunction or UpdateFunction request
    as a reference to the function source code.

    When uploading source code to the generated signed URL, please follow
    these restrictions:

    * Source file type should be a zip file.
    * Source file size should not exceed 100MB limit.
    * No credentials should be attached - the signed URLs provide access to the
    target bucket using internal service identity; if credentials were
    attached, the identity from the credentials would be used, but that
    identity does not have permissions to upload files to the URL.

    When making a HTTP PUT request, these two headers need to be specified:

    * `content-type: application/zip`
    * `x-goog-content-length-range: 0,104857600`

    And this header SHOULD NOT be specified:

    * `Authorization: Bearer YOUR_TOKEN`
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateDownloadUrl(self, request, context):
        """Returns a signed URL for downloading deployed function source code.
    The URL is only valid for a limited period and should be used within
    minutes after generation.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


<mask token>

import grpc
from google.cloud.functions.v1beta2 import functions_pb2 as google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2
from google.longrunning import operations_pb2 as google_dot_longrunning_dot_operations__pb2


class CloudFunctionsServiceStub(object):
    """A service that application uses to manipulate triggers and functions.
  """

    def __init__(self, channel):
        """Constructor.

    Args:
      channel: A grpc.Channel.
    """
        self.ListFunctions = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/ListFunctions'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            ListFunctionsRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            ListFunctionsResponse.FromString)
        self.GetFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GetFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GetFunctionRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CloudFunction.FromString)
        self.CreateFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/CreateFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CreateFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.UpdateFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/UpdateFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            UpdateFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.DeleteFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/DeleteFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            DeleteFunctionRequest.SerializeToString, response_deserializer=
            google_dot_longrunning_dot_operations__pb2.Operation.FromString)
        self.CallFunction = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/CallFunction'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CallFunctionRequest.SerializeToString, response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            CallFunctionResponse.FromString)
        self.GenerateUploadUrl = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateUploadUrl'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateUploadUrlRequest.SerializeToString,
            response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateUploadUrlResponse.FromString)
        self.GenerateDownloadUrl = channel.unary_unary(
            '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateDownloadUrl'
            , request_serializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateDownloadUrlRequest.SerializeToString,
            response_deserializer=
            google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
            GenerateDownloadUrlResponse.FromString)


class CloudFunctionsServiceServicer(object):
    """A service that application uses to manipulate triggers and functions.
  """

    def ListFunctions(self, request, context):
        """Returns a list of functions that belong to the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GetFunction(self, request, context):
        """Returns a function with the given name from the requested project.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CreateFunction(self, request, context):
        """Creates a new function. If a function with the given name already exists in
    the specified project, the long running operation will return
    `ALREADY_EXISTS` error.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def UpdateFunction(self, request, context):
        """Updates existing function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def DeleteFunction(self, request, context):
        """Deletes a function with the given name from the specified project. If the
    given function is used by some trigger, the trigger will be updated to
    remove this function.
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def CallFunction(self, request, context):
        """Synchronously invokes a deployed Cloud Function. To be used for testing
    purposes as very limited traffic is allowed. For more information on
    the actual limits refer to [API Calls](
    https://cloud.google.com/functions/quotas#rate_limits).
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateUploadUrl(self, request, context):
        """Returns a signed URL for uploading a function source code.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    Once the function source code upload is complete, the used signed
    URL should be provided in CreateFunction or UpdateFunction request
    as a reference to the function source code.

    When uploading source code to the generated signed URL, please follow
    these restrictions:

    * Source file type should be a zip file.
    * Source file size should not exceed 100MB limit.
    * No credentials should be attached - the signed URLs provide access to the
    target bucket using internal service identity; if credentials were
    attached, the identity from the credentials would be used, but that
    identity does not have permissions to upload files to the URL.

    When making a HTTP PUT request, these two headers need to be specified:

    * `content-type: application/zip`
    * `x-goog-content-length-range: 0,104857600`

    And this header SHOULD NOT be specified:

    * `Authorization: Bearer YOUR_TOKEN`
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def GenerateDownloadUrl(self, request, context):
        """Returns a signed URL for downloading deployed function source code.
    The URL is only valid for a limited period and should be used within
    minutes after generation.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    """
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')


def add_CloudFunctionsServiceServicer_to_server(servicer, server):
    rpc_method_handlers = {'ListFunctions': grpc.
        unary_unary_rpc_method_handler(servicer.ListFunctions,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        ListFunctionsRequest.FromString, response_serializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        ListFunctionsResponse.SerializeToString), 'GetFunction': grpc.
        unary_unary_rpc_method_handler(servicer.GetFunction,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        GetFunctionRequest.FromString, response_serializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        CloudFunction.SerializeToString), 'CreateFunction': grpc.
        unary_unary_rpc_method_handler(servicer.CreateFunction,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        CreateFunctionRequest.FromString, response_serializer=
        google_dot_longrunning_dot_operations__pb2.Operation.
        SerializeToString), 'UpdateFunction': grpc.
        unary_unary_rpc_method_handler(servicer.UpdateFunction,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        UpdateFunctionRequest.FromString, response_serializer=
        google_dot_longrunning_dot_operations__pb2.Operation.
        SerializeToString), 'DeleteFunction': grpc.
        unary_unary_rpc_method_handler(servicer.DeleteFunction,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        DeleteFunctionRequest.FromString, response_serializer=
        google_dot_longrunning_dot_operations__pb2.Operation.
        SerializeToString), 'CallFunction': grpc.
        unary_unary_rpc_method_handler(servicer.CallFunction,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        CallFunctionRequest.FromString, response_serializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        CallFunctionResponse.SerializeToString), 'GenerateUploadUrl': grpc.
        unary_unary_rpc_method_handler(servicer.GenerateUploadUrl,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        GenerateUploadUrlRequest.FromString, response_serializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        GenerateUploadUrlResponse.SerializeToString), 'GenerateDownloadUrl':
        grpc.unary_unary_rpc_method_handler(servicer.GenerateDownloadUrl,
        request_deserializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        GenerateDownloadUrlRequest.FromString, response_serializer=
        google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.
        GenerateDownloadUrlResponse.SerializeToString)}
    generic_handler = grpc.method_handlers_generic_handler(
        'google.cloud.functions.v1beta2.CloudFunctionsService',
        rpc_method_handlers)
    server.add_generic_rpc_handlers((generic_handler,))

# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!
import grpc

from google.cloud.functions.v1beta2 import functions_pb2 as google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2
from google.longrunning import operations_pb2 as google_dot_longrunning_dot_operations__pb2


class CloudFunctionsServiceStub(object):
  """A service that application uses to manipulate triggers and functions.
  """

  def __init__(self, channel):
    """Constructor.

    Args:
      channel: A grpc.Channel.
    """
    self.ListFunctions = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/ListFunctions',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsResponse.FromString,
        )
    self.GetFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/GetFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GetFunctionRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CloudFunction.FromString,
        )
    self.CreateFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/CreateFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CreateFunctionRequest.SerializeToString,
        response_deserializer=google_dot_longrunning_dot_operations__pb2.Operation.FromString,
        )
    self.UpdateFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/UpdateFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.UpdateFunctionRequest.SerializeToString,
        response_deserializer=google_dot_longrunning_dot_operations__pb2.Operation.FromString,
        )
    self.DeleteFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/DeleteFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.DeleteFunctionRequest.SerializeToString,
        response_deserializer=google_dot_longrunning_dot_operations__pb2.Operation.FromString,
        )
    self.CallFunction = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/CallFunction',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionResponse.FromString,
        )
    self.GenerateUploadUrl = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateUploadUrl',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlResponse.FromString,
        )
    self.GenerateDownloadUrl = channel.unary_unary(
        '/google.cloud.functions.v1beta2.CloudFunctionsService/GenerateDownloadUrl',
        request_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlRequest.SerializeToString,
        response_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlResponse.FromString,
        )


class CloudFunctionsServiceServicer(object):
  """A service that application uses to manipulate triggers and functions.
  """

  def ListFunctions(self, request, context):
    """Returns a list of functions that belong to the requested project.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def GetFunction(self, request, context):
    """Returns a function with the given name from the requested project.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def CreateFunction(self, request, context):
    """Creates a new function. If a function with the given name already exists in
    the specified project, the long running operation will return
    `ALREADY_EXISTS` error.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def UpdateFunction(self, request, context):
    """Updates existing function.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def DeleteFunction(self, request, context):
    """Deletes a function with the given name from the specified project. If the
    given function is used by some trigger, the trigger will be updated to
    remove this function.
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def CallFunction(self, request, context):
    """Synchronously invokes a deployed Cloud Function. To be used for testing
    purposes as very limited traffic is allowed. For more information on
    the actual limits refer to [API Calls](
    https://cloud.google.com/functions/quotas#rate_limits).
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def GenerateUploadUrl(self, request, context):
    """Returns a signed URL for uploading a function source code.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    Once the function source code upload is complete, the used signed
    URL should be provided in CreateFunction or UpdateFunction request
    as a reference to the function source code.

    When uploading source code to the generated signed URL, please follow
    these restrictions:

    * Source file type should be a zip file.
    * Source file size should not exceed 100MB limit.
    * No credentials should be attached - the signed URLs provide access to the
    target bucket using internal service identity; if credentials were
    attached, the identity from the credentials would be used, but that
    identity does not have permissions to upload files to the URL.

    When making a HTTP PUT request, these two headers need to be specified:

    * `content-type: application/zip`
    * `x-goog-content-length-range: 0,104857600`

    And this header SHOULD NOT be specified:

    * `Authorization: Bearer YOUR_TOKEN`
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

  def GenerateDownloadUrl(self, request, context):
    """Returns a signed URL for downloading deployed function source code.
    The URL is only valid for a limited period and should be used within
    minutes after generation.
    For more information about the signed URL usage see:
    https://cloud.google.com/storage/docs/access-control/signed-urls
    """
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')


def add_CloudFunctionsServiceServicer_to_server(servicer, server):
  rpc_method_handlers = {
      'ListFunctions': grpc.unary_unary_rpc_method_handler(
          servicer.ListFunctions,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.ListFunctionsResponse.SerializeToString,
      ),
      'GetFunction': grpc.unary_unary_rpc_method_handler(
          servicer.GetFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GetFunctionRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CloudFunction.SerializeToString,
      ),
      'CreateFunction': grpc.unary_unary_rpc_method_handler(
          servicer.CreateFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CreateFunctionRequest.FromString,
          response_serializer=google_dot_longrunning_dot_operations__pb2.Operation.SerializeToString,
      ),
      'UpdateFunction': grpc.unary_unary_rpc_method_handler(
          servicer.UpdateFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.UpdateFunctionRequest.FromString,
          response_serializer=google_dot_longrunning_dot_operations__pb2.Operation.SerializeToString,
      ),
      'DeleteFunction': grpc.unary_unary_rpc_method_handler(
          servicer.DeleteFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.DeleteFunctionRequest.FromString,
          response_serializer=google_dot_longrunning_dot_operations__pb2.Operation.SerializeToString,
      ),
      'CallFunction': grpc.unary_unary_rpc_method_handler(
          servicer.CallFunction,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.CallFunctionResponse.SerializeToString,
      ),
      'GenerateUploadUrl': grpc.unary_unary_rpc_method_handler(
          servicer.GenerateUploadUrl,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateUploadUrlResponse.SerializeToString,
      ),
      'GenerateDownloadUrl': grpc.unary_unary_rpc_method_handler(
          servicer.GenerateDownloadUrl,
          request_deserializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlRequest.FromString,
          response_serializer=google_dot_cloud_dot_functions_dot_v1beta2_dot_functions__pb2.GenerateDownloadUrlResponse.SerializeToString,
      ),
  }
  generic_handler = grpc.method_handlers_generic_handler(
      'google.cloud.functions.v1beta2.CloudFunctionsService', rpc_method_handlers)
  server.add_generic_rpc_handlers((generic_handler,))
