diff --git a/protos/google/pubsub/v1/pubsub.proto b/protos/google/pubsub/v1/pubsub.proto index 095a37b15..9d79638f8 100644 --- a/protos/google/pubsub/v1/pubsub.proto +++ b/protos/google/pubsub/v1/pubsub.proto @@ -32,7 +32,6 @@ option java_package = "com.google.pubsub.v1"; option php_namespace = "Google\\Cloud\\PubSub\\V1"; option ruby_package = "Google::Cloud::PubSub::V1"; - // The service that an application uses to manipulate topics, and to send // messages to a topic. service Publisher { @@ -79,7 +78,8 @@ service Publisher { } // Lists the names of the subscriptions on this topic. - rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest) returns (ListTopicSubscriptionsResponse) { + rpc ListTopicSubscriptions(ListTopicSubscriptionsRequest) + returns (ListTopicSubscriptionsResponse) { option (google.api.http) = { get: "/v1/{topic=projects/*/topics/*}/subscriptions" }; @@ -94,7 +94,8 @@ service Publisher { // BETA: This feature is part of a beta release. This API might be // changed in backward-incompatible ways and is not recommended for production // use. It is not subject to any SLA or deprecation policy. - rpc ListTopicSnapshots(ListTopicSnapshotsRequest) returns (ListTopicSnapshotsResponse) { + rpc ListTopicSnapshots(ListTopicSnapshotsRequest) + returns (ListTopicSnapshotsResponse) { option (google.api.http) = { get: "/v1/{topic=projects/*/topics/*}/snapshots" }; @@ -125,9 +126,10 @@ service Subscriber { // If the name is not provided in the request, the server will assign a random // name for this subscription on the same project as the topic, conforming // to the - // [resource name format](https://cloud.google.com/pubsub/docs/admin#resource_names). - // The generated name is populated in the returned Subscription object. - // Note that for REST API requests, you must specify a name in the request. + // [resource name + // format](https://cloud.google.com/pubsub/docs/admin#resource_names). The + // generated name is populated in the returned Subscription object. Note that + // for REST API requests, you must specify a name in the request. rpc CreateSubscription(Subscription) returns (Subscription) { option (google.api.http) = { put: "/v1/{name=projects/*/subscriptions/*}" @@ -152,7 +154,8 @@ service Subscriber { } // Lists matching subscriptions. - rpc ListSubscriptions(ListSubscriptionsRequest) returns (ListSubscriptionsResponse) { + rpc ListSubscriptions(ListSubscriptionsRequest) + returns (ListSubscriptionsResponse) { option (google.api.http) = { get: "/v1/{project=projects/*}/subscriptions" }; @@ -163,7 +166,8 @@ service Subscriber { // `NOT_FOUND`. After a subscription is deleted, a new one may be created with // the same name, but the new one has no association with the old // subscription or its topic unless the same topic is specified. - rpc DeleteSubscription(DeleteSubscriptionRequest) returns (google.protobuf.Empty) { + rpc DeleteSubscription(DeleteSubscriptionRequest) + returns (google.protobuf.Empty) { option (google.api.http) = { delete: "/v1/{subscription=projects/*/subscriptions/*}" }; @@ -174,7 +178,8 @@ service Subscriber { // subscriber, or to make the message available for redelivery if the // processing was interrupted. Note that this does not modify the // subscription-level `ackDeadlineSeconds` used for subsequent messages. - rpc ModifyAckDeadline(ModifyAckDeadlineRequest) returns (google.protobuf.Empty) { + rpc ModifyAckDeadline(ModifyAckDeadlineRequest) + returns (google.protobuf.Empty) { option (google.api.http) = { post: "/v1/{subscription=projects/*/subscriptions/*}:modifyAckDeadline" body: "*" @@ -212,8 +217,8 @@ service Subscriber { // reassign server-side resources, in which case, the client should // re-establish the stream. Flow control can be achieved by configuring the // underlying RPC channel. - rpc StreamingPull(stream StreamingPullRequest) returns (stream StreamingPullResponse) { - } + rpc StreamingPull(stream StreamingPullRequest) + returns (stream StreamingPullResponse) {} // Modifies the `PushConfig` for a specified subscription. // @@ -221,7 +226,8 @@ service Subscriber { // an empty `PushConfig`) or vice versa, or change the endpoint URL and other // attributes of a push subscription. Messages will accumulate for delivery // continuously through the call regardless of changes to the `PushConfig`. - rpc ModifyPushConfig(ModifyPushConfigRequest) returns (google.protobuf.Empty) { + rpc ModifyPushConfig(ModifyPushConfigRequest) + returns (google.protobuf.Empty) { option (google.api.http) = { post: "/v1/{subscription=projects/*/subscriptions/*}:modifyPushConfig" body: "*" @@ -275,9 +281,10 @@ service Subscriber { // the request, the server will assign a random // name for this snapshot on the same project as the subscription, conforming // to the - // [resource name format](https://cloud.google.com/pubsub/docs/admin#resource_names). - // The generated name is populated in the returned Snapshot object. Note that - // for REST API requests, you must specify a name in the request. + // [resource name + // format](https://cloud.google.com/pubsub/docs/admin#resource_names). The + // generated name is populated in the returned Snapshot object. Note that for + // REST API requests, you must specify a name in the request. rpc CreateSnapshot(CreateSnapshotRequest) returns (Snapshot) { option (google.api.http) = { put: "/v1/{name=projects/*/snapshots/*}" @@ -576,7 +583,8 @@ message Subscription { // messages are not expunged from the subscription's backlog, even if they are // acknowledged, until they fall out of the `message_retention_duration` // window. This must be true if you would like to - // + // // Seek to a timestamp. //

// BETA: This feature is part of a beta release. This API might be @@ -872,9 +880,9 @@ message StreamingPullResponse { } // Request for the `CreateSnapshot` method.

-// BETA: This feature is part of a beta release. This API might be changed in -// backward-incompatible ways and is not recommended for production use. -// It is not subject to any SLA or deprecation policy. +// BETA: This feature is part of a beta release. This API might be +// changed in backward-incompatible ways and is not recommended for production +// use. It is not subject to any SLA or deprecation policy. message CreateSnapshotRequest { // Optional user-provided name for this snapshot. // If the name is not provided in the request, the server will assign a random @@ -1028,6 +1036,4 @@ message SeekRequest { } // Response for the `Seek` method (this response is empty). -message SeekResponse { - -} +message SeekResponse {} diff --git a/src/v1/doc/google/pubsub/v1/doc_pubsub.js b/src/v1/doc/google/pubsub/v1/doc_pubsub.js index c30756dd9..938a76bbe 100644 --- a/src/v1/doc/google/pubsub/v1/doc_pubsub.js +++ b/src/v1/doc/google/pubsub/v1/doc_pubsub.js @@ -378,7 +378,8 @@ const DeleteTopicRequest = { * messages are not expunged from the subscription's backlog, even if they are * acknowledged, until they fall out of the `message_retention_duration` * window. This must be true if you would like to - * + * * Seek to a timestamp. *

* BETA: This feature is part of a beta release. This API might be @@ -820,9 +821,9 @@ const StreamingPullResponse = { /** * Request for the `CreateSnapshot` method.

- * BETA: This feature is part of a beta release. This API might be changed in - * backward-incompatible ways and is not recommended for production use. - * It is not subject to any SLA or deprecation policy. + * BETA: This feature is part of a beta release. This API might be + * changed in backward-incompatible ways and is not recommended for production + * use. It is not subject to any SLA or deprecation policy. * * @property {string} name * Optional user-provided name for this snapshot. diff --git a/src/v1/subscriber_client.js b/src/v1/subscriber_client.js index 597a9c0f9..e826a5c4e 100644 --- a/src/v1/subscriber_client.js +++ b/src/v1/subscriber_client.js @@ -291,9 +291,10 @@ class SubscriberClient { * If the name is not provided in the request, the server will assign a random * name for this subscription on the same project as the topic, conforming * to the - * [resource name format](https://cloud.google.com/pubsub/docs/admin#resource_names). - * The generated name is populated in the returned Subscription object. - * Note that for REST API requests, you must specify a name in the request. + * [resource name + * format](https://cloud.google.com/pubsub/docs/admin#resource_names). The + * generated name is populated in the returned Subscription object. Note that + * for REST API requests, you must specify a name in the request. * * @param {Object} request * The request object that will be sent. @@ -341,7 +342,8 @@ class SubscriberClient { * messages are not expunged from the subscription's backlog, even if they are * acknowledged, until they fall out of the `message_retention_duration` * window. This must be true if you would like to - * + * * Seek to a timestamp. *

* BETA: This feature is part of a beta release. This API might be @@ -1180,9 +1182,10 @@ class SubscriberClient { * the request, the server will assign a random * name for this snapshot on the same project as the subscription, conforming * to the - * [resource name format](https://cloud.google.com/pubsub/docs/admin#resource_names). - * The generated name is populated in the returned Snapshot object. Note that - * for REST API requests, you must specify a name in the request. + * [resource name + * format](https://cloud.google.com/pubsub/docs/admin#resource_names). The + * generated name is populated in the returned Snapshot object. Note that for + * REST API requests, you must specify a name in the request. * * @param {Object} request * The request object that will be sent. diff --git a/synth.metadata b/synth.metadata index 5993b9c77..957eb402b 100644 --- a/synth.metadata +++ b/synth.metadata @@ -1,5 +1,5 @@ { - "updateTime": "2019-02-28T12:18:55.555938Z", + "updateTime": "2019-03-01T12:18:24.808590Z", "sources": [ { "generator": { @@ -12,8 +12,8 @@ "git": { "name": "googleapis", "remote": "https://github.com/googleapis/googleapis.git", - "sha": "9c769d3a0e67e4df9b9e8eee480124c2700a7e6c", - "internalRef": "235997788" + "sha": "41d72d444fbe445f4da89e13be02078734fb7875", + "internalRef": "236230004" } }, {