# Connectors API . projects . locations . connections . eventSubscriptions

## Instance Methods

Close httplib2 connections.

Creates a new EventSubscription in a given project,location and connection.

Deletes a single EventSubscription.

Gets details of a single EventSubscription.

List EventSubscriptions in a given project,location and connection.

Retrieves the next page of results.

Updates the parameters of a single EventSubscription.

RetryEventSubscription retries the registration of Subscription.

### Method Details

`close()`

    Close httplib2 connections.

`create(parent, body=None, eventSubscriptionId=None, x__xgafv=None)`

    Creates a new EventSubscription in a given project,location and connection.

    Args:
      parent: string, Required. Parent resource of the EventSubscription, of the form: `projects/*/locations/*/connections/*` (required)
      body: object, The request body.
        The object takes the form of:

    { # represents the Connector's EventSubscription resource
      "createTime": "A String", # Output only. Created time.
      "destinations": { # Message for EventSubscription Destination to act on receiving an event # Optional. The destination to hit when we receive an event
        "endpoint": { # Endpoint message includes details of the Destination endpoint. # OPTION 1: Hit an endpoint when we receive an event.
          "endpointUri": "A String", # Optional. The URI of the Endpoint.
          "headers": [ # Optional. List of Header to be added to the Endpoint.
            { # Header details for a given header to be added to Endpoint.
              "key": "A String", # Optional. Key of Header.
              "value": "A String", # Optional. Value of Header.
            },
          ],
        },
        "pubsub": { # Pub/Sub message includes details of the Destination Pub/Sub topic. # OPTION 3: Write the event to Pub/Sub topic.
          "attributes": { # Optional. Pub/Sub message attributes to be added to the Pub/Sub message.
            "a_key": "A String",
          },
          "configVariables": [ # Optional. Configuration for configuring the trigger
            { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
              "boolValue": True or False, # Value is a bool.
              "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
                "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
                "type": "A String", # Type.
              },
              "intValue": "A String", # Value is an integer
              "key": "A String", # Optional. Key of the config variable.
              "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
                "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
              },
              "stringValue": "A String", # Value is a string.
            },
          ],
          "projectId": "A String", # Required. The project id which has the Pub/Sub topic.
          "topicId": "A String", # Required. The topic id of the Pub/Sub topic.
        },
        "serviceAccount": "A String", # Optional. Service account needed for runtime plane to trigger IP workflow.
        "type": "A String", # Optional. type of the destination
      },
      "eventTypeId": "A String", # Optional. Event type id of the event of current EventSubscription.
      "jms": { # JMS message denotes the source of the event # Optional. JMS is the source for the event listener.
        "name": "A String", # Optional. Name of the JMS source. i.e. queueName or topicName
        "type": "A String", # Optional. Type of the JMS Source. i.e. Queue or Topic
      },
      "name": "A String", # Required. Identifier. Resource name of the EventSubscription. Format: projects/{project}/locations/{location}/connections/{connection}/eventSubscriptions/{event_subscription}
      "status": { # EventSubscription Status denotes the status of the EventSubscription resource. # Optional. Status indicates the status of the event subscription resource
        "description": "A String", # Output only. Description of the state.
        "state": "A String", # Output only. State of Event Subscription resource.
      },
      "subscriber": "A String", # Optional. name of the Subscriber for the current EventSubscription.
      "subscriberLink": "A String", # Optional. Link for Subscriber of the current EventSubscription.
      "triggerConfigVariables": [ # Optional. Configuration for configuring the trigger
        { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
          "boolValue": True or False, # Value is a bool.
          "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
            "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
            "type": "A String", # Type.
          },
          "intValue": "A String", # Value is an integer
          "key": "A String", # Optional. Key of the config variable.
          "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
            "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
          },
          "stringValue": "A String", # Value is a string.
        },
      ],
      "updateTime": "A String", # Output only. Updated time.
    }

      eventSubscriptionId: string, Required. Identifier to assign to the Event Subscription. Must be unique within scope of the parent resource.
      x__xgafv: string, V1 error format.
        Allowed values
          1 - v1 error format
          2 - v2 error format

    Returns:
      An object of the form:

        { # This resource represents a long-running operation that is the result of a network API call.
      "done": True or False, # If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
      "error": { # The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
        "code": 42, # The status code, which should be an enum value of google.rpc.Code.
        "details": [ # A list of messages that carry the error details. There is a common set of message types for APIs to use.
          {
            "a_key": "", # Properties of the object. Contains field @type with type URL.
          },
        ],
        "message": "A String", # A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client.
      },
      "metadata": { # Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
      "name": "A String", # The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{unique_id}`.
      "response": { # The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
    }

`delete(name, x__xgafv=None)`

    Deletes a single EventSubscription.

    Args:
      name: string, Required. Resource name of the form: `projects/*/locations/*/connections/*/eventsubscriptions/*` (required)
      x__xgafv: string, V1 error format.
        Allowed values
          1 - v1 error format
          2 - v2 error format

    Returns:
      An object of the form:

        { # This resource represents a long-running operation that is the result of a network API call.
      "done": True or False, # If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
      "error": { # The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
        "code": 42, # The status code, which should be an enum value of google.rpc.Code.
        "details": [ # A list of messages that carry the error details. There is a common set of message types for APIs to use.
          {
            "a_key": "", # Properties of the object. Contains field @type with type URL.
          },
        ],
        "message": "A String", # A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client.
      },
      "metadata": { # Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
      "name": "A String", # The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{unique_id}`.
      "response": { # The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
    }

`get(name, x__xgafv=None)`

    Gets details of a single EventSubscription.

    Args:
      name: string, Required. Resource name of the form: `projects/*/locations/*/connections/*/eventSubscriptions/*` (required)
      x__xgafv: string, V1 error format.
        Allowed values
          1 - v1 error format
          2 - v2 error format

    Returns:
      An object of the form:

        { # represents the Connector's EventSubscription resource
      "createTime": "A String", # Output only. Created time.
      "destinations": { # Message for EventSubscription Destination to act on receiving an event # Optional. The destination to hit when we receive an event
        "endpoint": { # Endpoint message includes details of the Destination endpoint. # OPTION 1: Hit an endpoint when we receive an event.
          "endpointUri": "A String", # Optional. The URI of the Endpoint.
          "headers": [ # Optional. List of Header to be added to the Endpoint.
            { # Header details for a given header to be added to Endpoint.
              "key": "A String", # Optional. Key of Header.
              "value": "A String", # Optional. Value of Header.
            },
          ],
        },
        "pubsub": { # Pub/Sub message includes details of the Destination Pub/Sub topic. # OPTION 3: Write the event to Pub/Sub topic.
          "attributes": { # Optional. Pub/Sub message attributes to be added to the Pub/Sub message.
            "a_key": "A String",
          },
          "configVariables": [ # Optional. Configuration for configuring the trigger
            { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
              "boolValue": True or False, # Value is a bool.
              "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
                "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
                "type": "A String", # Type.
              },
              "intValue": "A String", # Value is an integer
              "key": "A String", # Optional. Key of the config variable.
              "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
                "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
              },
              "stringValue": "A String", # Value is a string.
            },
          ],
          "projectId": "A String", # Required. The project id which has the Pub/Sub topic.
          "topicId": "A String", # Required. The topic id of the Pub/Sub topic.
        },
        "serviceAccount": "A String", # Optional. Service account needed for runtime plane to trigger IP workflow.
        "type": "A String", # Optional. type of the destination
      },
      "eventTypeId": "A String", # Optional. Event type id of the event of current EventSubscription.
      "jms": { # JMS message denotes the source of the event # Optional. JMS is the source for the event listener.
        "name": "A String", # Optional. Name of the JMS source. i.e. queueName or topicName
        "type": "A String", # Optional. Type of the JMS Source. i.e. Queue or Topic
      },
      "name": "A String", # Required. Identifier. Resource name of the EventSubscription. Format: projects/{project}/locations/{location}/connections/{connection}/eventSubscriptions/{event_subscription}
      "status": { # EventSubscription Status denotes the status of the EventSubscription resource. # Optional. Status indicates the status of the event subscription resource
        "description": "A String", # Output only. Description of the state.
        "state": "A String", # Output only. State of Event Subscription resource.
      },
      "subscriber": "A String", # Optional. name of the Subscriber for the current EventSubscription.
      "subscriberLink": "A String", # Optional. Link for Subscriber of the current EventSubscription.
      "triggerConfigVariables": [ # Optional. Configuration for configuring the trigger
        { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
          "boolValue": True or False, # Value is a bool.
          "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
            "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
            "type": "A String", # Type.
          },
          "intValue": "A String", # Value is an integer
          "key": "A String", # Optional. Key of the config variable.
          "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
            "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
          },
          "stringValue": "A String", # Value is a string.
        },
      ],
      "updateTime": "A String", # Output only. Updated time.
    }

`list(parent, filter=None, orderBy=None, pageSize=None, pageToken=None, x__xgafv=None)`

    List EventSubscriptions in a given project,location and connection.

    Args:
      parent: string, Required. Parent resource of the EventSubscription, of the form: `projects/*/locations/*/connections/*` (required)
      filter: string, Filter.
      orderBy: string, Order by parameters.
      pageSize: integer, Page size.
      pageToken: string, Page token.
      x__xgafv: string, V1 error format.
        Allowed values
          1 - v1 error format
          2 - v2 error format

    Returns:
      An object of the form:

        { # Response message for ConnectorsService.ListEventSubscriptions
      "eventSubscriptions": [ # Subscriptions.
        { # represents the Connector's EventSubscription resource
          "createTime": "A String", # Output only. Created time.
          "destinations": { # Message for EventSubscription Destination to act on receiving an event # Optional. The destination to hit when we receive an event
            "endpoint": { # Endpoint message includes details of the Destination endpoint. # OPTION 1: Hit an endpoint when we receive an event.
              "endpointUri": "A String", # Optional. The URI of the Endpoint.
              "headers": [ # Optional. List of Header to be added to the Endpoint.
                { # Header details for a given header to be added to Endpoint.
                  "key": "A String", # Optional. Key of Header.
                  "value": "A String", # Optional. Value of Header.
                },
              ],
            },
            "pubsub": { # Pub/Sub message includes details of the Destination Pub/Sub topic. # OPTION 3: Write the event to Pub/Sub topic.
              "attributes": { # Optional. Pub/Sub message attributes to be added to the Pub/Sub message.
                "a_key": "A String",
              },
              "configVariables": [ # Optional. Configuration for configuring the trigger
                { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
                  "boolValue": True or False, # Value is a bool.
                  "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
                    "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
                    "type": "A String", # Type.
                  },
                  "intValue": "A String", # Value is an integer
                  "key": "A String", # Optional. Key of the config variable.
                  "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
                    "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
                  },
                  "stringValue": "A String", # Value is a string.
                },
              ],
              "projectId": "A String", # Required. The project id which has the Pub/Sub topic.
              "topicId": "A String", # Required. The topic id of the Pub/Sub topic.
            },
            "serviceAccount": "A String", # Optional. Service account needed for runtime plane to trigger IP workflow.
            "type": "A String", # Optional. type of the destination
          },
          "eventTypeId": "A String", # Optional. Event type id of the event of current EventSubscription.
          "jms": { # JMS message denotes the source of the event # Optional. JMS is the source for the event listener.
            "name": "A String", # Optional. Name of the JMS source. i.e. queueName or topicName
            "type": "A String", # Optional. Type of the JMS Source. i.e. Queue or Topic
          },
          "name": "A String", # Required. Identifier. Resource name of the EventSubscription. Format: projects/{project}/locations/{location}/connections/{connection}/eventSubscriptions/{event_subscription}
          "status": { # EventSubscription Status denotes the status of the EventSubscription resource. # Optional. Status indicates the status of the event subscription resource
            "description": "A String", # Output only. Description of the state.
            "state": "A String", # Output only. State of Event Subscription resource.
          },
          "subscriber": "A String", # Optional. name of the Subscriber for the current EventSubscription.
          "subscriberLink": "A String", # Optional. Link for Subscriber of the current EventSubscription.
          "triggerConfigVariables": [ # Optional. Configuration for configuring the trigger
            { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
              "boolValue": True or False, # Value is a bool.
              "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
                "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
                "type": "A String", # Type.
              },
              "intValue": "A String", # Value is an integer
              "key": "A String", # Optional. Key of the config variable.
              "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
                "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
              },
              "stringValue": "A String", # Value is a string.
            },
          ],
          "updateTime": "A String", # Output only. Updated time.
        },
      ],
      "nextPageToken": "A String", # Next page token.
      "unreachable": [ # Locations that could not be reached.
        "A String",
      ],
    }

`list_next()`

    Retrieves the next page of results.

            Args:
              previous_request: The request for the previous page. (required)
              previous_response: The response from the request for the previous page. (required)

            Returns:
              A request object that you can call 'execute()' on to request the next
              page. Returns None if there are no more items in the collection.

`patch(name, body=None, updateMask=None, x__xgafv=None)`

    Updates the parameters of a single EventSubscription.

    Args:
      name: string, Required. Identifier. Resource name of the EventSubscription. Format: projects/{project}/locations/{location}/connections/{connection}/eventSubscriptions/{event_subscription} (required)
      body: object, The request body.
        The object takes the form of:

    { # represents the Connector's EventSubscription resource
      "createTime": "A String", # Output only. Created time.
      "destinations": { # Message for EventSubscription Destination to act on receiving an event # Optional. The destination to hit when we receive an event
        "endpoint": { # Endpoint message includes details of the Destination endpoint. # OPTION 1: Hit an endpoint when we receive an event.
          "endpointUri": "A String", # Optional. The URI of the Endpoint.
          "headers": [ # Optional. List of Header to be added to the Endpoint.
            { # Header details for a given header to be added to Endpoint.
              "key": "A String", # Optional. Key of Header.
              "value": "A String", # Optional. Value of Header.
            },
          ],
        },
        "pubsub": { # Pub/Sub message includes details of the Destination Pub/Sub topic. # OPTION 3: Write the event to Pub/Sub topic.
          "attributes": { # Optional. Pub/Sub message attributes to be added to the Pub/Sub message.
            "a_key": "A String",
          },
          "configVariables": [ # Optional. Configuration for configuring the trigger
            { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
              "boolValue": True or False, # Value is a bool.
              "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
                "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
                "type": "A String", # Type.
              },
              "intValue": "A String", # Value is an integer
              "key": "A String", # Optional. Key of the config variable.
              "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
                "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
              },
              "stringValue": "A String", # Value is a string.
            },
          ],
          "projectId": "A String", # Required. The project id which has the Pub/Sub topic.
          "topicId": "A String", # Required. The topic id of the Pub/Sub topic.
        },
        "serviceAccount": "A String", # Optional. Service account needed for runtime plane to trigger IP workflow.
        "type": "A String", # Optional. type of the destination
      },
      "eventTypeId": "A String", # Optional. Event type id of the event of current EventSubscription.
      "jms": { # JMS message denotes the source of the event # Optional. JMS is the source for the event listener.
        "name": "A String", # Optional. Name of the JMS source. i.e. queueName or topicName
        "type": "A String", # Optional. Type of the JMS Source. i.e. Queue or Topic
      },
      "name": "A String", # Required. Identifier. Resource name of the EventSubscription. Format: projects/{project}/locations/{location}/connections/{connection}/eventSubscriptions/{event_subscription}
      "status": { # EventSubscription Status denotes the status of the EventSubscription resource. # Optional. Status indicates the status of the event subscription resource
        "description": "A String", # Output only. Description of the state.
        "state": "A String", # Output only. State of Event Subscription resource.
      },
      "subscriber": "A String", # Optional. name of the Subscriber for the current EventSubscription.
      "subscriberLink": "A String", # Optional. Link for Subscriber of the current EventSubscription.
      "triggerConfigVariables": [ # Optional. Configuration for configuring the trigger
        { # ConfigVariable represents a configuration variable present in a Connection. or AuthConfig.
          "boolValue": True or False, # Value is a bool.
          "encryptionKeyValue": { # Encryption Key value. # Value is a Encryption Key.
            "kmsKeyName": "A String", # Optional. The [KMS key name] with which the content of the Operation is encrypted. The expected format: `projects/*/locations/*/keyRings/*/cryptoKeys/*`. Will be empty string if google managed.
            "type": "A String", # Type.
          },
          "intValue": "A String", # Value is an integer
          "key": "A String", # Optional. Key of the config variable.
          "secretValue": { # Secret provides a reference to entries in Secret Manager. # Value is a secret.
            "secretVersion": "A String", # Optional. The resource name of the secret version in the format, format as: `projects/*/secrets/*/versions/*`.
          },
          "stringValue": "A String", # Value is a string.
        },
      ],
      "updateTime": "A String", # Output only. Updated time.
    }

      updateMask: string, Required. The list of fields to update. Fields are specified relative to the Subscription. A field will be overwritten if it is in the mask. You can modify only the fields listed below. To update the EventSubscription details: * `serviceAccount`
      x__xgafv: string, V1 error format.
        Allowed values
          1 - v1 error format
          2 - v2 error format

    Returns:
      An object of the form:

        { # This resource represents a long-running operation that is the result of a network API call.
      "done": True or False, # If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
      "error": { # The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
        "code": 42, # The status code, which should be an enum value of google.rpc.Code.
        "details": [ # A list of messages that carry the error details. There is a common set of message types for APIs to use.
          {
            "a_key": "", # Properties of the object. Contains field @type with type URL.
          },
        ],
        "message": "A String", # A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client.
      },
      "metadata": { # Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
      "name": "A String", # The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{unique_id}`.
      "response": { # The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
    }

`retry(name, body=None, x__xgafv=None)`

    RetryEventSubscription retries the registration of Subscription.

    Args:
      name: string, Required. Resource name of the form: `projects/*/locations/*/connections/*/eventSubscriptions/*` (required)
      body: object, The request body.
        The object takes the form of:

    { # Request message for ConnectorsService.RefreshEventSubscription
    }

      x__xgafv: string, V1 error format.
        Allowed values
          1 - v1 error format
          2 - v2 error format

    Returns:
      An object of the form:

        { # This resource represents a long-running operation that is the result of a network API call.
      "done": True or False, # If the value is `false`, it means the operation is still in progress. If `true`, the operation is completed, and either `error` or `response` is available.
      "error": { # The `Status` type defines a logical error model that is suitable for different programming environments, including REST APIs and RPC APIs. It is used by [gRPC](https://github.com/grpc). Each `Status` message contains three pieces of data: error code, error message, and error details. You can find out more about this error model and how to work with it in the [API Design Guide](https://cloud.google.com/apis/design/errors). # The error result of the operation in case of failure or cancellation.
        "code": 42, # The status code, which should be an enum value of google.rpc.Code.
        "details": [ # A list of messages that carry the error details. There is a common set of message types for APIs to use.
          {
            "a_key": "", # Properties of the object. Contains field @type with type URL.
          },
        ],
        "message": "A String", # A developer-facing error message, which should be in English. Any user-facing error message should be localized and sent in the google.rpc.Status.details field, or localized by the client.
      },
      "metadata": { # Service-specific metadata associated with the operation. It typically contains progress information and common metadata such as create time. Some services might not provide such metadata. Any method that returns a long-running operation should document the metadata type, if any.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
      "name": "A String", # The server-assigned name, which is only unique within the same service that originally returns it. If you use the default HTTP mapping, the `name` should be a resource name ending with `operations/{unique_id}`.
      "response": { # The normal, successful response of the operation. If the original method returns no data on success, such as `Delete`, the response is `google.protobuf.Empty`. If the original method is standard `Get`/`Create`/`Update`, the response should be the resource. For other methods, the response should have the type `XxxResponse`, where `Xxx` is the original method name. For example, if the original method name is `TakeSnapshot()`, the inferred response type is `TakeSnapshotResponse`.
        "a_key": "", # Properties of the object. Contains field @type with type URL.
      },
    }