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 } 51 it := c.ListQueues(ctx, req) 52 for { 53 resp, err := it.Next() 54 if err == iterator.Done { 55 break 56 } 57 if err != nil { 58 // TODO: Handle error. 59 } 60 // TODO: Use resp. 61 _ = resp 62 } 63} 64 65func ExampleClient_GetQueue() { 66 ctx := context.Background() 67 c, err := cloudtasks.NewClient(ctx) 68 if err != nil { 69 // TODO: Handle error. 70 } 71 defer c.Close() 72 73 req := &taskspb.GetQueueRequest{ 74 // TODO: Fill request struct fields. 75 } 76 resp, err := c.GetQueue(ctx, req) 77 if err != nil { 78 // TODO: Handle error. 79 } 80 // TODO: Use resp. 81 _ = resp 82} 83 84func ExampleClient_CreateQueue() { 85 ctx := context.Background() 86 c, err := cloudtasks.NewClient(ctx) 87 if err != nil { 88 // TODO: Handle error. 89 } 90 defer c.Close() 91 92 req := &taskspb.CreateQueueRequest{ 93 // TODO: Fill request struct fields. 94 } 95 resp, err := c.CreateQueue(ctx, req) 96 if err != nil { 97 // TODO: Handle error. 98 } 99 // TODO: Use resp. 100 _ = resp 101} 102 103func ExampleClient_UpdateQueue() { 104 ctx := context.Background() 105 c, err := cloudtasks.NewClient(ctx) 106 if err != nil { 107 // TODO: Handle error. 108 } 109 defer c.Close() 110 111 req := &taskspb.UpdateQueueRequest{ 112 // TODO: Fill request struct fields. 113 } 114 resp, err := c.UpdateQueue(ctx, req) 115 if err != nil { 116 // TODO: Handle error. 117 } 118 // TODO: Use resp. 119 _ = resp 120} 121 122func ExampleClient_DeleteQueue() { 123 ctx := context.Background() 124 c, err := cloudtasks.NewClient(ctx) 125 if err != nil { 126 // TODO: Handle error. 127 } 128 defer c.Close() 129 130 req := &taskspb.DeleteQueueRequest{ 131 // TODO: Fill request struct fields. 132 } 133 err = c.DeleteQueue(ctx, req) 134 if err != nil { 135 // TODO: Handle error. 136 } 137} 138 139func ExampleClient_PurgeQueue() { 140 ctx := context.Background() 141 c, err := cloudtasks.NewClient(ctx) 142 if err != nil { 143 // TODO: Handle error. 144 } 145 defer c.Close() 146 147 req := &taskspb.PurgeQueueRequest{ 148 // TODO: Fill request struct fields. 149 } 150 resp, err := c.PurgeQueue(ctx, req) 151 if err != nil { 152 // TODO: Handle error. 153 } 154 // TODO: Use resp. 155 _ = resp 156} 157 158func ExampleClient_PauseQueue() { 159 ctx := context.Background() 160 c, err := cloudtasks.NewClient(ctx) 161 if err != nil { 162 // TODO: Handle error. 163 } 164 defer c.Close() 165 166 req := &taskspb.PauseQueueRequest{ 167 // TODO: Fill request struct fields. 168 } 169 resp, err := c.PauseQueue(ctx, req) 170 if err != nil { 171 // TODO: Handle error. 172 } 173 // TODO: Use resp. 174 _ = resp 175} 176 177func ExampleClient_ResumeQueue() { 178 ctx := context.Background() 179 c, err := cloudtasks.NewClient(ctx) 180 if err != nil { 181 // TODO: Handle error. 182 } 183 defer c.Close() 184 185 req := &taskspb.ResumeQueueRequest{ 186 // TODO: Fill request struct fields. 187 } 188 resp, err := c.ResumeQueue(ctx, req) 189 if err != nil { 190 // TODO: Handle error. 191 } 192 // TODO: Use resp. 193 _ = resp 194} 195 196func ExampleClient_GetIamPolicy() { 197 ctx := context.Background() 198 c, err := cloudtasks.NewClient(ctx) 199 if err != nil { 200 // TODO: Handle error. 201 } 202 defer c.Close() 203 204 req := &iampb.GetIamPolicyRequest{ 205 // TODO: Fill request struct fields. 206 } 207 resp, err := c.GetIamPolicy(ctx, req) 208 if err != nil { 209 // TODO: Handle error. 210 } 211 // TODO: Use resp. 212 _ = resp 213} 214 215func ExampleClient_SetIamPolicy() { 216 ctx := context.Background() 217 c, err := cloudtasks.NewClient(ctx) 218 if err != nil { 219 // TODO: Handle error. 220 } 221 defer c.Close() 222 223 req := &iampb.SetIamPolicyRequest{ 224 // TODO: Fill request struct fields. 225 } 226 resp, err := c.SetIamPolicy(ctx, req) 227 if err != nil { 228 // TODO: Handle error. 229 } 230 // TODO: Use resp. 231 _ = resp 232} 233 234func ExampleClient_TestIamPermissions() { 235 ctx := context.Background() 236 c, err := cloudtasks.NewClient(ctx) 237 if err != nil { 238 // TODO: Handle error. 239 } 240 defer c.Close() 241 242 req := &iampb.TestIamPermissionsRequest{ 243 // TODO: Fill request struct fields. 244 } 245 resp, err := c.TestIamPermissions(ctx, req) 246 if err != nil { 247 // TODO: Handle error. 248 } 249 // TODO: Use resp. 250 _ = resp 251} 252 253func ExampleClient_ListTasks() { 254 ctx := context.Background() 255 c, err := cloudtasks.NewClient(ctx) 256 if err != nil { 257 // TODO: Handle error. 258 } 259 defer c.Close() 260 261 req := &taskspb.ListTasksRequest{ 262 // TODO: Fill request struct fields. 263 } 264 it := c.ListTasks(ctx, req) 265 for { 266 resp, err := it.Next() 267 if err == iterator.Done { 268 break 269 } 270 if err != nil { 271 // TODO: Handle error. 272 } 273 // TODO: Use resp. 274 _ = resp 275 } 276} 277 278func ExampleClient_GetTask() { 279 ctx := context.Background() 280 c, err := cloudtasks.NewClient(ctx) 281 if err != nil { 282 // TODO: Handle error. 283 } 284 defer c.Close() 285 286 req := &taskspb.GetTaskRequest{ 287 // TODO: Fill request struct fields. 288 } 289 resp, err := c.GetTask(ctx, req) 290 if err != nil { 291 // TODO: Handle error. 292 } 293 // TODO: Use resp. 294 _ = resp 295} 296 297func ExampleClient_CreateTask() { 298 ctx := context.Background() 299 c, err := cloudtasks.NewClient(ctx) 300 if err != nil { 301 // TODO: Handle error. 302 } 303 defer c.Close() 304 305 req := &taskspb.CreateTaskRequest{ 306 // TODO: Fill request struct fields. 307 } 308 resp, err := c.CreateTask(ctx, req) 309 if err != nil { 310 // TODO: Handle error. 311 } 312 // TODO: Use resp. 313 _ = resp 314} 315 316func ExampleClient_DeleteTask() { 317 ctx := context.Background() 318 c, err := cloudtasks.NewClient(ctx) 319 if err != nil { 320 // TODO: Handle error. 321 } 322 defer c.Close() 323 324 req := &taskspb.DeleteTaskRequest{ 325 // TODO: Fill request struct fields. 326 } 327 err = c.DeleteTask(ctx, req) 328 if err != nil { 329 // TODO: Handle error. 330 } 331} 332 333func ExampleClient_LeaseTasks() { 334 ctx := context.Background() 335 c, err := cloudtasks.NewClient(ctx) 336 if err != nil { 337 // TODO: Handle error. 338 } 339 defer c.Close() 340 341 req := &taskspb.LeaseTasksRequest{ 342 // TODO: Fill request struct fields. 343 } 344 resp, err := c.LeaseTasks(ctx, req) 345 if err != nil { 346 // TODO: Handle error. 347 } 348 // TODO: Use resp. 349 _ = resp 350} 351 352func ExampleClient_AcknowledgeTask() { 353 ctx := context.Background() 354 c, err := cloudtasks.NewClient(ctx) 355 if err != nil { 356 // TODO: Handle error. 357 } 358 defer c.Close() 359 360 req := &taskspb.AcknowledgeTaskRequest{ 361 // TODO: Fill request struct fields. 362 } 363 err = c.AcknowledgeTask(ctx, req) 364 if err != nil { 365 // TODO: Handle error. 366 } 367} 368 369func ExampleClient_RenewLease() { 370 ctx := context.Background() 371 c, err := cloudtasks.NewClient(ctx) 372 if err != nil { 373 // TODO: Handle error. 374 } 375 defer c.Close() 376 377 req := &taskspb.RenewLeaseRequest{ 378 // TODO: Fill request struct fields. 379 } 380 resp, err := c.RenewLease(ctx, req) 381 if err != nil { 382 // TODO: Handle error. 383 } 384 // TODO: Use resp. 385 _ = resp 386} 387 388func ExampleClient_CancelLease() { 389 ctx := context.Background() 390 c, err := cloudtasks.NewClient(ctx) 391 if err != nil { 392 // TODO: Handle error. 393 } 394 defer c.Close() 395 396 req := &taskspb.CancelLeaseRequest{ 397 // TODO: Fill request struct fields. 398 } 399 resp, err := c.CancelLease(ctx, req) 400 if err != nil { 401 // TODO: Handle error. 402 } 403 // TODO: Use resp. 404 _ = resp 405} 406 407func ExampleClient_RunTask() { 408 ctx := context.Background() 409 c, err := cloudtasks.NewClient(ctx) 410 if err != nil { 411 // TODO: Handle error. 412 } 413 defer c.Close() 414 415 req := &taskspb.RunTaskRequest{ 416 // TODO: Fill request struct fields. 417 } 418 resp, err := c.RunTask(ctx, req) 419 if err != nil { 420 // TODO: Handle error. 421 } 422 // TODO: Use resp. 423 _ = resp 424} 425