all: regen gapics
Re-pins to latest genproto to include relevant protos. This prompted a
re-pin of gRPC to 1.19.0 (since genproto depends on it).
Change-Id: I3585f1e26ff5681318dcd45444195827cbe91db3
Reviewed-on: https://code-review.googlesource.com/c/gocloud/+/38750
Reviewed-by: kokoro <noreply+kokoro@google.com>
Reviewed-by: Chris Broadfoot <cbro@google.com>
diff --git a/asset/apiv1beta1/asset_client.go b/asset/apiv1beta1/asset_client.go
index fd2e0a9..02f423f 100644
--- a/asset/apiv1beta1/asset_client.go
+++ b/asset/apiv1beta1/asset_client.go
@@ -139,8 +139,9 @@
// ExportAssets exports assets with time and resource types to a given Cloud Storage
// location. The output format is newline-delimited JSON.
-// This API implements the [google.longrunning.Operation][google.longrunning.Operation] API allowing you
-// to keep track of the export.
+// This API implements the
+// [google.longrunning.Operation][google.longrunning.Operation] API allowing
+// you to keep track of the export.
func (c *Client) ExportAssets(ctx context.Context, req *assetpb.ExportAssetsRequest, opts ...gax.CallOption) (*ExportAssetsOperation, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ExportAssets[0:len(c.CallOptions.ExportAssets):len(c.CallOptions.ExportAssets)], opts...)
diff --git a/asset/apiv1beta1/doc.go b/asset/apiv1beta1/doc.go
index fdbb8f4..42a494c 100644
--- a/asset/apiv1beta1/doc.go
+++ b/asset/apiv1beta1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/bigquery/datatransfer/apiv1/data_transfer_client.go b/bigquery/datatransfer/apiv1/data_transfer_client.go
index a214706..4373fb2 100644
--- a/bigquery/datatransfer/apiv1/data_transfer_client.go
+++ b/bigquery/datatransfer/apiv1/data_transfer_client.go
@@ -109,9 +109,9 @@
// NewClient creates a new data transfer service client.
//
// The Google BigQuery Data Transfer Service API enables BigQuery users to
-// configure the transfer of their data from other Google Products into BigQuery.
-// This service contains methods that are end user exposed. It backs up the
-// frontend.
+// configure the transfer of their data from other Google Products into
+// BigQuery. This service contains methods that are end user exposed. It backs
+// up the frontend.
func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error) {
conn, err := transport.DialGRPC(ctx, append(defaultClientOptions(), opts...)...)
if err != nil {
diff --git a/bigquery/datatransfer/apiv1/doc.go b/bigquery/datatransfer/apiv1/doc.go
index ca106dc..45e7451 100644
--- a/bigquery/datatransfer/apiv1/doc.go
+++ b/bigquery/datatransfer/apiv1/doc.go
@@ -87,4 +87,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/bigquery/storage/apiv1beta1/doc.go b/bigquery/storage/apiv1beta1/doc.go
index d39966f..92cee30 100644
--- a/bigquery/storage/apiv1beta1/doc.go
+++ b/bigquery/storage/apiv1beta1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/cloudtasks/apiv2beta2/cloud_tasks_client.go b/cloudtasks/apiv2beta2/cloud_tasks_client.go
index a97ddd9..1ea0e84 100644
--- a/cloudtasks/apiv2beta2/cloud_tasks_client.go
+++ b/cloudtasks/apiv2beta2/cloud_tasks_client.go
@@ -220,14 +220,15 @@
// CreateQueue creates a queue.
//
// Queues created with this method allow tasks to live for a maximum of 31
-// days. After a task is 31 days old, the task will be deleted regardless of whether
-// it was dispatched or not.
+// days. After a task is 31 days old, the task will be deleted regardless of
+// whether it was dispatched or not.
//
// WARNING: Using this method may have unintended side effects if you are
// using an App Engine queue.yaml or queue.xml file to manage your queues.
// Read
-// Overview of Queue Management and queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml)
-// before using this method.
+// Overview of Queue Management and
+// queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml) before using
+// this method.
func (c *Client) CreateQueue(ctx context.Context, req *taskspb.CreateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", req.GetParent()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -250,14 +251,15 @@
// the queue if it does exist.
//
// Queues created with this method allow tasks to live for a maximum of 31
-// days. After a task is 31 days old, the task will be deleted regardless of whether
-// it was dispatched or not.
+// days. After a task is 31 days old, the task will be deleted regardless of
+// whether it was dispatched or not.
//
// WARNING: Using this method may have unintended side effects if you are
// using an App Engine queue.yaml or queue.xml file to manage your queues.
// Read
-// Overview of Queue Management and queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml)
-// before using this method.
+// Overview of Queue Management and
+// queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml) before using
+// this method.
func (c *Client) UpdateQueue(ctx context.Context, req *taskspb.UpdateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "queue.name", req.GetQueue().GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -284,8 +286,9 @@
// WARNING: Using this method may have unintended side effects if you are
// using an App Engine queue.yaml or queue.xml file to manage your queues.
// Read
-// Overview of Queue Management and queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml)
-// before using this method.
+// Overview of Queue Management and
+// queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml) before using
+// this method.
func (c *Client) DeleteQueue(ctx context.Context, req *taskspb.DeleteQueueRequest, opts ...gax.CallOption) error {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -324,9 +327,10 @@
//
// If a queue is paused then the system will stop dispatching tasks
// until the queue is resumed via
-// [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can still be added
-// when the queue is paused. A queue is paused if its
-// [state][google.cloud.tasks.v2beta2.Queue.state] is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+// [ResumeQueue][google.cloud.tasks.v2beta2.CloudTasks.ResumeQueue]. Tasks can
+// still be added when the queue is paused. A queue is paused if its
+// [state][google.cloud.tasks.v2beta2.Queue.state] is
+// [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
func (c *Client) PauseQueue(ctx context.Context, req *taskspb.PauseQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -347,14 +351,17 @@
//
// This method resumes a queue after it has been
// [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED] or
-// [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a queue is stored
-// in the queue's [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method it
-// will be set to [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
+// [DISABLED][google.cloud.tasks.v2beta2.Queue.State.DISABLED]. The state of a
+// queue is stored in the queue's
+// [state][google.cloud.tasks.v2beta2.Queue.state]; after calling this method
+// it will be set to
+// [RUNNING][google.cloud.tasks.v2beta2.Queue.State.RUNNING].
//
// WARNING: Resuming many high-QPS queues at the same time can
// lead to target overloading. If you are resuming high-QPS
// queues, follow the 500/50/5 pattern described in
-// Managing Cloud Tasks Scaling Risks (at https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
+// Managing Cloud Tasks Scaling
+// Risks (at https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
func (c *Client) ResumeQueue(ctx context.Context, req *taskspb.ResumeQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -371,9 +378,9 @@
return resp, nil
}
-// GetIamPolicy gets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue].
-// Returns an empty policy if the resource exists and does not have a policy
-// set.
+// GetIamPolicy gets the access control policy for a
+// [Queue][google.cloud.tasks.v2beta2.Queue]. Returns an empty policy if the
+// resource exists and does not have a policy set.
//
// Authorization requires the following
// Google IAM (at https://cloud.google.com/iam) permission on the specified
@@ -396,8 +403,8 @@
return resp, nil
}
-// SetIamPolicy sets the access control policy for a [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing
-// policy.
+// SetIamPolicy sets the access control policy for a
+// [Queue][google.cloud.tasks.v2beta2.Queue]. Replaces any existing policy.
//
// Note: The Cloud Console does not check queue-level IAM permissions yet.
// Project-level permissions are required to use the Cloud Console.
@@ -423,9 +430,10 @@
return resp, nil
}
-// TestIamPermissions returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta2.Queue].
-// If the resource does not exist, this will return an empty set of
-// permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+// TestIamPermissions returns permissions that a caller has on a
+// [Queue][google.cloud.tasks.v2beta2.Queue]. If the resource does not exist,
+// this will return an empty set of permissions, not a
+// [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
//
// Note: This operation is designed to be used for building permission-aware
// UIs and command-line tools, not for authorization checking. This operation
@@ -448,10 +456,10 @@
// ListTasks lists the tasks in a queue.
//
-// By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC] view is retrieved
-// due to performance considerations;
-// [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view] controls the
-// subset of information which is returned.
+// By default, only the [BASIC][google.cloud.tasks.v2beta2.Task.View.BASIC]
+// view is retrieved due to performance considerations;
+// [response_view][google.cloud.tasks.v2beta2.ListTasksRequest.response_view]
+// controls the subset of information which is returned.
//
// The tasks may be returned in any order. The ordering may change at any
// time.
@@ -513,10 +521,12 @@
//
// Tasks cannot be updated after creation; there is no UpdateTask command.
//
-// For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget], the maximum task size is
+// For [App Engine queues][google.cloud.tasks.v2beta2.AppEngineHttpTarget],
+// the maximum task size is
// 100KB.
//
-// For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum task size is 1MB.
+// For [pull queues][google.cloud.tasks.v2beta2.PullTarget], the maximum
+// task size is 1MB.
func (c *Client) CreateTask(ctx context.Context, req *taskspb.CreateTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", req.GetParent()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -555,18 +565,19 @@
//
// This method is invoked by the worker to obtain a lease. The
// worker must acknowledge the task via
-// [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask] after they have
-// performed the work associated with the task.
+// [AcknowledgeTask][google.cloud.tasks.v2beta2.CloudTasks.AcknowledgeTask]
+// after they have performed the work associated with the task.
//
-// The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended to store data that
-// the worker needs to perform the work associated with the task. To
-// return the payloads in the [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
-// [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view] to
-// [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
+// The [payload][google.cloud.tasks.v2beta2.PullMessage.payload] is intended
+// to store data that the worker needs to perform the work associated with the
+// task. To return the payloads in the
+// [response][google.cloud.tasks.v2beta2.LeaseTasksResponse], set
+// [response_view][google.cloud.tasks.v2beta2.LeaseTasksRequest.response_view]
+// to [FULL][google.cloud.tasks.v2beta2.Task.View.FULL].
//
-// A maximum of 10 qps of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks]
-// requests are allowed per
-// queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
+// A maximum of 10 qps of
+// [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] requests are
+// allowed per queue. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
// is returned when this limit is
// exceeded. [RESOURCE_EXHAUSTED][google.rpc.Code.RESOURCE_EXHAUSTED]
// is also returned when
@@ -591,12 +602,13 @@
// AcknowledgeTask acknowledges a pull task.
//
// The worker, that is, the entity that
-// [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must call this method
-// to indicate that the work associated with the task has finished.
+// [leased][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks] this task must
+// call this method to indicate that the work associated with the task has
+// finished.
//
// The worker must acknowledge a task within the
-// [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration] or the lease
-// will expire and the task will become available to be leased
+// [lease_duration][google.cloud.tasks.v2beta2.LeaseTasksRequest.lease_duration]
+// or the lease will expire and the task will become available to be leased
// again. After the task is acknowledged, it will not be returned
// by a later [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks],
// [GetTask][google.cloud.tasks.v2beta2.CloudTasks.GetTask], or
@@ -617,7 +629,8 @@
//
// The worker can use this method to extend the lease by a new
// duration, starting from now. The new task lease will be
-// returned in the task's [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
+// returned in the task's
+// [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time].
func (c *Client) RenewLease(ctx context.Context, req *taskspb.RenewLeaseRequest, opts ...gax.CallOption) (*taskspb.Task, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -637,9 +650,9 @@
// CancelLease cancel a pull task's lease.
//
// The worker can use this method to cancel a task's lease by
-// setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] to now. This will
-// make the task available to be leased to the next caller of
-// [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
+// setting its [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time]
+// to now. This will make the task available to be leased to the next caller
+// of [LeaseTasks][google.cloud.tasks.v2beta2.CloudTasks.LeaseTasks].
func (c *Client) CancelLease(ctx context.Context, req *taskspb.CancelLeaseRequest, opts ...gax.CallOption) (*taskspb.Task, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -659,30 +672,33 @@
// RunTask forces a task to run now.
//
// When this method is called, Cloud Tasks will dispatch the task, even if
-// the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or
-// is [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
+// the task is already running, the queue has reached its
+// [RateLimits][google.cloud.tasks.v2beta2.RateLimits] or is
+// [PAUSED][google.cloud.tasks.v2beta2.Queue.State.PAUSED].
//
// This command is meant to be used for manual debugging. For
-// example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be used to retry a failed
-// task after a fix has been made or to manually force a task to be
-// dispatched now.
+// example, [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] can be
+// used to retry a failed task after a fix has been made or to manually force
+// a task to be dispatched now.
//
// The dispatched task is returned. That is, the task that is returned
-// contains the [status][google.cloud.tasks.v2beta2.Task.status] after the task is dispatched but
-// before the task is received by its target.
+// contains the [status][google.cloud.tasks.v2beta2.Task.status] after the
+// task is dispatched but before the task is received by its target.
//
// If Cloud Tasks receives a successful response from the task's
// target, then the task will be deleted; otherwise the task's
-// [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be reset to the time that
-// [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus the retry delay specified
-// in the queue's [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
+// [schedule_time][google.cloud.tasks.v2beta2.Task.schedule_time] will be
+// reset to the time that
+// [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] was called plus
+// the retry delay specified in the queue's
+// [RetryConfig][google.cloud.tasks.v2beta2.RetryConfig].
//
// [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] returns
// [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
// task that has already succeeded or permanently failed.
//
-// [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called on a
-// [pull task][google.cloud.tasks.v2beta2.PullMessage].
+// [RunTask][google.cloud.tasks.v2beta2.CloudTasks.RunTask] cannot be called
+// on a [pull task][google.cloud.tasks.v2beta2.PullMessage].
func (c *Client) RunTask(ctx context.Context, req *taskspb.RunTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
diff --git a/cloudtasks/apiv2beta2/doc.go b/cloudtasks/apiv2beta2/doc.go
index 33c8f0e..19f2e67 100644
--- a/cloudtasks/apiv2beta2/doc.go
+++ b/cloudtasks/apiv2beta2/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/cloudtasks/apiv2beta3/cloud_tasks_client.go b/cloudtasks/apiv2beta3/cloud_tasks_client.go
index 72d97b2..1d6f45c 100644
--- a/cloudtasks/apiv2beta3/cloud_tasks_client.go
+++ b/cloudtasks/apiv2beta3/cloud_tasks_client.go
@@ -212,14 +212,15 @@
// CreateQueue creates a queue.
//
// Queues created with this method allow tasks to live for a maximum of 31
-// days. After a task is 31 days old, the task will be deleted regardless of whether
-// it was dispatched or not.
+// days. After a task is 31 days old, the task will be deleted regardless of
+// whether it was dispatched or not.
//
// WARNING: Using this method may have unintended side effects if you are
// using an App Engine queue.yaml or queue.xml file to manage your queues.
// Read
-// Overview of Queue Management and queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml)
-// before using this method.
+// Overview of Queue Management and
+// queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml) before using
+// this method.
func (c *Client) CreateQueue(ctx context.Context, req *taskspb.CreateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", req.GetParent()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -242,14 +243,15 @@
// the queue if it does exist.
//
// Queues created with this method allow tasks to live for a maximum of 31
-// days. After a task is 31 days old, the task will be deleted regardless of whether
-// it was dispatched or not.
+// days. After a task is 31 days old, the task will be deleted regardless of
+// whether it was dispatched or not.
//
// WARNING: Using this method may have unintended side effects if you are
// using an App Engine queue.yaml or queue.xml file to manage your queues.
// Read
-// Overview of Queue Management and queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml)
-// before using this method.
+// Overview of Queue Management and
+// queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml) before using
+// this method.
func (c *Client) UpdateQueue(ctx context.Context, req *taskspb.UpdateQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "queue.name", req.GetQueue().GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -276,8 +278,9 @@
// WARNING: Using this method may have unintended side effects if you are
// using an App Engine queue.yaml or queue.xml file to manage your queues.
// Read
-// Overview of Queue Management and queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml)
-// before using this method.
+// Overview of Queue Management and
+// queue.yaml (at https://cloud.google.com/tasks/docs/queue-yaml) before using
+// this method.
func (c *Client) DeleteQueue(ctx context.Context, req *taskspb.DeleteQueueRequest, opts ...gax.CallOption) error {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -316,9 +319,10 @@
//
// If a queue is paused then the system will stop dispatching tasks
// until the queue is resumed via
-// [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. Tasks can still be added
-// when the queue is paused. A queue is paused if its
-// [state][google.cloud.tasks.v2beta3.Queue.state] is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
+// [ResumeQueue][google.cloud.tasks.v2beta3.CloudTasks.ResumeQueue]. Tasks can
+// still be added when the queue is paused. A queue is paused if its
+// [state][google.cloud.tasks.v2beta3.Queue.state] is
+// [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
func (c *Client) PauseQueue(ctx context.Context, req *taskspb.PauseQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -339,14 +343,17 @@
//
// This method resumes a queue after it has been
// [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED] or
-// [DISABLED][google.cloud.tasks.v2beta3.Queue.State.DISABLED]. The state of a queue is stored
-// in the queue's [state][google.cloud.tasks.v2beta3.Queue.state]; after calling this method it
-// will be set to [RUNNING][google.cloud.tasks.v2beta3.Queue.State.RUNNING].
+// [DISABLED][google.cloud.tasks.v2beta3.Queue.State.DISABLED]. The state of a
+// queue is stored in the queue's
+// [state][google.cloud.tasks.v2beta3.Queue.state]; after calling this method
+// it will be set to
+// [RUNNING][google.cloud.tasks.v2beta3.Queue.State.RUNNING].
//
// WARNING: Resuming many high-QPS queues at the same time can
// lead to target overloading. If you are resuming high-QPS
// queues, follow the 500/50/5 pattern described in
-// Managing Cloud Tasks Scaling Risks (at https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
+// Managing Cloud Tasks Scaling
+// Risks (at https://cloud.google.com/tasks/docs/manage-cloud-task-scaling).
func (c *Client) ResumeQueue(ctx context.Context, req *taskspb.ResumeQueueRequest, opts ...gax.CallOption) (*taskspb.Queue, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -363,9 +370,9 @@
return resp, nil
}
-// GetIamPolicy gets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue].
-// Returns an empty policy if the resource exists and does not have a policy
-// set.
+// GetIamPolicy gets the access control policy for a
+// [Queue][google.cloud.tasks.v2beta3.Queue]. Returns an empty policy if the
+// resource exists and does not have a policy set.
//
// Authorization requires the following
// Google IAM (at https://cloud.google.com/iam) permission on the specified
@@ -388,8 +395,8 @@
return resp, nil
}
-// SetIamPolicy sets the access control policy for a [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing
-// policy.
+// SetIamPolicy sets the access control policy for a
+// [Queue][google.cloud.tasks.v2beta3.Queue]. Replaces any existing policy.
//
// Note: The Cloud Console does not check queue-level IAM permissions yet.
// Project-level permissions are required to use the Cloud Console.
@@ -415,9 +422,10 @@
return resp, nil
}
-// TestIamPermissions returns permissions that a caller has on a [Queue][google.cloud.tasks.v2beta3.Queue].
-// If the resource does not exist, this will return an empty set of
-// permissions, not a [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
+// TestIamPermissions returns permissions that a caller has on a
+// [Queue][google.cloud.tasks.v2beta3.Queue]. If the resource does not exist,
+// this will return an empty set of permissions, not a
+// [NOT_FOUND][google.rpc.Code.NOT_FOUND] error.
//
// Note: This operation is designed to be used for building permission-aware
// UIs and command-line tools, not for authorization checking. This operation
@@ -440,10 +448,10 @@
// ListTasks lists the tasks in a queue.
//
-// By default, only the [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC] view is retrieved
-// due to performance considerations;
-// [response_view][google.cloud.tasks.v2beta3.ListTasksRequest.response_view] controls the
-// subset of information which is returned.
+// By default, only the [BASIC][google.cloud.tasks.v2beta3.Task.View.BASIC]
+// view is retrieved due to performance considerations;
+// [response_view][google.cloud.tasks.v2beta3.ListTasksRequest.response_view]
+// controls the subset of information which is returned.
//
// The tasks may be returned in any order. The ordering may change at any
// time.
@@ -505,7 +513,8 @@
//
// Tasks cannot be updated after creation; there is no UpdateTask command.
//
-// For [App Engine queues][google.cloud.tasks.v2beta3.AppEngineHttpQueue], the maximum task size is
+// For [App Engine queues][google.cloud.tasks.v2beta3.AppEngineHttpQueue],
+// the maximum task size is
// 100KB.
func (c *Client) CreateTask(ctx context.Context, req *taskspb.CreateTaskRequest, opts ...gax.CallOption) (*taskspb.Task, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", req.GetParent()))
@@ -543,13 +552,14 @@
// RunTask forces a task to run now.
//
// When this method is called, Cloud Tasks will dispatch the task, even if
-// the task is already running, the queue has reached its [RateLimits][google.cloud.tasks.v2beta3.RateLimits] or
-// is [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
+// the task is already running, the queue has reached its
+// [RateLimits][google.cloud.tasks.v2beta3.RateLimits] or is
+// [PAUSED][google.cloud.tasks.v2beta3.Queue.State.PAUSED].
//
// This command is meant to be used for manual debugging. For
-// example, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] can be used to retry a failed
-// task after a fix has been made or to manually force a task to be
-// dispatched now.
+// example, [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] can be
+// used to retry a failed task after a fix has been made or to manually force
+// a task to be dispatched now.
//
// The dispatched task is returned. That is, the task that is returned
// contains the [status][Task.status] after the task is dispatched but
@@ -557,9 +567,11 @@
//
// If Cloud Tasks receives a successful response from the task's
// target, then the task will be deleted; otherwise the task's
-// [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] will be reset to the time that
-// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] was called plus the retry delay specified
-// in the queue's [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
+// [schedule_time][google.cloud.tasks.v2beta3.Task.schedule_time] will be
+// reset to the time that
+// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] was called plus
+// the retry delay specified in the queue's
+// [RetryConfig][google.cloud.tasks.v2beta3.RetryConfig].
//
// [RunTask][google.cloud.tasks.v2beta3.CloudTasks.RunTask] returns
// [NOT_FOUND][google.rpc.Code.NOT_FOUND] when it is called on a
diff --git a/cloudtasks/apiv2beta3/doc.go b/cloudtasks/apiv2beta3/doc.go
index 35f4610..f9c0a29 100644
--- a/cloudtasks/apiv2beta3/doc.go
+++ b/cloudtasks/apiv2beta3/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/containeranalysis/apiv1beta1/doc.go b/containeranalysis/apiv1beta1/doc.go
index 208bfde..675c659 100644
--- a/containeranalysis/apiv1beta1/doc.go
+++ b/containeranalysis/apiv1beta1/doc.go
@@ -88,4 +88,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/dataproc/apiv1/doc.go b/dataproc/apiv1/doc.go
index 19f2005..99a40d0 100644
--- a/dataproc/apiv1/doc.go
+++ b/dataproc/apiv1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/dataproc/apiv1/job_controller_client.go b/dataproc/apiv1/job_controller_client.go
index dd125fb..2392409 100644
--- a/dataproc/apiv1/job_controller_client.go
+++ b/dataproc/apiv1/job_controller_client.go
@@ -228,7 +228,8 @@
// CancelJob starts a job cancellation request. To access the job resource
// after cancellation, call
-// regions/{region}/jobs.list (at /dataproc/docs/reference/rest/v1/projects.regions.jobs/list) or
+// regions/{region}/jobs.list (at /dataproc/docs/reference/rest/v1/projects.regions.jobs/list)
+// or
// regions/{region}/jobs.get (at /dataproc/docs/reference/rest/v1/projects.regions.jobs/get).
func (c *JobControllerClient) CancelJob(ctx context.Context, req *dataprocpb.CancelJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
diff --git a/dataproc/apiv1/workflow_template_client.go b/dataproc/apiv1/workflow_template_client.go
index bfb0e65..e93d7c3 100644
--- a/dataproc/apiv1/workflow_template_client.go
+++ b/dataproc/apiv1/workflow_template_client.go
@@ -236,7 +236,8 @@
// InstantiateInlineWorkflowTemplate instantiates a template and begins execution.
//
// This method is equivalent to executing the sequence
-// [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate],
+// [CreateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.CreateWorkflowTemplate],
+// [InstantiateWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.InstantiateWorkflowTemplate],
// [DeleteWorkflowTemplate][google.cloud.dataproc.v1.WorkflowTemplateService.DeleteWorkflowTemplate].
//
// The returned Operation can be used to track execution of
diff --git a/dataproc/apiv1beta2/doc.go b/dataproc/apiv1beta2/doc.go
index 6871c51..4433206 100644
--- a/dataproc/apiv1beta2/doc.go
+++ b/dataproc/apiv1beta2/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/dataproc/apiv1beta2/job_controller_client.go b/dataproc/apiv1beta2/job_controller_client.go
index cd52d5e..7afd00f 100644
--- a/dataproc/apiv1beta2/job_controller_client.go
+++ b/dataproc/apiv1beta2/job_controller_client.go
@@ -228,7 +228,8 @@
// CancelJob starts a job cancellation request. To access the job resource
// after cancellation, call
-// regions/{region}/jobs.list (at /dataproc/docs/reference/rest/v1beta2/projects.regions.jobs/list) or
+// regions/{region}/jobs.list (at /dataproc/docs/reference/rest/v1beta2/projects.regions.jobs/list)
+// or
// regions/{region}/jobs.get (at /dataproc/docs/reference/rest/v1beta2/projects.regions.jobs/get).
func (c *JobControllerClient) CancelJob(ctx context.Context, req *dataprocpb.CancelJobRequest, opts ...gax.CallOption) (*dataprocpb.Job, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
diff --git a/dataproc/apiv1beta2/workflow_template_client.go b/dataproc/apiv1beta2/workflow_template_client.go
index 8ebc882..50a5338 100644
--- a/dataproc/apiv1beta2/workflow_template_client.go
+++ b/dataproc/apiv1beta2/workflow_template_client.go
@@ -236,7 +236,8 @@
// InstantiateInlineWorkflowTemplate instantiates a template and begins execution.
//
// This method is equivalent to executing the sequence
-// [CreateWorkflowTemplate][google.cloud.dataproc.v1beta2.WorkflowTemplateService.CreateWorkflowTemplate], [InstantiateWorkflowTemplate][google.cloud.dataproc.v1beta2.WorkflowTemplateService.InstantiateWorkflowTemplate],
+// [CreateWorkflowTemplate][google.cloud.dataproc.v1beta2.WorkflowTemplateService.CreateWorkflowTemplate],
+// [InstantiateWorkflowTemplate][google.cloud.dataproc.v1beta2.WorkflowTemplateService.InstantiateWorkflowTemplate],
// [DeleteWorkflowTemplate][google.cloud.dataproc.v1beta2.WorkflowTemplateService.DeleteWorkflowTemplate].
//
// The returned Operation can be used to track execution of
diff --git a/debugger/apiv2/doc.go b/debugger/apiv2/doc.go
index dbefee0..4cd26b3 100644
--- a/debugger/apiv2/doc.go
+++ b/debugger/apiv2/doc.go
@@ -90,4 +90,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/dialogflow/apiv2/agents_client.go b/dialogflow/apiv2/agents_client.go
index 6d60e18..53892b6 100644
--- a/dialogflow/apiv2/agents_client.go
+++ b/dialogflow/apiv2/agents_client.go
@@ -107,18 +107,22 @@
// in your app, product, or service to determine user intent and respond to the
// user in a natural way.
//
-// After you create an agent, you can add [Intents][google.cloud.dialogflow.v2.Intents], [Contexts][google.cloud.dialogflow.v2.Contexts],
-// [Entity Types][google.cloud.dialogflow.v2.EntityTypes], [Webhooks][google.cloud.dialogflow.v2.WebhookRequest], and so on to
-// manage the flow of a conversation and match user input to predefined intents
-// and actions.
+// After you create an agent, you can add
+// [Intents][google.cloud.dialogflow.v2.Intents],
+// [Contexts][google.cloud.dialogflow.v2.Contexts], [Entity
+// Types][google.cloud.dialogflow.v2.EntityTypes],
+// [Webhooks][google.cloud.dialogflow.v2.WebhookRequest], and so on to manage
+// the flow of a conversation and match user input to predefined intents and
+// actions.
//
// You can create an agent using both Dialogflow Standard Edition and
// Dialogflow Enterprise Edition. For details, see
// Dialogflow Editions (at /dialogflow-enterprise/docs/editions).
//
// You can save your agent for backup or versioning by exporting the agent by
-// using the [ExportAgent][google.cloud.dialogflow.v2.Agents.ExportAgent] method. You can import a saved
-// agent by using the [ImportAgent][google.cloud.dialogflow.v2.Agents.ImportAgent] method.
+// using the [ExportAgent][google.cloud.dialogflow.v2.Agents.ExportAgent]
+// method. You can import a saved agent by using the
+// [ImportAgent][google.cloud.dialogflow.v2.Agents.ImportAgent] method.
//
// Dialogflow provides several
// prebuilt agents (at https://dialogflow.com/docs/prebuilt-agents) for common
@@ -255,7 +259,8 @@
// ExportAgent exports the specified agent to a ZIP file.
//
-// Operation <response: [ExportAgentResponse][google.cloud.dialogflow.v2.ExportAgentResponse],
+// Operation <response:
+// [ExportAgentResponse][google.cloud.dialogflow.v2.ExportAgentResponse],
// metadata: [google.protobuf.Struct][google.protobuf.Struct]>
func (c *AgentsClient) ExportAgent(ctx context.Context, req *dialogflowpb.ExportAgentRequest, opts ...gax.CallOption) (*ExportAgentOperation, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
diff --git a/dialogflow/apiv2/contexts_client.go b/dialogflow/apiv2/contexts_client.go
index c8ecc65..7620ddb 100644
--- a/dialogflow/apiv2/contexts_client.go
+++ b/dialogflow/apiv2/contexts_client.go
@@ -102,11 +102,11 @@
//
// You can include contexts as input parameters of a
// [DetectIntent][google.cloud.dialogflow.v2.Sessions.DetectIntent] (or
-// [StreamingDetectIntent][google.cloud.dialogflow.v2.Sessions.StreamingDetectIntent]) request,
-// or as output contexts included in the returned intent.
-// Contexts expire when an intent is matched, after the number of DetectIntent
-// requests specified by the lifespan_count parameter, or after 10 minutes
-// if no intents are matched for a DetectIntent request.
+// [StreamingDetectIntent][google.cloud.dialogflow.v2.Sessions.StreamingDetectIntent])
+// request, or as output contexts included in the returned intent. Contexts
+// expire when an intent is matched, after the number of DetectIntent requests
+// specified by the lifespan_count parameter, or after 10 minutes if no
+// intents are matched for a DetectIntent request.
//
// For more information about contexts, see the
// Dialogflow documentation (at https://dialogflow.com/docs/contexts).
diff --git a/dialogflow/apiv2/doc.go b/dialogflow/apiv2/doc.go
index f30bc82..c5c1396 100644
--- a/dialogflow/apiv2/doc.go
+++ b/dialogflow/apiv2/doc.go
@@ -87,4 +87,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/dialogflow/apiv2/entity_types_client.go b/dialogflow/apiv2/entity_types_client.go
index 0d2f1f3..9bf2355 100644
--- a/dialogflow/apiv2/entity_types_client.go
+++ b/dialogflow/apiv2/entity_types_client.go
@@ -133,7 +133,8 @@
//
// * **User** - entities that are built for an individual user such as
// favorites, preferences, playlists, and so on. A user entity is
-// represented by the [SessionEntityType][google.cloud.dialogflow.v2.SessionEntityType] type.
+// represented by the
+// [SessionEntityType][google.cloud.dialogflow.v2.SessionEntityType] type.
//
// For more information about entity types, see the
// [Dialogflow documentation](https://dialogflow.com/docs/entities).
@@ -282,7 +283,8 @@
// BatchUpdateEntityTypes updates/Creates multiple entity types in the specified agent.
//
-// Operation <response: [BatchUpdateEntityTypesResponse][google.cloud.dialogflow.v2.BatchUpdateEntityTypesResponse],
+// Operation <response:
+// [BatchUpdateEntityTypesResponse][google.cloud.dialogflow.v2.BatchUpdateEntityTypesResponse],
// metadata: [google.protobuf.Struct][google.protobuf.Struct]>
func (c *EntityTypesClient) BatchUpdateEntityTypes(ctx context.Context, req *dialogflowpb.BatchUpdateEntityTypesRequest, opts ...gax.CallOption) (*BatchUpdateEntityTypesOperation, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
diff --git a/dialogflow/apiv2/intents_client.go b/dialogflow/apiv2/intents_client.go
index 1912fba..91842e9 100644
--- a/dialogflow/apiv2/intents_client.go
+++ b/dialogflow/apiv2/intents_client.go
@@ -107,10 +107,10 @@
// An intent represents a mapping between input from a user and an action to
// be taken by your application. When you pass user input to the
// [DetectIntent][google.cloud.dialogflow.v2.Sessions.DetectIntent] (or
-// [StreamingDetectIntent][google.cloud.dialogflow.v2.Sessions.StreamingDetectIntent]) method, the
-// Dialogflow API analyzes the input and searches
-// for a matching intent. If no match is found, the Dialogflow API returns a
-// fallback intent (`is_fallback` = true).
+// [StreamingDetectIntent][google.cloud.dialogflow.v2.Sessions.StreamingDetectIntent])
+// method, the Dialogflow API analyzes the input and searches for a matching
+// intent. If no match is found, the Dialogflow API returns a fallback intent
+// (`is_fallback` = true).
//
// You can provide additional information for the Dialogflow API to use to
// match user input to an intent by adding the following to your intent.
@@ -280,7 +280,8 @@
// BatchUpdateIntents updates/Creates multiple intents in the specified agent.
//
-// Operation <response: [BatchUpdateIntentsResponse][google.cloud.dialogflow.v2.BatchUpdateIntentsResponse]>
+// Operation <response:
+// [BatchUpdateIntentsResponse][google.cloud.dialogflow.v2.BatchUpdateIntentsResponse]>
func (c *IntentsClient) BatchUpdateIntents(ctx context.Context, req *dialogflowpb.BatchUpdateIntentsRequest, opts ...gax.CallOption) (*BatchUpdateIntentsOperation, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.BatchUpdateIntents[0:len(c.CallOptions.BatchUpdateIntents):len(c.CallOptions.BatchUpdateIntents)], opts...)
diff --git a/dialogflow/apiv2/sessions_client.go b/dialogflow/apiv2/sessions_client.go
index 3c19da6..c13d6be 100644
--- a/dialogflow/apiv2/sessions_client.go
+++ b/dialogflow/apiv2/sessions_client.go
@@ -68,9 +68,10 @@
// NewSessionsClient creates a new sessions client.
//
// A session represents an interaction with a user. You retrieve user input
-// and pass it to the [DetectIntent][google.cloud.dialogflow.v2.Sessions.DetectIntent] (or
-// [StreamingDetectIntent][google.cloud.dialogflow.v2.Sessions.StreamingDetectIntent]) method to determine
-// user intent and respond.
+// and pass it to the
+// [DetectIntent][google.cloud.dialogflow.v2.Sessions.DetectIntent] (or
+// [StreamingDetectIntent][google.cloud.dialogflow.v2.Sessions.StreamingDetectIntent])
+// method to determine user intent and respond.
func NewSessionsClient(ctx context.Context, opts ...option.ClientOption) (*SessionsClient, error) {
conn, err := transport.DialGRPC(ctx, append(defaultSessionsClientOptions(), opts...)...)
if err != nil {
diff --git a/dlp/apiv2/doc.go b/dlp/apiv2/doc.go
index 3266531..5b675e0 100644
--- a/dlp/apiv2/doc.go
+++ b/dlp/apiv2/doc.go
@@ -87,4 +87,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/errorreporting/apiv1beta1/doc.go b/errorreporting/apiv1beta1/doc.go
index bf4cb3a..f86d7f9 100644
--- a/errorreporting/apiv1beta1/doc.go
+++ b/errorreporting/apiv1beta1/doc.go
@@ -90,4 +90,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/errorreporting/apiv1beta1/report_errors_client.go b/errorreporting/apiv1beta1/report_errors_client.go
index c3e7d9c..ea9f247 100644
--- a/errorreporting/apiv1beta1/report_errors_client.go
+++ b/errorreporting/apiv1beta1/report_errors_client.go
@@ -107,7 +107,8 @@
// <strong>or</strong> an
// <a href="https://support.google.com/cloud/answer/6158862">API key</a>
// for authentication. To use an API key, append it to the URL as the value of
-// a key parameter. For example:<pre>POST https://clouderrorreporting.googleapis.com/v1beta1/projects/example-project/events:report?key=123ABC456</pre>
+// a key parameter. For example:<pre>POST
+// https://clouderrorreporting.googleapis.com/v1beta1/projects/example-project/events:report?key=123ABC456</pre>
func (c *ReportErrorsClient) ReportErrorEvent(ctx context.Context, req *clouderrorreportingpb.ReportErrorEventRequest, opts ...gax.CallOption) (*clouderrorreportingpb.ReportErrorEventResponse, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ReportErrorEvent[0:len(c.CallOptions.ReportErrorEvent):len(c.CallOptions.ReportErrorEvent)], opts...)
diff --git a/expr/apiv1alpha1/doc.go b/expr/apiv1alpha1/doc.go
index 8a4a01e..2c82e48 100644
--- a/expr/apiv1alpha1/doc.go
+++ b/expr/apiv1alpha1/doc.go
@@ -84,4 +84,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/firestore/apiv1beta1/doc.go b/firestore/apiv1beta1/doc.go
index 40b423e..baad273 100644
--- a/firestore/apiv1beta1/doc.go
+++ b/firestore/apiv1beta1/doc.go
@@ -88,4 +88,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/go.mod b/go.mod
index 4dad397..d4e21b7 100644
--- a/go.mod
+++ b/go.mod
@@ -1,7 +1,6 @@
module cloud.google.com/go
require (
- github.com/BurntSushi/toml v0.3.1 // indirect
github.com/golang/mock v1.2.0
github.com/golang/protobuf v1.2.0
github.com/google/btree v0.0.0-20180813153112-4030bb1f1f0c
@@ -12,14 +11,14 @@
github.com/jstemmer/go-junit-report v0.0.0-20190106144839-af01ea7f8024
go.opencensus.io v0.18.0
golang.org/x/build v0.0.0-20190111050920-041ab4dc3f9d
- golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3
+ golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961
golang.org/x/oauth2 v0.0.0-20181203162652-d668ce993890
- golang.org/x/sync v0.0.0-20181108010431-42b317875d0f
+ golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6
golang.org/x/text v0.3.1-0.20180807135948-17ff2d5776d2
golang.org/x/time v0.0.0-20181108054448-85acf8d2951c
- golang.org/x/tools v0.0.0-20181030000716-a0a13e073c7b
+ golang.org/x/tools v0.0.0-20190226205152-f727befe758c
google.golang.org/api v0.1.0
- google.golang.org/genproto v0.0.0-20190226184841-fc2db5cae922
- google.golang.org/grpc v1.17.0
+ google.golang.org/genproto v0.0.0-20190306203927-b5d61aea6440
+ google.golang.org/grpc v1.19.0
honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a
)
diff --git a/go.sum b/go.sum
index ea620c0..0ddcb4e 100644
--- a/go.sum
+++ b/go.sum
@@ -100,12 +100,16 @@
golang.org/x/lint v0.0.0-20180702182130-06c8688daad7/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3 h1:x/bBzNauLQAlE3fLku/xy92Y8QwKX5HZymrMz2IiKFc=
golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
+golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961 h1:GmgasJE571dBGXS7E282h2rIZj+KvCLV8z5I6QXbKNI=
+golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
golang.org/x/net v0.0.0-20180724234803-3673e40ba225/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20180826012351-8a410e7b638d/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181029044818-c44066c5c816/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/net v0.0.0-20181106065722-10aee1819953 h1:LuZIitY8waaxUfNIdtajyE/YzA/zyf0YxXG27VpLrkg=
golang.org/x/net v0.0.0-20181106065722-10aee1819953/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
+golang.org/x/net v0.0.0-20190213061140-3a22650c66bd h1:HuTn7WObtcDo9uEEU7rEqL0jYthdXAmZ6PP+meazmaU=
+golang.org/x/net v0.0.0-20190213061140-3a22650c66bd/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20181017192945-9dcd33a902f4/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20181203162652-d668ce993890 h1:uESlIz09WIHT2I+pasSXcpLYqYK8wHcdCetU3VuMBJE=
@@ -114,6 +118,8 @@
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f h1:Bl/8QSvNqXvPGPGXa2z5xUTmV7VDcZyvRZ+QQXkXTZQ=
golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6 h1:bjcUS9ztw9kFmmIxJInhon/0Is3p+EHBKNgquIzo1OI=
+golang.org/x/sync v0.0.0-20190227155943-e225da77a7e6/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e h1:o3PsSEY8E4eXWkXrIP9YJALUkVZqzHJT5DOasTyn8Vs=
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
@@ -130,6 +136,9 @@
golang.org/x/tools v0.0.0-20180828015842-6cd1fcedba52/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/tools v0.0.0-20181030000716-a0a13e073c7b h1:Un5iKMvgLIGMzGM1mJWvi22FiMX9XB6/NOzYKoy66y8=
golang.org/x/tools v0.0.0-20181030000716-a0a13e073c7b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20190226205152-f727befe758c h1:vamGzbGri8IKo20MQncCuljcQ5uAO6kaCeawQPVblAI=
+golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
google.golang.org/api v0.0.0-20180910000450-7ca32eb868bf/go.mod h1:4mhQ8q/RsB7i+udVvVy5NUi08OU8ZlA0gRVgrF7VFY0=
google.golang.org/api v0.0.0-20181030000543-1d582fd0359e/go.mod h1:4mhQ8q/RsB7i+udVvVy5NUi08OU8ZlA0gRVgrF7VFY0=
google.golang.org/api v0.1.0 h1:K6z2u68e86TPdSdefXdzvXgR1zEMa+459vBSfWYAZkI=
@@ -138,23 +147,28 @@
google.golang.org/appengine v1.2.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
google.golang.org/appengine v1.3.0 h1:FBSsiFRMz3LBeXIomRnVzrQwSDj4ibvcRexLG0LZGQk=
google.golang.org/appengine v1.3.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
+google.golang.org/appengine v1.4.0 h1:/wp5JvzpHIxhs/dumFmF7BXTf3Z+dd4uXta4kVyO508=
+google.golang.org/appengine v1.4.0/go.mod h1:xpcJRLb0r/rnEns0DIKYYv+WjYCduHsrkT7/EB5XEv4=
google.golang.org/genproto v0.0.0-20180817151627-c66870c02cf8/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
google.golang.org/genproto v0.0.0-20180831171423-11092d34479b/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
google.golang.org/genproto v0.0.0-20181029155118-b69ba1387ce2/go.mod h1:JiN7NxoALGmiZfu7CAH4rXhgtRTLTxftemlI0sWmxmc=
google.golang.org/genproto v0.0.0-20181202183823-bd91e49a0898 h1:yvw+zsSmSM02Z5H3ZdEV7B7Ql7eFrjQTnmByJvK+3J8=
google.golang.org/genproto v0.0.0-20181202183823-bd91e49a0898/go.mod h1:7Ep/1NZk928CDR8SjdVbjWNpdIf6nzjE3BTgJDr2Atg=
-google.golang.org/genproto v0.0.0-20190226184841-fc2db5cae922 h1:EqOOG7rjaEsiSBOxSSdQyc6rjCtWNQegwGE06rm6SII=
-google.golang.org/genproto v0.0.0-20190226184841-fc2db5cae922/go.mod h1:L3J43x8/uS+qIUoksaLKe6OS3nUKxOKuIFz1sl2/jx4=
+google.golang.org/genproto v0.0.0-20190306203927-b5d61aea6440 h1:VOR2wHHZJgoALLvnlCN4JUaWACO1lOLXiSN2F3g/GXU=
+google.golang.org/genproto v0.0.0-20190306203927-b5d61aea6440/go.mod h1:VzzqZJRnGkLBvHegQrXjBqPurQTc5/KpmUdxsrq26oE=
google.golang.org/grpc v1.14.0/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw=
google.golang.org/grpc v1.16.0/go.mod h1:0JHn/cJsOMiMfNA9+DeHDlAU7KAAB5GDlYFpa9MZMio=
google.golang.org/grpc v1.17.0 h1:TRJYBgMclJvGYn2rIMjj+h9KtMt5r1Ij7ODVRIZkwhk=
google.golang.org/grpc v1.17.0/go.mod h1:6QZJwpn2B+Zp71q/5VxRsJ6NXXVCE5NRUHRo+f3cWCs=
+google.golang.org/grpc v1.19.0 h1:cfg4PD8YEdSFnm7qLV4++93WcmhH2nIUhMjhdCvl3j8=
+google.golang.org/grpc v1.19.0/go.mod h1:mqu4LbDTu4XGKhr4mRzUsmM4RtVoemTSY81AxZiDr8c=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/inf.v0 v0.9.1 h1:73M5CoZyi3ZLMOyDlQh031Cx6N9NDJ2Vvfl76EDAgDc=
gopkg.in/inf.v0 v0.9.1/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw=
gopkg.in/yaml.v2 v2.2.1/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
grpc.go4.org v0.0.0-20170609214715-11d0a25b4919/go.mod h1:77eQGdRu53HpSqPFJFmuJdjuHRquDANNeA4x7B8WQ9o=
honnef.co/go/tools v0.0.0-20180728063816-88497007e858/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
+honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a h1:/8zB6iBfHCl1qAnEAWwGPNrUvapuy6CPla1VM0k8hQw=
honnef.co/go/tools v0.0.0-20190106161140-3f1c8253044a/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
sourcegraph.com/sourcegraph/go-diff v0.5.0/go.mod h1:kuch7UrkMzY0X+p9CRK03kfuPQ2zzQcaEFbx8wA8rck=
diff --git a/iam/admin/apiv1/doc.go b/iam/admin/apiv1/doc.go
index 440ef52..3374bfe 100644
--- a/iam/admin/apiv1/doc.go
+++ b/iam/admin/apiv1/doc.go
@@ -89,4 +89,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/iam/credentials/apiv1/doc.go b/iam/credentials/apiv1/doc.go
index ffcd7e9..56dd5ec 100644
--- a/iam/credentials/apiv1/doc.go
+++ b/iam/credentials/apiv1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/iot/apiv1/doc.go b/iot/apiv1/doc.go
index 72f530a..31a64ad 100644
--- a/iot/apiv1/doc.go
+++ b/iot/apiv1/doc.go
@@ -88,4 +88,4 @@
return "UNKNOWN"
}
-const versionClient = "20190219"
+const versionClient = "20190306"
diff --git a/irm/apiv1alpha2/doc.go b/irm/apiv1alpha2/doc.go
index 983725a..0428537 100644
--- a/irm/apiv1alpha2/doc.go
+++ b/irm/apiv1alpha2/doc.go
@@ -85,4 +85,4 @@
return "UNKNOWN"
}
-const versionClient = "20190225"
+const versionClient = "20190306"
diff --git a/kms/apiv1/doc.go b/kms/apiv1/doc.go
index 3ed9b80..cd34a1c 100644
--- a/kms/apiv1/doc.go
+++ b/kms/apiv1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/kms/apiv1/key_management_client.go b/kms/apiv1/key_management_client.go
index 8c11f72..d5f7de9 100644
--- a/kms/apiv1/key_management_client.go
+++ b/kms/apiv1/key_management_client.go
@@ -299,8 +299,9 @@
return resp, nil
}
-// GetCryptoKey returns metadata for a given [CryptoKey][google.cloud.kms.v1.CryptoKey], as well as its
-// [primary][google.cloud.kms.v1.CryptoKey.primary] [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion].
+// GetCryptoKey returns metadata for a given [CryptoKey][google.cloud.kms.v1.CryptoKey], as
+// well as its [primary][google.cloud.kms.v1.CryptoKey.primary]
+// [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion].
func (c *KeyManagementClient) GetCryptoKey(ctx context.Context, req *kmspb.GetCryptoKeyRequest, opts ...gax.CallOption) (*kmspb.CryptoKey, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -317,7 +318,8 @@
return resp, nil
}
-// GetCryptoKeyVersion returns metadata for a given [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion].
+// GetCryptoKeyVersion returns metadata for a given
+// [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion].
func (c *KeyManagementClient) GetCryptoKeyVersion(ctx context.Context, req *kmspb.GetCryptoKeyVersionRequest, opts ...gax.CallOption) (*kmspb.CryptoKeyVersion, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -334,7 +336,8 @@
return resp, nil
}
-// CreateKeyRing create a new [KeyRing][google.cloud.kms.v1.KeyRing] in a given Project and Location.
+// CreateKeyRing create a new [KeyRing][google.cloud.kms.v1.KeyRing] in a given Project and
+// Location.
func (c *KeyManagementClient) CreateKeyRing(ctx context.Context, req *kmspb.CreateKeyRingRequest, opts ...gax.CallOption) (*kmspb.KeyRing, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "parent", req.GetParent()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -351,7 +354,8 @@
return resp, nil
}
-// CreateCryptoKey create a new [CryptoKey][google.cloud.kms.v1.CryptoKey] within a [KeyRing][google.cloud.kms.v1.KeyRing].
+// CreateCryptoKey create a new [CryptoKey][google.cloud.kms.v1.CryptoKey] within a
+// [KeyRing][google.cloud.kms.v1.KeyRing].
//
// [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose] and
// [CryptoKey.version_template.algorithm][google.cloud.kms.v1.CryptoKeyVersionTemplate.algorithm]
@@ -372,7 +376,8 @@
return resp, nil
}
-// CreateCryptoKeyVersion create a new [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion] in a [CryptoKey][google.cloud.kms.v1.CryptoKey].
+// CreateCryptoKeyVersion create a new [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion] in a
+// [CryptoKey][google.cloud.kms.v1.CryptoKey].
//
// The server will assign the next sequential id. If unset,
// [state][google.cloud.kms.v1.CryptoKeyVersion.state] will be set to
@@ -410,13 +415,18 @@
return resp, nil
}
-// UpdateCryptoKeyVersion update a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion]'s metadata.
+// UpdateCryptoKeyVersion update a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion]'s
+// metadata.
//
// [state][google.cloud.kms.v1.CryptoKeyVersion.state] may be changed between
-// [ENABLED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.ENABLED] and
-// [DISABLED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DISABLED] using this
-// method. See [DestroyCryptoKeyVersion][google.cloud.kms.v1.KeyManagementService.DestroyCryptoKeyVersion] and [RestoreCryptoKeyVersion][google.cloud.kms.v1.KeyManagementService.RestoreCryptoKeyVersion] to
-// move between other states.
+// [ENABLED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.ENABLED]
+// and
+// [DISABLED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DISABLED]
+// using this method. See
+// [DestroyCryptoKeyVersion][google.cloud.kms.v1.KeyManagementService.DestroyCryptoKeyVersion]
+// and
+// [RestoreCryptoKeyVersion][google.cloud.kms.v1.KeyManagementService.RestoreCryptoKeyVersion]
+// to move between other states.
func (c *KeyManagementClient) UpdateCryptoKeyVersion(ctx context.Context, req *kmspb.UpdateCryptoKeyVersionRequest, opts ...gax.CallOption) (*kmspb.CryptoKeyVersion, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "crypto_key_version.name", req.GetCryptoKeyVersion().GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -433,8 +443,9 @@
return resp, nil
}
-// Encrypt encrypts data, so that it can only be recovered by a call to [Decrypt][google.cloud.kms.v1.KeyManagementService.Decrypt].
-// The [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose] must be
+// Encrypt encrypts data, so that it can only be recovered by a call to
+// [Decrypt][google.cloud.kms.v1.KeyManagementService.Decrypt]. The
+// [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose] must be
// [ENCRYPT_DECRYPT][google.cloud.kms.v1.CryptoKey.CryptoKeyPurpose.ENCRYPT_DECRYPT].
func (c *KeyManagementClient) Encrypt(ctx context.Context, req *kmspb.EncryptRequest, opts ...gax.CallOption) (*kmspb.EncryptResponse, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
@@ -452,8 +463,10 @@
return resp, nil
}
-// Decrypt decrypts data that was protected by [Encrypt][google.cloud.kms.v1.KeyManagementService.Encrypt]. The [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose]
-// must be [ENCRYPT_DECRYPT][google.cloud.kms.v1.CryptoKey.CryptoKeyPurpose.ENCRYPT_DECRYPT].
+// Decrypt decrypts data that was protected by
+// [Encrypt][google.cloud.kms.v1.KeyManagementService.Encrypt]. The
+// [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose] must be
+// [ENCRYPT_DECRYPT][google.cloud.kms.v1.CryptoKey.CryptoKeyPurpose.ENCRYPT_DECRYPT].
func (c *KeyManagementClient) Decrypt(ctx context.Context, req *kmspb.DecryptRequest, opts ...gax.CallOption) (*kmspb.DecryptResponse, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -470,7 +483,9 @@
return resp, nil
}
-// UpdateCryptoKeyPrimaryVersion update the version of a [CryptoKey][google.cloud.kms.v1.CryptoKey] that will be used in [Encrypt][google.cloud.kms.v1.KeyManagementService.Encrypt].
+// UpdateCryptoKeyPrimaryVersion update the version of a [CryptoKey][google.cloud.kms.v1.CryptoKey] that
+// will be used in
+// [Encrypt][google.cloud.kms.v1.KeyManagementService.Encrypt].
//
// Returns an error if called on an asymmetric key.
func (c *KeyManagementClient) UpdateCryptoKeyPrimaryVersion(ctx context.Context, req *kmspb.UpdateCryptoKeyPrimaryVersionRequest, opts ...gax.CallOption) (*kmspb.CryptoKey, error) {
@@ -489,18 +504,24 @@
return resp, nil
}
-// DestroyCryptoKeyVersion schedule a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion] for destruction.
+// DestroyCryptoKeyVersion schedule a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion] for
+// destruction.
//
-// Upon calling this method, [CryptoKeyVersion.state][google.cloud.kms.v1.CryptoKeyVersion.state] will be set to
+// Upon calling this method,
+// [CryptoKeyVersion.state][google.cloud.kms.v1.CryptoKeyVersion.state] will
+// be set to
// [DESTROY_SCHEDULED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DESTROY_SCHEDULED]
-// and [destroy_time][google.cloud.kms.v1.CryptoKeyVersion.destroy_time] will be set to a time 24
-// hours in the future, at which point the [state][google.cloud.kms.v1.CryptoKeyVersion.state]
-// will be changed to
-// [DESTROYED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DESTROYED], and the key
-// material will be irrevocably destroyed.
+// and [destroy_time][google.cloud.kms.v1.CryptoKeyVersion.destroy_time] will
+// be set to a time 24 hours in the future, at which point the
+// [state][google.cloud.kms.v1.CryptoKeyVersion.state] will be changed to
+// [DESTROYED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DESTROYED],
+// and the key material will be irrevocably destroyed.
//
-// Before the [destroy_time][google.cloud.kms.v1.CryptoKeyVersion.destroy_time] is reached,
-// [RestoreCryptoKeyVersion][google.cloud.kms.v1.KeyManagementService.RestoreCryptoKeyVersion] may be called to reverse the process.
+// Before the
+// [destroy_time][google.cloud.kms.v1.CryptoKeyVersion.destroy_time] is
+// reached,
+// [RestoreCryptoKeyVersion][google.cloud.kms.v1.KeyManagementService.RestoreCryptoKeyVersion]
+// may be called to reverse the process.
func (c *KeyManagementClient) DestroyCryptoKeyVersion(ctx context.Context, req *kmspb.DestroyCryptoKeyVersionRequest, opts ...gax.CallOption) (*kmspb.CryptoKeyVersion, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -521,9 +542,11 @@
// [DESTROY_SCHEDULED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DESTROY_SCHEDULED]
// state.
//
-// Upon restoration of the CryptoKeyVersion, [state][google.cloud.kms.v1.CryptoKeyVersion.state]
-// will be set to [DISABLED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DISABLED],
-// and [destroy_time][google.cloud.kms.v1.CryptoKeyVersion.destroy_time] will be cleared.
+// Upon restoration of the CryptoKeyVersion,
+// [state][google.cloud.kms.v1.CryptoKeyVersion.state] will be set to
+// [DISABLED][google.cloud.kms.v1.CryptoKeyVersion.CryptoKeyVersionState.DISABLED],
+// and [destroy_time][google.cloud.kms.v1.CryptoKeyVersion.destroy_time] will
+// be cleared.
func (c *KeyManagementClient) RestoreCryptoKeyVersion(ctx context.Context, req *kmspb.RestoreCryptoKeyVersionRequest, opts ...gax.CallOption) (*kmspb.CryptoKeyVersion, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -540,9 +563,11 @@
return resp, nil
}
-// GetPublicKey returns the public key for the given [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion]. The
+// GetPublicKey returns the public key for the given
+// [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion]. The
// [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose] must be
-// [ASYMMETRIC_SIGN][google.cloud.kms.v1.CryptoKey.CryptoKeyPurpose.ASYMMETRIC_SIGN] or
+// [ASYMMETRIC_SIGN][google.cloud.kms.v1.CryptoKey.CryptoKeyPurpose.ASYMMETRIC_SIGN]
+// or
// [ASYMMETRIC_DECRYPT][google.cloud.kms.v1.CryptoKey.CryptoKeyPurpose.ASYMMETRIC_DECRYPT].
func (c *KeyManagementClient) GetPublicKey(ctx context.Context, req *kmspb.GetPublicKeyRequest, opts ...gax.CallOption) (*kmspb.PublicKey, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
@@ -561,8 +586,10 @@
}
// AsymmetricDecrypt decrypts data that was encrypted with a public key retrieved from
-// [GetPublicKey][google.cloud.kms.v1.KeyManagementService.GetPublicKey] corresponding to a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion] with
-// [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose] ASYMMETRIC_DECRYPT.
+// [GetPublicKey][google.cloud.kms.v1.KeyManagementService.GetPublicKey]
+// corresponding to a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion]
+// with [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose]
+// ASYMMETRIC_DECRYPT.
func (c *KeyManagementClient) AsymmetricDecrypt(ctx context.Context, req *kmspb.AsymmetricDecryptRequest, opts ...gax.CallOption) (*kmspb.AsymmetricDecryptResponse, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
@@ -579,9 +606,11 @@
return resp, nil
}
-// AsymmetricSign signs data using a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion] with [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose]
+// AsymmetricSign signs data using a [CryptoKeyVersion][google.cloud.kms.v1.CryptoKeyVersion]
+// with [CryptoKey.purpose][google.cloud.kms.v1.CryptoKey.purpose]
// ASYMMETRIC_SIGN, producing a signature that can be verified with the public
-// key retrieved from [GetPublicKey][google.cloud.kms.v1.KeyManagementService.GetPublicKey].
+// key retrieved from
+// [GetPublicKey][google.cloud.kms.v1.KeyManagementService.GetPublicKey].
func (c *KeyManagementClient) AsymmetricSign(ctx context.Context, req *kmspb.AsymmetricSignRequest, opts ...gax.CallOption) (*kmspb.AsymmetricSignResponse, error) {
md := metadata.Pairs("x-goog-request-params", fmt.Sprintf("%s=%v", "name", req.GetName()))
ctx = insertMetadata(ctx, c.xGoogMetadata, md)
diff --git a/language/apiv1/doc.go b/language/apiv1/doc.go
index 9b8c0d7..2ddeaf1 100644
--- a/language/apiv1/doc.go
+++ b/language/apiv1/doc.go
@@ -87,4 +87,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/language/apiv1/language_client.go b/language/apiv1/language_client.go
index ddeb440..264a686 100644
--- a/language/apiv1/language_client.go
+++ b/language/apiv1/language_client.go
@@ -161,8 +161,10 @@
return resp, nil
}
-// AnalyzeEntitySentiment finds entities, similar to [AnalyzeEntities][google.cloud.language.v1.LanguageService.AnalyzeEntities] in the text and analyzes
-// sentiment associated with each entity and its mentions.
+// AnalyzeEntitySentiment finds entities, similar to
+// [AnalyzeEntities][google.cloud.language.v1.LanguageService.AnalyzeEntities]
+// in the text and analyzes sentiment associated with each entity and its
+// mentions.
func (c *Client) AnalyzeEntitySentiment(ctx context.Context, req *languagepb.AnalyzeEntitySentimentRequest, opts ...gax.CallOption) (*languagepb.AnalyzeEntitySentimentResponse, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.AnalyzeEntitySentiment[0:len(c.CallOptions.AnalyzeEntitySentiment):len(c.CallOptions.AnalyzeEntitySentiment)], opts...)
diff --git a/language/apiv1beta2/doc.go b/language/apiv1beta2/doc.go
index 236a366..1f4e9c9 100644
--- a/language/apiv1beta2/doc.go
+++ b/language/apiv1beta2/doc.go
@@ -88,4 +88,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/language/apiv1beta2/language_client.go b/language/apiv1beta2/language_client.go
index 19a9671..1d943ad 100644
--- a/language/apiv1beta2/language_client.go
+++ b/language/apiv1beta2/language_client.go
@@ -161,8 +161,10 @@
return resp, nil
}
-// AnalyzeEntitySentiment finds entities, similar to [AnalyzeEntities][google.cloud.language.v1beta2.LanguageService.AnalyzeEntities] in the text and analyzes
-// sentiment associated with each entity and its mentions.
+// AnalyzeEntitySentiment finds entities, similar to
+// [AnalyzeEntities][google.cloud.language.v1beta2.LanguageService.AnalyzeEntities]
+// in the text and analyzes sentiment associated with each entity and its
+// mentions.
func (c *Client) AnalyzeEntitySentiment(ctx context.Context, req *languagepb.AnalyzeEntitySentimentRequest, opts ...gax.CallOption) (*languagepb.AnalyzeEntitySentimentResponse, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.AnalyzeEntitySentiment[0:len(c.CallOptions.AnalyzeEntitySentiment):len(c.CallOptions.AnalyzeEntitySentiment)], opts...)
diff --git a/logging/apiv2/doc.go b/logging/apiv2/doc.go
index 6948819..023bc5b 100644
--- a/logging/apiv2/doc.go
+++ b/logging/apiv2/doc.go
@@ -92,4 +92,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/longrunning/autogen/doc.go b/longrunning/autogen/doc.go
index 6b6252a..2c8adfe 100644
--- a/longrunning/autogen/doc.go
+++ b/longrunning/autogen/doc.go
@@ -85,4 +85,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/longrunning/autogen/operations_client.go b/longrunning/autogen/operations_client.go
index 7316802..e0c176e 100644
--- a/longrunning/autogen/operations_client.go
+++ b/longrunning/autogen/operations_client.go
@@ -92,12 +92,12 @@
// Manages long-running operations with an API service.
//
// When an API method normally takes long time to complete, it can be designed
-// to return [Operation][google.longrunning.Operation] to the client, and the client can use this
-// interface to receive the real response asynchronously by polling the
-// operation resource, or pass the operation resource to another API (such as
-// Google Cloud Pub/Sub API) to receive the response. Any API service that
-// returns long-running operations should implement the Operations interface
-// so developers can have a consistent client experience.
+// to return [Operation][google.longrunning.Operation] to the client, and the
+// client can use this interface to receive the real response asynchronously by
+// polling the operation resource, or pass the operation resource to another API
+// (such as Google Cloud Pub/Sub API) to receive the response. Any API service
+// that returns long-running operations should implement the Operations
+// interface so developers can have a consistent client experience.
func NewOperationsClient(ctx context.Context, opts ...option.ClientOption) (*OperationsClient, error) {
conn, err := transport.DialGRPC(ctx, append(defaultOperationsClientOptions(), opts...)...)
if err != nil {
@@ -200,8 +200,9 @@
// other methods to check whether the cancellation succeeded or whether the
// operation completed despite cancellation. On successful cancellation,
// the operation is not deleted; instead, it becomes an operation with
-// an [Operation.error][google.longrunning.Operation.error] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
-// corresponding to Code.CANCELLED.
+// an [Operation.error][google.longrunning.Operation.error] value with a
+// [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+// Code.CANCELLED.
func (c *OperationsClient) CancelOperation(ctx context.Context, req *longrunningpb.CancelOperationRequest, opts ...gax.CallOption) error {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.CancelOperation[0:len(c.CallOptions.CancelOperation):len(c.CallOptions.CancelOperation)], opts...)
diff --git a/monitoring/apiv3/doc.go b/monitoring/apiv3/doc.go
index 4db8d95..cf1d122 100644
--- a/monitoring/apiv3/doc.go
+++ b/monitoring/apiv3/doc.go
@@ -91,4 +91,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/monitoring/apiv3/metric_client.go b/monitoring/apiv3/metric_client.go
index 0299335..7162d62 100644
--- a/monitoring/apiv3/metric_client.go
+++ b/monitoring/apiv3/metric_client.go
@@ -136,7 +136,8 @@
c.xGoogMetadata = metadata.Pairs("x-goog-api-client", gax.XGoogHeader(kv...))
}
-// ListMonitoredResourceDescriptors lists monitored resource descriptors that match a filter. This method does not require a Stackdriver account.
+// ListMonitoredResourceDescriptors lists monitored resource descriptors that match a filter. This method does
+// not require a Stackdriver account.
func (c *MetricClient) ListMonitoredResourceDescriptors(ctx context.Context, req *monitoringpb.ListMonitoredResourceDescriptorsRequest, opts ...gax.CallOption) *MonitoredResourceDescriptorIterator {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ListMonitoredResourceDescriptors[0:len(c.CallOptions.ListMonitoredResourceDescriptors):len(c.CallOptions.ListMonitoredResourceDescriptors)], opts...)
@@ -173,7 +174,8 @@
return it
}
-// GetMonitoredResourceDescriptor gets a single monitored resource descriptor. This method does not require a Stackdriver account.
+// GetMonitoredResourceDescriptor gets a single monitored resource descriptor. This method does not require a
+// Stackdriver account.
func (c *MetricClient) GetMonitoredResourceDescriptor(ctx context.Context, req *monitoringpb.GetMonitoredResourceDescriptorRequest, opts ...gax.CallOption) (*monitoredrespb.MonitoredResourceDescriptor, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.GetMonitoredResourceDescriptor[0:len(c.CallOptions.GetMonitoredResourceDescriptor):len(c.CallOptions.GetMonitoredResourceDescriptor)], opts...)
@@ -189,7 +191,8 @@
return resp, nil
}
-// ListMetricDescriptors lists metric descriptors that match a filter. This method does not require a Stackdriver account.
+// ListMetricDescriptors lists metric descriptors that match a filter. This method does not require
+// a Stackdriver account.
func (c *MetricClient) ListMetricDescriptors(ctx context.Context, req *monitoringpb.ListMetricDescriptorsRequest, opts ...gax.CallOption) *MetricDescriptorIterator {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ListMetricDescriptors[0:len(c.CallOptions.ListMetricDescriptors):len(c.CallOptions.ListMetricDescriptors)], opts...)
@@ -226,7 +229,8 @@
return it
}
-// GetMetricDescriptor gets a single metric descriptor. This method does not require a Stackdriver account.
+// GetMetricDescriptor gets a single metric descriptor. This method does not require a Stackdriver
+// account.
func (c *MetricClient) GetMetricDescriptor(ctx context.Context, req *monitoringpb.GetMetricDescriptorRequest, opts ...gax.CallOption) (*metricpb.MetricDescriptor, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.GetMetricDescriptor[0:len(c.CallOptions.GetMetricDescriptor):len(c.CallOptions.GetMetricDescriptor)], opts...)
@@ -273,7 +277,8 @@
return err
}
-// ListTimeSeries lists time series that match a filter. This method does not require a Stackdriver account.
+// ListTimeSeries lists time series that match a filter. This method does not require a
+// Stackdriver account.
func (c *MetricClient) ListTimeSeries(ctx context.Context, req *monitoringpb.ListTimeSeriesRequest, opts ...gax.CallOption) *TimeSeriesIterator {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ListTimeSeries[0:len(c.CallOptions.ListTimeSeries):len(c.CallOptions.ListTimeSeries)], opts...)
diff --git a/oslogin/apiv1/doc.go b/oslogin/apiv1/doc.go
index 36ca543..313a04a 100644
--- a/oslogin/apiv1/doc.go
+++ b/oslogin/apiv1/doc.go
@@ -89,4 +89,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/oslogin/apiv1beta/doc.go b/oslogin/apiv1beta/doc.go
index d9d85d4..bf607b3 100644
--- a/oslogin/apiv1beta/doc.go
+++ b/oslogin/apiv1beta/doc.go
@@ -89,4 +89,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/pubsub/apiv1/doc.go b/pubsub/apiv1/doc.go
index ba47dc0..5037331 100644
--- a/pubsub/apiv1/doc.go
+++ b/pubsub/apiv1/doc.go
@@ -89,4 +89,4 @@
return "UNKNOWN"
}
-const versionClient = "20190219"
+const versionClient = "20190306"
diff --git a/pubsub/apiv1/subscriber_client.go b/pubsub/apiv1/subscriber_client.go
index 1c45204..26bcf93 100644
--- a/pubsub/apiv1/subscriber_client.go
+++ b/pubsub/apiv1/subscriber_client.go
@@ -194,9 +194,10 @@
// 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 (at 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 (at 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.
func (c *SubscriberClient) CreateSubscription(ctx context.Context, req *pubsubpb.Subscription, opts ...gax.CallOption) (*pubsubpb.Subscription, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.CreateSubscription[0:len(c.CallOptions.CreateSubscription):len(c.CallOptions.CreateSubscription)], opts...)
@@ -452,9 +453,10 @@
// 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 (at 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 (at 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.
func (c *SubscriberClient) CreateSnapshot(ctx context.Context, req *pubsubpb.CreateSnapshotRequest, opts ...gax.CallOption) (*pubsubpb.Snapshot, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.CreateSnapshot[0:len(c.CallOptions.CreateSnapshot):len(c.CallOptions.CreateSnapshot)], opts...)
diff --git a/redis/apiv1/doc.go b/redis/apiv1/doc.go
index 3a96791..8d90ea3 100644
--- a/redis/apiv1/doc.go
+++ b/redis/apiv1/doc.go
@@ -85,4 +85,4 @@
return "UNKNOWN"
}
-const versionClient = "20190225"
+const versionClient = "20190306"
diff --git a/redis/apiv1beta1/doc.go b/redis/apiv1beta1/doc.go
index a3f7951..3177967 100644
--- a/redis/apiv1beta1/doc.go
+++ b/redis/apiv1beta1/doc.go
@@ -88,4 +88,4 @@
return "UNKNOWN"
}
-const versionClient = "20190225"
+const versionClient = "20190306"
diff --git a/scheduler/apiv1beta1/cloud_scheduler_client.go b/scheduler/apiv1beta1/cloud_scheduler_client.go
index 37fd1e5..deab68c 100644
--- a/scheduler/apiv1beta1/cloud_scheduler_client.go
+++ b/scheduler/apiv1beta1/cloud_scheduler_client.go
@@ -205,13 +205,14 @@
// UpdateJob updates a job.
//
-// If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job does
-// not exist, NOT_FOUND is returned.
+// If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is
+// returned. If the job does not exist, NOT_FOUND is returned.
//
// If UpdateJob does not successfully return, it is possible for the
-// job to be in an [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job in this state may
-// not be executed. If this happens, retry the UpdateJob request
-// until a successful response is received.
+// job to be in an
+// [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED]
+// state. A job in this state may not be executed. If this happens, retry the
+// UpdateJob request until a successful response is received.
func (c *CloudSchedulerClient) UpdateJob(ctx context.Context, req *schedulerpb.UpdateJobRequest, opts ...gax.CallOption) (*schedulerpb.Job, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.UpdateJob[0:len(c.CallOptions.UpdateJob):len(c.CallOptions.UpdateJob)], opts...)
@@ -242,10 +243,14 @@
// PauseJob pauses a job.
//
// If a job is paused then the system will stop executing the job
-// until it is re-enabled via [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The
-// state of the job is stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it
-// will be set to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]
-// to be paused.
+// until it is re-enabled via
+// [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The
+// state of the job is stored in
+// [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set
+// to [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A
+// job must be in
+// [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be
+// paused.
func (c *CloudSchedulerClient) PauseJob(ctx context.Context, req *schedulerpb.PauseJobRequest, opts ...gax.CallOption) (*schedulerpb.Job, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.PauseJob[0:len(c.CallOptions.PauseJob):len(c.CallOptions.PauseJob)], opts...)
@@ -263,10 +268,15 @@
// ResumeJob resume a job.
//
-// This method reenables a job after it has been [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The
-// state of a job is stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it
-// will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job must be in
-// [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed.
+// This method reenables a job after it has been
+// [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The
+// state of a job is stored in
+// [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this
+// method it will be set to
+// [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A
+// job must be in
+// [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be
+// resumed.
func (c *CloudSchedulerClient) ResumeJob(ctx context.Context, req *schedulerpb.ResumeJobRequest, opts ...gax.CallOption) (*schedulerpb.Job, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ResumeJob[0:len(c.CallOptions.ResumeJob):len(c.CallOptions.ResumeJob)], opts...)
diff --git a/scheduler/apiv1beta1/doc.go b/scheduler/apiv1beta1/doc.go
index fc66140..14010ec 100644
--- a/scheduler/apiv1beta1/doc.go
+++ b/scheduler/apiv1beta1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/securitycenter/apiv1beta1/doc.go b/securitycenter/apiv1beta1/doc.go
index c9f0358..72d5639 100644
--- a/securitycenter/apiv1beta1/doc.go
+++ b/securitycenter/apiv1beta1/doc.go
@@ -87,4 +87,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/spanner/admin/database/apiv1/database_admin_client.go b/spanner/admin/database/apiv1/database_admin_client.go
index 25afc5e..1c42bff 100644
--- a/spanner/admin/database/apiv1/database_admin_client.go
+++ b/spanner/admin/database/apiv1/database_admin_client.go
@@ -201,8 +201,8 @@
// have a name of the format <database_name>/operations/<operation_id> and
// can be used to track preparation of the database. The
// [metadata][google.longrunning.Operation.metadata] field type is
-// [CreateDatabaseMetadata][google.spanner.admin.database.v1.CreateDatabaseMetadata]. The
-// [response][google.longrunning.Operation.response] field type is
+// [CreateDatabaseMetadata][google.spanner.admin.database.v1.CreateDatabaseMetadata].
+// The [response][google.longrunning.Operation.response] field type is
// [Database][google.spanner.admin.database.v1.Database], if successful.
func (c *DatabaseAdminClient) CreateDatabase(ctx context.Context, req *databasepb.CreateDatabaseRequest, opts ...gax.CallOption) (*CreateDatabaseOperation, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
@@ -243,7 +243,8 @@
// the format <database_name>/operations/<operation_id> and can be used to
// track execution of the schema change(s). The
// [metadata][google.longrunning.Operation.metadata] field type is
-// [UpdateDatabaseDdlMetadata][google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata]. The operation has no response.
+// [UpdateDatabaseDdlMetadata][google.spanner.admin.database.v1.UpdateDatabaseDdlMetadata].
+// The operation has no response.
func (c *DatabaseAdminClient) UpdateDatabaseDdl(ctx context.Context, req *databasepb.UpdateDatabaseDdlRequest, opts ...gax.CallOption) (*UpdateDatabaseDdlOperation, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.UpdateDatabaseDdl[0:len(c.CallOptions.UpdateDatabaseDdl):len(c.CallOptions.UpdateDatabaseDdl)], opts...)
diff --git a/spanner/admin/database/apiv1/doc.go b/spanner/admin/database/apiv1/doc.go
index 9ae4794..6ac0514 100644
--- a/spanner/admin/database/apiv1/doc.go
+++ b/spanner/admin/database/apiv1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/spanner/admin/instance/apiv1/doc.go b/spanner/admin/instance/apiv1/doc.go
index fdd19f1..736a236 100644
--- a/spanner/admin/instance/apiv1/doc.go
+++ b/spanner/admin/instance/apiv1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/spanner/admin/instance/apiv1/instance_admin_client.go b/spanner/admin/instance/apiv1/instance_admin_client.go
index d65742d..2c23989 100644
--- a/spanner/admin/instance/apiv1/instance_admin_client.go
+++ b/spanner/admin/instance/apiv1/instance_admin_client.go
@@ -353,9 +353,9 @@
// Until completion of the returned operation:
//
// Cancelling the operation sets its metadata's
-// [cancel_time][google.spanner.admin.instance.v1.UpdateInstanceMetadata.cancel_time], and begins
-// restoring resources to their pre-request values. The operation
-// is guaranteed to succeed at undoing all resource changes,
+// [cancel_time][google.spanner.admin.instance.v1.UpdateInstanceMetadata.cancel_time],
+// and begins restoring resources to their pre-request values. The
+// operation is guaranteed to succeed at undoing all resource changes,
// after which point it terminates with a CANCELLED status.
//
// All other attempts to modify the instance are rejected.
diff --git a/spanner/apiv1/doc.go b/spanner/apiv1/doc.go
index cecb391..cbf1e01 100644
--- a/spanner/apiv1/doc.go
+++ b/spanner/apiv1/doc.go
@@ -89,4 +89,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/spanner/apiv1/mock_test.go b/spanner/apiv1/mock_test.go
index 2a4fc5b..3a85cd3 100644
--- a/spanner/apiv1/mock_test.go
+++ b/spanner/apiv1/mock_test.go
@@ -138,6 +138,18 @@
return nil
}
+func (s *mockSpannerServer) ExecuteBatchDml(ctx context.Context, req *spannerpb.ExecuteBatchDmlRequest) (*spannerpb.ExecuteBatchDmlResponse, error) {
+ md, _ := metadata.FromIncomingContext(ctx)
+ if xg := md["x-goog-api-client"]; len(xg) == 0 || !strings.Contains(xg[0], "gl-go/") {
+ return nil, fmt.Errorf("x-goog-api-client = %v, expected gl-go key", xg)
+ }
+ s.reqs = append(s.reqs, req)
+ if s.err != nil {
+ return nil, s.err
+ }
+ return s.resps[0].(*spannerpb.ExecuteBatchDmlResponse), nil
+}
+
func (s *mockSpannerServer) Read(ctx context.Context, req *spannerpb.ReadRequest) (*spannerpb.ResultSet, error) {
md, _ := metadata.FromIncomingContext(ctx)
if xg := md["x-goog-api-client"]; len(xg) == 0 || !strings.Contains(xg[0], "gl-go/") {
@@ -631,6 +643,74 @@
}
_ = resp
}
+func TestSpannerExecuteBatchDml(t *testing.T) {
+ var expectedResponse *spannerpb.ExecuteBatchDmlResponse = &spannerpb.ExecuteBatchDmlResponse{}
+
+ mockSpanner.err = nil
+ mockSpanner.reqs = nil
+
+ mockSpanner.resps = append(mockSpanner.resps[:0], expectedResponse)
+
+ var formattedSession string = fmt.Sprintf("projects/%s/instances/%s/databases/%s/sessions/%s", "[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]")
+ var transaction *spannerpb.TransactionSelector = &spannerpb.TransactionSelector{}
+ var statements []*spannerpb.ExecuteBatchDmlRequest_Statement = nil
+ var seqno int64 = 109325920
+ var request = &spannerpb.ExecuteBatchDmlRequest{
+ Session: formattedSession,
+ Transaction: transaction,
+ Statements: statements,
+ Seqno: seqno,
+ }
+
+ c, err := NewClient(context.Background(), clientOpt)
+ if err != nil {
+ t.Fatal(err)
+ }
+
+ resp, err := c.ExecuteBatchDml(context.Background(), request)
+
+ if err != nil {
+ t.Fatal(err)
+ }
+
+ if want, got := request, mockSpanner.reqs[0]; !proto.Equal(want, got) {
+ t.Errorf("wrong request %q, want %q", got, want)
+ }
+
+ if want, got := expectedResponse, resp; !proto.Equal(want, got) {
+ t.Errorf("wrong response %q, want %q)", got, want)
+ }
+}
+
+func TestSpannerExecuteBatchDmlError(t *testing.T) {
+ errCode := codes.PermissionDenied
+ mockSpanner.err = gstatus.Error(errCode, "test error")
+
+ var formattedSession string = fmt.Sprintf("projects/%s/instances/%s/databases/%s/sessions/%s", "[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]")
+ var transaction *spannerpb.TransactionSelector = &spannerpb.TransactionSelector{}
+ var statements []*spannerpb.ExecuteBatchDmlRequest_Statement = nil
+ var seqno int64 = 109325920
+ var request = &spannerpb.ExecuteBatchDmlRequest{
+ Session: formattedSession,
+ Transaction: transaction,
+ Statements: statements,
+ Seqno: seqno,
+ }
+
+ c, err := NewClient(context.Background(), clientOpt)
+ if err != nil {
+ t.Fatal(err)
+ }
+
+ resp, err := c.ExecuteBatchDml(context.Background(), request)
+
+ if st, ok := gstatus.FromError(err); !ok {
+ t.Errorf("got error %v, expected grpc error", err)
+ } else if c := st.Code(); c != errCode {
+ t.Errorf("got error code %q, want %q", c, errCode)
+ }
+ _ = resp
+}
func TestSpannerRead(t *testing.T) {
var expectedResponse *spannerpb.ResultSet = &spannerpb.ResultSet{}
diff --git a/spanner/apiv1/spanner_client.go b/spanner/apiv1/spanner_client.go
index 9796d32..35743fb 100644
--- a/spanner/apiv1/spanner_client.go
+++ b/spanner/apiv1/spanner_client.go
@@ -40,6 +40,7 @@
DeleteSession []gax.CallOption
ExecuteSql []gax.CallOption
ExecuteStreamingSql []gax.CallOption
+ ExecuteBatchDml []gax.CallOption
Read []gax.CallOption
StreamingRead []gax.CallOption
BeginTransaction []gax.CallOption
@@ -89,6 +90,7 @@
DeleteSession: retry[[2]string{"default", "idempotent"}],
ExecuteSql: retry[[2]string{"default", "idempotent"}],
ExecuteStreamingSql: retry[[2]string{"streaming", "non_idempotent"}],
+ ExecuteBatchDml: retry[[2]string{"default", "idempotent"}],
Read: retry[[2]string{"default", "idempotent"}],
StreamingRead: retry[[2]string{"streaming", "non_idempotent"}],
BeginTransaction: retry[[2]string{"default", "idempotent"}],
@@ -246,7 +248,9 @@
return it
}
-// DeleteSession ends a session, releasing server resources associated with it.
+// DeleteSession ends a session, releasing server resources associated with it. This will
+// asynchronously trigger cancellation of any operations that are running with
+// this session.
func (c *Client) DeleteSession(ctx context.Context, req *spannerpb.DeleteSessionRequest, opts ...gax.CallOption) error {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.DeleteSession[0:len(c.CallOptions.DeleteSession):len(c.CallOptions.DeleteSession)], opts...)
@@ -265,10 +269,12 @@
//
// Operations inside read-write transactions might return ABORTED. If
// this occurs, the application should restart the transaction from
-// the beginning. See [Transaction][google.spanner.v1.Transaction] for more details.
+// the beginning. See [Transaction][google.spanner.v1.Transaction] for more
+// details.
//
// Larger result sets can be fetched in streaming fashion by calling
-// [ExecuteStreamingSql][google.spanner.v1.Spanner.ExecuteStreamingSql] instead.
+// [ExecuteStreamingSql][google.spanner.v1.Spanner.ExecuteStreamingSql]
+// instead.
func (c *Client) ExecuteSql(ctx context.Context, req *spannerpb.ExecuteSqlRequest, opts ...gax.CallOption) (*spannerpb.ResultSet, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ExecuteSql[0:len(c.CallOptions.ExecuteSql):len(c.CallOptions.ExecuteSql)], opts...)
@@ -284,11 +290,11 @@
return resp, nil
}
-// ExecuteStreamingSql like [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql], except returns the result
-// set as a stream. Unlike [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql], there
-// is no limit on the size of the returned result set. However, no
-// individual row in the result set can exceed 100 MiB, and no
-// column value can exceed 10 MiB.
+// ExecuteStreamingSql like [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql], except returns the
+// result set as a stream. Unlike
+// [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql], there is no limit on
+// the size of the returned result set. However, no individual row in the
+// result set can exceed 100 MiB, and no column value can exceed 10 MiB.
func (c *Client) ExecuteStreamingSql(ctx context.Context, req *spannerpb.ExecuteSqlRequest, opts ...gax.CallOption) (spannerpb.Spanner_ExecuteStreamingSqlClient, error) {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.ExecuteStreamingSql[0:len(c.CallOptions.ExecuteStreamingSql):len(c.CallOptions.ExecuteStreamingSql)], opts...)
@@ -304,16 +310,51 @@
return resp, nil
}
+// ExecuteBatchDml executes a batch of SQL DML statements. This method allows many statements
+// to be run with lower latency than submitting them sequentially with
+// [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
+//
+// Statements are executed in order, sequentially.
+// [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
+// [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
+// statement fails, its error status will be returned as part of the
+// [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
+// stop at the first failed statement; the remaining statements will not run.
+//
+// ExecuteBatchDml is expected to return an OK status with a response even if
+// there was an error while processing one of the DML statements. Clients must
+// inspect response.status to determine if there were any errors while
+// processing the request.
+//
+// See more details in
+// [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
+// [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
+func (c *Client) ExecuteBatchDml(ctx context.Context, req *spannerpb.ExecuteBatchDmlRequest, opts ...gax.CallOption) (*spannerpb.ExecuteBatchDmlResponse, error) {
+ ctx = insertMetadata(ctx, c.xGoogMetadata)
+ opts = append(c.CallOptions.ExecuteBatchDml[0:len(c.CallOptions.ExecuteBatchDml):len(c.CallOptions.ExecuteBatchDml)], opts...)
+ var resp *spannerpb.ExecuteBatchDmlResponse
+ err := gax.Invoke(ctx, func(ctx context.Context, settings gax.CallSettings) error {
+ var err error
+ resp, err = c.client.ExecuteBatchDml(ctx, req, settings.GRPC...)
+ return err
+ }, opts...)
+ if err != nil {
+ return nil, err
+ }
+ return resp, nil
+}
+
// Read reads rows from the database using key lookups and scans, as a
// simple key/value style alternative to
-// [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql]. This method cannot be used to
-// return a result set larger than 10 MiB; if the read matches more
+// [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql]. This method cannot be
+// used to return a result set larger than 10 MiB; if the read matches more
// data than that, the read fails with a FAILED_PRECONDITION
// error.
//
// Reads inside read-write transactions might return ABORTED. If
// this occurs, the application should restart the transaction from
-// the beginning. See [Transaction][google.spanner.v1.Transaction] for more details.
+// the beginning. See [Transaction][google.spanner.v1.Transaction] for more
+// details.
//
// Larger result sets can be yielded in streaming fashion by calling
// [StreamingRead][google.spanner.v1.Spanner.StreamingRead] instead.
@@ -332,9 +373,9 @@
return resp, nil
}
-// StreamingRead like [Read][google.spanner.v1.Spanner.Read], except returns the result set as a
-// stream. Unlike [Read][google.spanner.v1.Spanner.Read], there is no limit on the
-// size of the returned result set. However, no individual row in
+// StreamingRead like [Read][google.spanner.v1.Spanner.Read], except returns the result set
+// as a stream. Unlike [Read][google.spanner.v1.Spanner.Read], there is no
+// limit on the size of the returned result set. However, no individual row in
// the result set can exceed 100 MiB, and no column value can exceed
// 10 MiB.
func (c *Client) StreamingRead(ctx context.Context, req *spannerpb.ReadRequest, opts ...gax.CallOption) (spannerpb.Spanner_StreamingReadClient, error) {
@@ -353,7 +394,8 @@
}
// BeginTransaction begins a new transaction. This step can often be skipped:
-// [Read][google.spanner.v1.Spanner.Read], [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql] and
+// [Read][google.spanner.v1.Spanner.Read],
+// [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql] and
// [Commit][google.spanner.v1.Spanner.Commit] can begin a new transaction as a
// side-effect.
func (c *Client) BeginTransaction(ctx context.Context, req *spannerpb.BeginTransactionRequest, opts ...gax.CallOption) (*spannerpb.Transaction, error) {
@@ -396,8 +438,9 @@
// Rollback rolls back a transaction, releasing any locks it holds. It is a good
// idea to call this for any transaction that includes one or more
-// [Read][google.spanner.v1.Spanner.Read] or [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql] requests and
-// ultimately decides not to commit.
+// [Read][google.spanner.v1.Spanner.Read] or
+// [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql] requests and ultimately
+// decides not to commit.
//
// Rollback returns OK if it successfully aborts the transaction, the
// transaction was already aborted, or the transaction is not
@@ -415,10 +458,11 @@
// PartitionQuery creates a set of partition tokens that can be used to execute a query
// operation in parallel. Each of the returned partition tokens can be used
-// by [ExecuteStreamingSql][google.spanner.v1.Spanner.ExecuteStreamingSql] to specify a subset
-// of the query result to read. The same session and read-only transaction
-// must be used by the PartitionQueryRequest used to create the
-// partition tokens and the ExecuteSqlRequests that use the partition tokens.
+// by [ExecuteStreamingSql][google.spanner.v1.Spanner.ExecuteStreamingSql] to
+// specify a subset of the query result to read. The same session and
+// read-only transaction must be used by the PartitionQueryRequest used to
+// create the partition tokens and the ExecuteSqlRequests that use the
+// partition tokens.
//
// Partition tokens become invalid when the session used to create them
// is deleted, is idle for too long, begins a new transaction, or becomes too
@@ -441,12 +485,13 @@
// PartitionRead creates a set of partition tokens that can be used to execute a read
// operation in parallel. Each of the returned partition tokens can be used
-// by [StreamingRead][google.spanner.v1.Spanner.StreamingRead] to specify a subset of the read
-// result to read. The same session and read-only transaction must be used by
-// the PartitionReadRequest used to create the partition tokens and the
-// ReadRequests that use the partition tokens. There are no ordering
-// guarantees on rows returned among the returned partition tokens, or even
-// within each individual StreamingRead call issued with a partition_token.
+// by [StreamingRead][google.spanner.v1.Spanner.StreamingRead] to specify a
+// subset of the read result to read. The same session and read-only
+// transaction must be used by the PartitionReadRequest used to create the
+// partition tokens and the ReadRequests that use the partition tokens. There
+// are no ordering guarantees on rows returned among the returned partition
+// tokens, or even within each individual StreamingRead call issued with a
+// partition_token.
//
// Partition tokens become invalid when the session used to create them
// is deleted, is idle for too long, begins a new transaction, or becomes too
diff --git a/spanner/apiv1/spanner_client_example_test.go b/spanner/apiv1/spanner_client_example_test.go
index 6652bba..342cf41 100644
--- a/spanner/apiv1/spanner_client_example_test.go
+++ b/spanner/apiv1/spanner_client_example_test.go
@@ -156,6 +156,24 @@
}
}
+func ExampleClient_ExecuteBatchDml() {
+ ctx := context.Background()
+ c, err := spanner.NewClient(ctx)
+ if err != nil {
+ // TODO: Handle error.
+ }
+
+ req := &spannerpb.ExecuteBatchDmlRequest{
+ // TODO: Fill request struct fields.
+ }
+ resp, err := c.ExecuteBatchDml(ctx, req)
+ if err != nil {
+ // TODO: Handle error.
+ }
+ // TODO: Use resp.
+ _ = resp
+}
+
func ExampleClient_Read() {
ctx := context.Background()
c, err := spanner.NewClient(ctx)
diff --git a/speech/apiv1/doc.go b/speech/apiv1/doc.go
index 9441e2d..f735d3a 100644
--- a/speech/apiv1/doc.go
+++ b/speech/apiv1/doc.go
@@ -85,4 +85,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/speech/apiv1p1beta1/doc.go b/speech/apiv1p1beta1/doc.go
index d0d0e82..d917b52 100644
--- a/speech/apiv1p1beta1/doc.go
+++ b/speech/apiv1p1beta1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/talent/apiv4beta1/doc.go b/talent/apiv4beta1/doc.go
index 5517b59..bc6a823 100644
--- a/talent/apiv4beta1/doc.go
+++ b/talent/apiv4beta1/doc.go
@@ -88,4 +88,4 @@
return "UNKNOWN"
}
-const versionClient = "20190225"
+const versionClient = "20190306"
diff --git a/talent/apiv4beta1/job_client.go b/talent/apiv4beta1/job_client.go
index be78dbb..453aa7f 100644
--- a/talent/apiv4beta1/job_client.go
+++ b/talent/apiv4beta1/job_client.go
@@ -252,11 +252,13 @@
return err
}
-// SearchJobs searches for jobs using the provided [SearchJobsRequest][google.cloud.talent.v4beta1.SearchJobsRequest].
+// SearchJobs searches for jobs using the provided
+// [SearchJobsRequest][google.cloud.talent.v4beta1.SearchJobsRequest].
//
-// This call constrains the [visibility][google.cloud.talent.v4beta1.Job.visibility] of jobs
-// present in the database, and only returns jobs that the caller has
-// permission to search against.
+// This call constrains the
+// [visibility][google.cloud.talent.v4beta1.Job.visibility] of jobs present in
+// the database, and only returns jobs that the caller has permission to
+// search against.
func (c *JobClient) SearchJobs(ctx context.Context, req *talentpb.SearchJobsRequest, opts ...gax.CallOption) *SearchJobsResponse_MatchingJobIterator {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.SearchJobs[0:len(c.CallOptions.SearchJobs):len(c.CallOptions.SearchJobs)], opts...)
@@ -293,16 +295,18 @@
return it
}
-// SearchJobsForAlert searches for jobs using the provided [SearchJobsRequest][google.cloud.talent.v4beta1.SearchJobsRequest].
+// SearchJobsForAlert searches for jobs using the provided
+// [SearchJobsRequest][google.cloud.talent.v4beta1.SearchJobsRequest].
//
// This API call is intended for the use case of targeting passive job
// seekers (for example, job seekers who have signed up to receive email
// alerts about potential job opportunities), and has different algorithmic
// adjustments that are targeted to passive job seekers.
//
-// This call constrains the [visibility][google.cloud.talent.v4beta1.Job.visibility] of jobs
-// present in the database, and only returns jobs the caller has
-// permission to search against.
+// This call constrains the
+// [visibility][google.cloud.talent.v4beta1.Job.visibility] of jobs present in
+// the database, and only returns jobs the caller has permission to search
+// against.
func (c *JobClient) SearchJobsForAlert(ctx context.Context, req *talentpb.SearchJobsRequest, opts ...gax.CallOption) *SearchJobsResponse_MatchingJobIterator {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.SearchJobsForAlert[0:len(c.CallOptions.SearchJobsForAlert):len(c.CallOptions.SearchJobsForAlert)], opts...)
diff --git a/talent/apiv4beta1/profile_client.go b/talent/apiv4beta1/profile_client.go
index 2fa605c..3ef64ad 100644
--- a/talent/apiv4beta1/profile_client.go
+++ b/talent/apiv4beta1/profile_client.go
@@ -232,7 +232,9 @@
// For example, search by raw queries "software engineer in Mountain View" or
// search by structured filters (location filter, education filter, etc.).
//
-// See [SearchProfilesRequest][google.cloud.talent.v4beta1.SearchProfilesRequest] for more information.
+// See
+// [SearchProfilesRequest][google.cloud.talent.v4beta1.SearchProfilesRequest]
+// for more information.
func (c *ProfileClient) SearchProfiles(ctx context.Context, req *talentpb.SearchProfilesRequest, opts ...gax.CallOption) *HistogramQueryResultIterator {
ctx = insertMetadata(ctx, c.xGoogMetadata)
opts = append(c.CallOptions.SearchProfiles[0:len(c.CallOptions.SearchProfiles):len(c.CallOptions.SearchProfiles)], opts...)
diff --git a/talent/apiv4beta1/resume_client.go b/talent/apiv4beta1/resume_client.go
index 7166c54..da2ed4f 100644
--- a/talent/apiv4beta1/resume_client.go
+++ b/talent/apiv4beta1/resume_client.go
@@ -101,8 +101,9 @@
c.xGoogMetadata = metadata.Pairs("x-goog-api-client", gax.XGoogHeader(kv...))
}
-// ParseResume parses a resume into a [Profile][google.cloud.talent.v4beta1.Profile]. The API attempts to fill out the
-// following profile fields if present within the resume:
+// ParseResume parses a resume into a [Profile][google.cloud.talent.v4beta1.Profile]. The
+// API attempts to fill out the following profile fields if present within the
+// resume:
//
// personNames
//
diff --git a/texttospeech/apiv1/doc.go b/texttospeech/apiv1/doc.go
index 40598ad..e11edfb 100644
--- a/texttospeech/apiv1/doc.go
+++ b/texttospeech/apiv1/doc.go
@@ -87,4 +87,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/trace/apiv1/doc.go b/trace/apiv1/doc.go
index 6dc9a06..9c38acd 100644
--- a/trace/apiv1/doc.go
+++ b/trace/apiv1/doc.go
@@ -94,4 +94,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/trace/apiv2/doc.go b/trace/apiv2/doc.go
index 00c98cf..1407c5d 100644
--- a/trace/apiv2/doc.go
+++ b/trace/apiv2/doc.go
@@ -91,4 +91,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/videointelligence/apiv1/doc.go b/videointelligence/apiv1/doc.go
index 0099069..84714c6 100644
--- a/videointelligence/apiv1/doc.go
+++ b/videointelligence/apiv1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/videointelligence/apiv1beta1/doc.go b/videointelligence/apiv1beta1/doc.go
index c33bc19..1997148 100644
--- a/videointelligence/apiv1beta1/doc.go
+++ b/videointelligence/apiv1beta1/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/videointelligence/apiv1beta2/doc.go b/videointelligence/apiv1beta2/doc.go
index e89e696..d3efc1d 100644
--- a/videointelligence/apiv1beta2/doc.go
+++ b/videointelligence/apiv1beta2/doc.go
@@ -86,4 +86,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/vision/apiv1/doc.go b/vision/apiv1/doc.go
index a533990..618f9af 100644
--- a/vision/apiv1/doc.go
+++ b/vision/apiv1/doc.go
@@ -89,4 +89,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
diff --git a/vision/apiv1/product_search_client.go b/vision/apiv1/product_search_client.go
index 37cb88c..91a3ac0 100644
--- a/vision/apiv1/product_search_client.go
+++ b/vision/apiv1/product_search_client.go
@@ -128,16 +128,18 @@
// Manages Products and ProductSets of reference images for use in product
// search. It uses the following resource model:
//
-// The API has a collection of [ProductSet][google.cloud.vision.v1.ProductSet] resources, named
-// projects/*/locations/*/productSets/*, which acts as a way to put different
-// products into groups to limit identification.
+// The API has a collection of [ProductSet][google.cloud.vision.v1.ProductSet]
+// resources, named projects/*/locations/*/productSets/*, which acts as a way
+// to put different products into groups to limit identification.
//
// In parallel,
//
-// The API has a collection of [Product][google.cloud.vision.v1.Product] resources, named
+// The API has a collection of [Product][google.cloud.vision.v1.Product]
+// resources, named
// projects/*/locations/*/products/*
//
-// Each [Product][google.cloud.vision.v1.Product] has a collection of [ReferenceImage][google.cloud.vision.v1.ReferenceImage] resources, named
+// Each [Product][google.cloud.vision.v1.Product] has a collection of
+// [ReferenceImage][google.cloud.vision.v1.ReferenceImage] resources, named
// projects/*/locations/*/products/*/referenceImages/*
func NewProductSearchClient(ctx context.Context, opts ...option.ClientOption) (*ProductSearchClient, error) {
conn, err := transport.DialGRPC(ctx, append(defaultProductSearchClientOptions(), opts...)...)
@@ -654,8 +656,8 @@
// ImportProductSets asynchronous API that imports a list of reference images to specified
// product sets based on a list of image information.
//
-// The [google.longrunning.Operation][google.longrunning.Operation] API can be used to keep track of the
-// progress and results of the request.
+// The [google.longrunning.Operation][google.longrunning.Operation] API can be
+// used to keep track of the progress and results of the request.
// Operation.metadata contains BatchOperationMetadata. (progress)
// Operation.response contains ImportProductSetsResponse. (results)
//
diff --git a/vision/apiv1p1beta1/doc.go b/vision/apiv1p1beta1/doc.go
index bf40b31..c4e2b1e 100644
--- a/vision/apiv1p1beta1/doc.go
+++ b/vision/apiv1p1beta1/doc.go
@@ -90,4 +90,4 @@
return "UNKNOWN"
}
-const versionClient = "20190121"
+const versionClient = "20190306"
