1 // Copyright 2024 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 17 package storage_test 18 19 import ( 20 "context" 21 22 storage "cloud.google.com/go/bigquery/storage/apiv1" 23 storagepb "cloud.google.com/go/bigquery/storage/apiv1/storagepb" 24 ) 25 26 func ExampleNewBigQueryReadClient() { 27 ctx := context.Background() 28 // This snippet has been automatically generated and should be regarded as a code template only. 29 // It will require modifications to work: 30 // - It may require correct/in-range values for request initialization. 31 // - It may require specifying regional endpoints when creating the service client as shown in: 32 // https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options 33 c, err := storage.NewBigQueryReadClient(ctx) 34 if err != nil { 35 // TODO: Handle error. 36 } 37 defer c.Close() 38 39 // TODO: Use client. 40 _ = c 41 } 42 43 func ExampleBigQueryReadClient_CreateReadSession() { 44 ctx := context.Background() 45 // This snippet has been automatically generated and should be regarded as a code template only. 46 // It will require modifications to work: 47 // - It may require correct/in-range values for request initialization. 48 // - It may require specifying regional endpoints when creating the service client as shown in: 49 // https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options 50 c, err := storage.NewBigQueryReadClient(ctx) 51 if err != nil { 52 // TODO: Handle error. 53 } 54 defer c.Close() 55 56 req := &storagepb.CreateReadSessionRequest{ 57 // TODO: Fill request struct fields. 58 // See https://pkg.go.dev/cloud.google.com/go/bigquery/storage/apiv1/storagepb#CreateReadSessionRequest. 59 } 60 resp, err := c.CreateReadSession(ctx, req) 61 if err != nil { 62 // TODO: Handle error. 63 } 64 // TODO: Use resp. 65 _ = resp 66 } 67 68 func ExampleBigQueryReadClient_SplitReadStream() { 69 ctx := context.Background() 70 // This snippet has been automatically generated and should be regarded as a code template only. 71 // It will require modifications to work: 72 // - It may require correct/in-range values for request initialization. 73 // - It may require specifying regional endpoints when creating the service client as shown in: 74 // https://pkg.go.dev/cloud.google.com/go#hdr-Client_Options 75 c, err := storage.NewBigQueryReadClient(ctx) 76 if err != nil { 77 // TODO: Handle error. 78 } 79 defer c.Close() 80 81 req := &storagepb.SplitReadStreamRequest{ 82 // TODO: Fill request struct fields. 83 // See https://pkg.go.dev/cloud.google.com/go/bigquery/storage/apiv1/storagepb#SplitReadStreamRequest. 84 } 85 resp, err := c.SplitReadStream(ctx, req) 86 if err != nil { 87 // TODO: Handle error. 88 } 89 // TODO: Use resp. 90 _ = resp 91 } 92