or run

tessl search

Version

Workspace: tessl
Visibility: Public
Created: 6 days ago
Last updated: about 16 hours ago
Describes: pkg:golang/cloud.google.com/go/bigquery@v1.72.0

tessl/golang-cloud-google-com--go--bigquery

tessl install tessl/golang-cloud-google-com--go--bigquery@1.72.0

Google Cloud BigQuery client library providing comprehensive Go APIs for querying, loading data, managing datasets and tables, streaming inserts, and accessing BigQuery's ecosystem of services including Storage, Analytics Hub, Data Transfer, and Migration APIs

Connection API

The Connection API manages connections to external data sources including Cloud SQL, AWS, Azure SQL, and other databases.

Package Import

import "cloud.google.com/go/bigquery/connection/apiv1"
import "cloud.google.com/go/bigquery/connection/apiv1/connectionpb"

Client Creation

func NewClient(ctx context.Context, opts ...option.ClientOption) (*Client, error)

type Client struct{}

func (c *Client) Close() error

Connection Management

func (c *Client) CreateConnection(ctx context.Context, req *connectionpb.CreateConnectionRequest, opts ...gax.CallOption) (*connectionpb.Connection, error)
func (c *Client) GetConnection(ctx context.Context, req *connectionpb.GetConnectionRequest, opts ...gax.CallOption) (*connectionpb.Connection, error)
func (c *Client) ListConnections(ctx context.Context, req *connectionpb.ListConnectionsRequest, opts ...gax.CallOption) *ConnectionIterator
func (c *Client) UpdateConnection(ctx context.Context, req *connectionpb.UpdateConnectionRequest, opts ...gax.CallOption) (*connectionpb.Connection, error)
func (c *Client) DeleteConnection(ctx context.Context, req *connectionpb.DeleteConnectionRequest, opts ...gax.CallOption) error

Connection Types

Cloud SQL

req := &connectionpb.CreateConnectionRequest{
    Parent: "projects/my-project/locations/us",
    ConnectionId: "mysql-connection",
    Connection: &connectionpb.Connection{
        Properties: &connectionpb.Connection_CloudSql{
            CloudSql: &connectionpb.CloudSqlProperties{
                Type: connectionpb.CloudSqlProperties_MYSQL,
                Database: "mydb",
                InstanceId: "my-project:us-central1:mysql-instance",
                Credential: &connectionpb.CloudSqlCredential{
                    Username: "user",
                    Password: "password",
                },
            },
        },
    },
}

AWS

req := &connectionpb.CreateConnectionRequest{
    Parent: "projects/my-project/locations/us",
    ConnectionId: "aws-connection",
    Connection: &connectionpb.Connection{
        Properties: &connectionpb.Connection_Aws{
            Aws: &connectionpb.AwsProperties{
                AccessRole: &connectionpb.AwsAccessRole{
                    IamRoleId: "arn:aws:iam::123456789012:role/MyRole",
                },
            },
        },
    },
}

IAM Management

func (c *Client) GetIamPolicy(ctx context.Context, req *iampb.GetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)
func (c *Client) SetIamPolicy(ctx context.Context, req *iampb.SetIamPolicyRequest, opts ...gax.CallOption) (*iampb.Policy, error)
func (c *Client) TestIamPermissions(ctx context.Context, req *iampb.TestIamPermissionsRequest, opts ...gax.CallOption) (*iampb.TestIamPermissionsResponse, error)