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