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