feat(pubsublite): update the API

#### pubsublite:v1 The following keys were added: - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.description - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.flatPath - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.httpMethod - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.id - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.parameterOrder - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.parameters.subscription.description - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.parameters.subscription.location - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.parameters.subscription.pattern - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.parameters.subscription.required - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.parameters.subscription.type - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.path - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.request.$ref - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.response.$ref - resources.cursor.resources.projects.resources.locations.resources.subscriptions.methods.commitCursor.scopes - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.description - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.flatPath - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.httpMethod - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.id - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.parameterOrder - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.parameters.topic.description - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.parameters.topic.location - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.parameters.topic.pattern - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.parameters.topic.required - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.parameters.topic.type - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.path - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.request.$ref - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.response.$ref - resources.topicStats.resources.projects.resources.locations.resources.topics.methods.computeTimeCursor.scopes - schemas.CommitCursorRequest.description - schemas.CommitCursorRequest.id - schemas.CommitCursorRequest.properties.cursor.$ref - schemas.CommitCursorRequest.properties.cursor.description - schemas.CommitCursorRequest.properties.partition.description - schemas.CommitCursorRequest.properties.partition.format - schemas.CommitCursorRequest.properties.partition.type - schemas.CommitCursorRequest.type - schemas.CommitCursorResponse.description - schemas.CommitCursorResponse.id - schemas.CommitCursorResponse.type - schemas.ComputeTimeCursorRequest.description - schemas.ComputeTimeCursorRequest.id - schemas.ComputeTimeCursorRequest.properties.partition.description - schemas.ComputeTimeCursorRequest.properties.partition.format - schemas.ComputeTimeCursorRequest.properties.partition.type - schemas.ComputeTimeCursorRequest.properties.target.$ref - schemas.ComputeTimeCursorRequest.properties.target.description - schemas.ComputeTimeCursorRequest.type - schemas.ComputeTimeCursorResponse.description - schemas.ComputeTimeCursorResponse.id - schemas.ComputeTimeCursorResponse.properties.cursor.$ref - schemas.ComputeTimeCursorResponse.properties.cursor.description - schemas.ComputeTimeCursorResponse.type - schemas.TimeTarget.description - schemas.TimeTarget.id - schemas.TimeTarget.properties.eventTime.description - schemas.TimeTarget.properties.eventTime.format - schemas.TimeTarget.properties.eventTime.type - schemas.TimeTarget.properties.publishTime.description - schemas.TimeTarget.properties.publishTime.format - schemas.TimeTarget.properties.publishTime.type - schemas.TimeTarget.type
googleapis · May 21, 2021 · 1ec199f · 1ec199f
1 parent 1572543
commit 1ec199f
Show file tree

Hide file tree

Showing 2 changed files with 537 additions and 39 deletions.
diff --git a/discovery/pubsublite-v1.json b/discovery/pubsublite-v1.json
@@ -510,6 +510,36 @@
             "locations": {
               "resources": {
                 "subscriptions": {
+                  "methods": {
+                    "commitCursor": {
+                      "description": "Updates the committed cursor.",
+                      "flatPath": "v1/cursor/projects/{projectsId}/locations/{locationsId}/subscriptions/{subscriptionsId}:commitCursor",
+                      "httpMethod": "POST",
+                      "id": "pubsublite.cursor.projects.locations.subscriptions.commitCursor",
+                      "parameterOrder": [
+                        "subscription"
+                      ],
+                      "parameters": {
+                        "subscription": {
+                          "description": "The subscription for which to update the cursor.",
+                          "location": "path",
+                          "pattern": "^projects/[^/]+/locations/[^/]+/subscriptions/[^/]+$",
+                          "required": true,
+                          "type": "string"
+                        }
+                      },
+                      "path": "v1/cursor/{+subscription}:commitCursor",
+                      "request": {
+                        "$ref": "CommitCursorRequest"
+                      },
+                      "response": {
+                        "$ref": "CommitCursorResponse"
+                      },
+                      "scopes": [
+                        "https://www.googleapis.com/auth/cloud-platform"
+                      ]
+                    }
+                  },
                   "resources": {
                     "cursors": {
                       "methods": {
@@ -622,6 +652,34 @@
                       "scopes": [
                         "https://www.googleapis.com/auth/cloud-platform"
                       ]
+                    },
+                    "computeTimeCursor": {
+                      "description": "Compute the corresponding cursor for a publish or event time in a topic partition.",
+                      "flatPath": "v1/topicStats/projects/{projectsId}/locations/{locationsId}/topics/{topicsId}:computeTimeCursor",
+                      "httpMethod": "POST",
+                      "id": "pubsublite.topicStats.projects.locations.topics.computeTimeCursor",
+                      "parameterOrder": [
+                        "topic"
+                      ],
+                      "parameters": {
+                        "topic": {
+                          "description": "Required. The topic for which we should compute the cursor.",
+                          "location": "path",
+                          "pattern": "^projects/[^/]+/locations/[^/]+/topics/[^/]+$",
+                          "required": true,
+                          "type": "string"
+                        }
+                      },
+                      "path": "v1/topicStats/{+topic}:computeTimeCursor",
+                      "request": {
+                        "$ref": "ComputeTimeCursorRequest"
+                      },
+                      "response": {
+                        "$ref": "ComputeTimeCursorResponse"
+                      },
+                      "scopes": [
+                        "https://www.googleapis.com/auth/cloud-platform"
+                      ]
                     }
                   }
                 }
@@ -632,7 +690,7 @@
       }
     }
   },
-  "revision": "20210322",
+  "revision": "20210513",
   "rootUrl": "https://pubsublite.googleapis.com/",
   "schemas": {
     "Capacity": {
@@ -652,6 +710,28 @@
       },
       "type": "object"
     },
+    "CommitCursorRequest": {
+      "description": "Request for CommitCursor.",
+      "id": "CommitCursorRequest",
+      "properties": {
+        "cursor": {
+          "$ref": "Cursor",
+          "description": "The new value for the committed cursor."
+        },
+        "partition": {
+          "description": "The partition for which to update the cursor. Partitions are zero indexed, so `partition` must be in the range [0, topic.num_partitions).",
+          "format": "int64",
+          "type": "string"
+        }
+      },
+      "type": "object"
+    },
+    "CommitCursorResponse": {
+      "description": "Response for CommitCursor.",
+      "id": "CommitCursorResponse",
+      "properties": {},
+      "type": "object"
+    },
     "ComputeHeadCursorRequest": {
       "description": "Compute the current head cursor for a partition.",
       "id": "ComputeHeadCursorRequest",
@@ -722,6 +802,33 @@
       },
       "type": "object"
     },
+    "ComputeTimeCursorRequest": {
+      "description": "Compute the corresponding cursor for a publish or event time in a topic partition.",
+      "id": "ComputeTimeCursorRequest",
+      "properties": {
+        "partition": {
+          "description": "Required. The partition for which we should compute the cursor.",
+          "format": "int64",
+          "type": "string"
+        },
+        "target": {
+          "$ref": "TimeTarget",
+          "description": "Required. The target publish or event time. Specifying a future time will return an unset cursor."
+        }
+      },
+      "type": "object"
+    },
+    "ComputeTimeCursorResponse": {
+      "description": "Response containing the cursor corresponding to a publish or event time in a topic partition.",
+      "id": "ComputeTimeCursorResponse",
+      "properties": {
+        "cursor": {
+          "$ref": "Cursor",
+          "description": "If present, the cursor references the first message with time greater than or equal to the specified target time. If such a message cannot be found, the cursor will be unset (i.e. `cursor` is not present)."
+        }
+      },
+      "type": "object"
+    },
     "Cursor": {
       "description": "A cursor that describes the position of a message within a topic partition.",
       "id": "Cursor",
@@ -906,6 +1013,23 @@
       },
       "type": "object"
     },
+    "TimeTarget": {
+      "description": "A target publish or event time. Can be used for seeking to or retrieving the corresponding cursor.",
+      "id": "TimeTarget",
+      "properties": {
+        "eventTime": {
+          "description": "Request the cursor of the first message with event time greater than or equal to `event_time`. If messages are missing an event time, the publish time is used as a fallback. As event times are user supplied, subsequent messages may have event times less than `event_time` and should be filtered by the client, if necessary.",
+          "format": "google-datetime",
+          "type": "string"
+        },
+        "publishTime": {
+          "description": "Request the cursor of the first message with publish time greater than or equal to `publish_time`. All messages thereafter are guaranteed to have publish times >= `publish_time`.",
+          "format": "google-datetime",
+          "type": "string"
+        }
+      },
+      "type": "object"
+    },
     "Topic": {
       "description": "Metadata about a topic resource.",
       "id": "Topic",