1// Copyright 2021 Google LLC 2// 3// Licensed under the Apache License, Version 2.0 (the "License"); 4// you may not use this file except in compliance with the License. 5// You may obtain a copy of the License at 6// 7// https://www.apache.org/licenses/LICENSE-2.0 8// 9// Unless required by applicable law or agreed to in writing, software 10// distributed under the License is distributed on an "AS IS" BASIS, 11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12// See the License for the specific language governing permissions and 13// limitations under the License. 14 15// Code generated by protoc-gen-go_gapic. DO NOT EDIT. 16 17package cloudtasks_test 18 19import ( 20 "context" 21 22 cloudtasks "cloud.google.com/go/cloudtasks/apiv2beta2" 23 "google.golang.org/api/iterator" 24 taskspb "google.golang.org/genproto/googleapis/cloud/tasks/v2beta2" 25 iampb "google.golang.org/genproto/googleapis/iam/v1" 26) 27 28func ExampleNewClient() { 29 ctx := context.Background() 30 c, err := cloudtasks.NewClient(ctx) 31 if err != nil { 32 // TODO: Handle error. 33 } 34 defer c.Close() 35 36 // TODO: Use client. 37 _ = c 38} 39 40func ExampleClient_ListQueues() { 41 ctx := context.Background() 42 c, err := cloudtasks.NewClient(ctx) 43 if err != nil { 44 // TODO: Handle error. 45 } 46 defer c.Close() 47 48 req := &taskspb.ListQueuesRequest{ 49 // TODO: Fill request struct fields. 50 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#ListQueuesRequest. 51 } 52 it := c.ListQueues(ctx, req) 53 for { 54 resp, err := it.Next() 55 if err == iterator.Done { 56 break 57 } 58 if err != nil { 59 // TODO: Handle error. 60 } 61 // TODO: Use resp. 62 _ = resp 63 } 64} 65 66func ExampleClient_GetQueue() { 67 ctx := context.Background() 68 c, err := cloudtasks.NewClient(ctx) 69 if err != nil { 70 // TODO: Handle error. 71 } 72 defer c.Close() 73 74 req := &taskspb.GetQueueRequest{ 75 // TODO: Fill request struct fields. 76 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#GetQueueRequest. 77 } 78 resp, err := c.GetQueue(ctx, req) 79 if err != nil { 80 // TODO: Handle error. 81 } 82 // TODO: Use resp. 83 _ = resp 84} 85 86func ExampleClient_CreateQueue() { 87 ctx := context.Background() 88 c, err := cloudtasks.NewClient(ctx) 89 if err != nil { 90 // TODO: Handle error. 91 } 92 defer c.Close() 93 94 req := &taskspb.CreateQueueRequest{ 95 // TODO: Fill request struct fields. 96 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#CreateQueueRequest. 97 } 98 resp, err := c.CreateQueue(ctx, req) 99 if err != nil { 100 // TODO: Handle error. 101 } 102 // TODO: Use resp. 103 _ = resp 104} 105 106func ExampleClient_UpdateQueue() { 107 ctx := context.Background() 108 c, err := cloudtasks.NewClient(ctx) 109 if err != nil { 110 // TODO: Handle error. 111 } 112 defer c.Close() 113 114 req := &taskspb.UpdateQueueRequest{ 115 // TODO: Fill request struct fields. 116 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#UpdateQueueRequest. 117 } 118 resp, err := c.UpdateQueue(ctx, req) 119 if err != nil { 120 // TODO: Handle error. 121 } 122 // TODO: Use resp. 123 _ = resp 124} 125 126func ExampleClient_DeleteQueue() { 127 ctx := context.Background() 128 c, err := cloudtasks.NewClient(ctx) 129 if err != nil { 130 // TODO: Handle error. 131 } 132 defer c.Close() 133 134 req := &taskspb.DeleteQueueRequest{ 135 // TODO: Fill request struct fields. 136 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#DeleteQueueRequest. 137 } 138 err = c.DeleteQueue(ctx, req) 139 if err != nil { 140 // TODO: Handle error. 141 } 142} 143 144func ExampleClient_PurgeQueue() { 145 ctx := context.Background() 146 c, err := cloudtasks.NewClient(ctx) 147 if err != nil { 148 // TODO: Handle error. 149 } 150 defer c.Close() 151 152 req := &taskspb.PurgeQueueRequest{ 153 // TODO: Fill request struct fields. 154 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#PurgeQueueRequest. 155 } 156 resp, err := c.PurgeQueue(ctx, req) 157 if err != nil { 158 // TODO: Handle error. 159 } 160 // TODO: Use resp. 161 _ = resp 162} 163 164func ExampleClient_PauseQueue() { 165 ctx := context.Background() 166 c, err := cloudtasks.NewClient(ctx) 167 if err != nil { 168 // TODO: Handle error. 169 } 170 defer c.Close() 171 172 req := &taskspb.PauseQueueRequest{ 173 // TODO: Fill request struct fields. 174 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#PauseQueueRequest. 175 } 176 resp, err := c.PauseQueue(ctx, req) 177 if err != nil { 178 // TODO: Handle error. 179 } 180 // TODO: Use resp. 181 _ = resp 182} 183 184func ExampleClient_ResumeQueue() { 185 ctx := context.Background() 186 c, err := cloudtasks.NewClient(ctx) 187 if err != nil { 188 // TODO: Handle error. 189 } 190 defer c.Close() 191 192 req := &taskspb.ResumeQueueRequest{ 193 // TODO: Fill request struct fields. 194 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#ResumeQueueRequest. 195 } 196 resp, err := c.ResumeQueue(ctx, req) 197 if err != nil { 198 // TODO: Handle error. 199 } 200 // TODO: Use resp. 201 _ = resp 202} 203 204func ExampleClient_GetIamPolicy() { 205 ctx := context.Background() 206 c, err := cloudtasks.NewClient(ctx) 207 if err != nil { 208 // TODO: Handle error. 209 } 210 defer c.Close() 211 212 req := &iampb.GetIamPolicyRequest{ 213 // TODO: Fill request struct fields. 214 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/iam/v1#GetIamPolicyRequest. 215 } 216 resp, err := c.GetIamPolicy(ctx, req) 217 if err != nil { 218 // TODO: Handle error. 219 } 220 // TODO: Use resp. 221 _ = resp 222} 223 224func ExampleClient_SetIamPolicy() { 225 ctx := context.Background() 226 c, err := cloudtasks.NewClient(ctx) 227 if err != nil { 228 // TODO: Handle error. 229 } 230 defer c.Close() 231 232 req := &iampb.SetIamPolicyRequest{ 233 // TODO: Fill request struct fields. 234 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/iam/v1#SetIamPolicyRequest. 235 } 236 resp, err := c.SetIamPolicy(ctx, req) 237 if err != nil { 238 // TODO: Handle error. 239 } 240 // TODO: Use resp. 241 _ = resp 242} 243 244func ExampleClient_TestIamPermissions() { 245 ctx := context.Background() 246 c, err := cloudtasks.NewClient(ctx) 247 if err != nil { 248 // TODO: Handle error. 249 } 250 defer c.Close() 251 252 req := &iampb.TestIamPermissionsRequest{ 253 // TODO: Fill request struct fields. 254 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/iam/v1#TestIamPermissionsRequest. 255 } 256 resp, err := c.TestIamPermissions(ctx, req) 257 if err != nil { 258 // TODO: Handle error. 259 } 260 // TODO: Use resp. 261 _ = resp 262} 263 264func ExampleClient_ListTasks() { 265 ctx := context.Background() 266 c, err := cloudtasks.NewClient(ctx) 267 if err != nil { 268 // TODO: Handle error. 269 } 270 defer c.Close() 271 272 req := &taskspb.ListTasksRequest{ 273 // TODO: Fill request struct fields. 274 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#ListTasksRequest. 275 } 276 it := c.ListTasks(ctx, req) 277 for { 278 resp, err := it.Next() 279 if err == iterator.Done { 280 break 281 } 282 if err != nil { 283 // TODO: Handle error. 284 } 285 // TODO: Use resp. 286 _ = resp 287 } 288} 289 290func ExampleClient_GetTask() { 291 ctx := context.Background() 292 c, err := cloudtasks.NewClient(ctx) 293 if err != nil { 294 // TODO: Handle error. 295 } 296 defer c.Close() 297 298 req := &taskspb.GetTaskRequest{ 299 // TODO: Fill request struct fields. 300 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#GetTaskRequest. 301 } 302 resp, err := c.GetTask(ctx, req) 303 if err != nil { 304 // TODO: Handle error. 305 } 306 // TODO: Use resp. 307 _ = resp 308} 309 310func ExampleClient_CreateTask() { 311 ctx := context.Background() 312 c, err := cloudtasks.NewClient(ctx) 313 if err != nil { 314 // TODO: Handle error. 315 } 316 defer c.Close() 317 318 req := &taskspb.CreateTaskRequest{ 319 // TODO: Fill request struct fields. 320 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#CreateTaskRequest. 321 } 322 resp, err := c.CreateTask(ctx, req) 323 if err != nil { 324 // TODO: Handle error. 325 } 326 // TODO: Use resp. 327 _ = resp 328} 329 330func ExampleClient_DeleteTask() { 331 ctx := context.Background() 332 c, err := cloudtasks.NewClient(ctx) 333 if err != nil { 334 // TODO: Handle error. 335 } 336 defer c.Close() 337 338 req := &taskspb.DeleteTaskRequest{ 339 // TODO: Fill request struct fields. 340 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#DeleteTaskRequest. 341 } 342 err = c.DeleteTask(ctx, req) 343 if err != nil { 344 // TODO: Handle error. 345 } 346} 347 348func ExampleClient_LeaseTasks() { 349 ctx := context.Background() 350 c, err := cloudtasks.NewClient(ctx) 351 if err != nil { 352 // TODO: Handle error. 353 } 354 defer c.Close() 355 356 req := &taskspb.LeaseTasksRequest{ 357 // TODO: Fill request struct fields. 358 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#LeaseTasksRequest. 359 } 360 resp, err := c.LeaseTasks(ctx, req) 361 if err != nil { 362 // TODO: Handle error. 363 } 364 // TODO: Use resp. 365 _ = resp 366} 367 368func ExampleClient_AcknowledgeTask() { 369 ctx := context.Background() 370 c, err := cloudtasks.NewClient(ctx) 371 if err != nil { 372 // TODO: Handle error. 373 } 374 defer c.Close() 375 376 req := &taskspb.AcknowledgeTaskRequest{ 377 // TODO: Fill request struct fields. 378 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#AcknowledgeTaskRequest. 379 } 380 err = c.AcknowledgeTask(ctx, req) 381 if err != nil { 382 // TODO: Handle error. 383 } 384} 385 386func ExampleClient_RenewLease() { 387 ctx := context.Background() 388 c, err := cloudtasks.NewClient(ctx) 389 if err != nil { 390 // TODO: Handle error. 391 } 392 defer c.Close() 393 394 req := &taskspb.RenewLeaseRequest{ 395 // TODO: Fill request struct fields. 396 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#RenewLeaseRequest. 397 } 398 resp, err := c.RenewLease(ctx, req) 399 if err != nil { 400 // TODO: Handle error. 401 } 402 // TODO: Use resp. 403 _ = resp 404} 405 406func ExampleClient_CancelLease() { 407 ctx := context.Background() 408 c, err := cloudtasks.NewClient(ctx) 409 if err != nil { 410 // TODO: Handle error. 411 } 412 defer c.Close() 413 414 req := &taskspb.CancelLeaseRequest{ 415 // TODO: Fill request struct fields. 416 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#CancelLeaseRequest. 417 } 418 resp, err := c.CancelLease(ctx, req) 419 if err != nil { 420 // TODO: Handle error. 421 } 422 // TODO: Use resp. 423 _ = resp 424} 425 426func ExampleClient_RunTask() { 427 ctx := context.Background() 428 c, err := cloudtasks.NewClient(ctx) 429 if err != nil { 430 // TODO: Handle error. 431 } 432 defer c.Close() 433 434 req := &taskspb.RunTaskRequest{ 435 // TODO: Fill request struct fields. 436 // See https://pkg.go.dev/google.golang.org/genproto/googleapis/cloud/tasks/v2beta2#RunTaskRequest. 437 } 438 resp, err := c.RunTask(ctx, req) 439 if err != nil { 440 // TODO: Handle error. 441 } 442 // TODO: Use resp. 443 _ = resp 444} 445