storage

Jul 8, 2022

Changes in this version

type BigQueryReadClient

+ func NewBigQueryReadRESTClient(ctx context.Context, opts ...option.ClientOption) (*BigQueryReadClient, error)

type BigQueryWriteClient

+ func NewBigQueryWriteRESTClient(ctx context.Context, opts ...option.ClientOption) (*BigQueryWriteClient, error)

Nov 4, 2020

Changes in this version

+ type BigQueryWriteCallOptions struct

+ AppendRows []gax.CallOption

+ BatchCommitWriteStreams []gax.CallOption

+ CreateWriteStream []gax.CallOption

+ FinalizeWriteStream []gax.CallOption

+ FlushRows []gax.CallOption

+ GetWriteStream []gax.CallOption

+ type BigQueryWriteClient struct

+ CallOptions *BigQueryWriteCallOptions

+ func NewBigQueryWriteClient(ctx context.Context, opts ...option.ClientOption) (*BigQueryWriteClient, error)

+ func (c *BigQueryWriteClient) AppendRows(ctx context.Context, opts ...gax.CallOption) (storagepb.BigQueryWrite_AppendRowsClient, error)

+ func (c *BigQueryWriteClient) BatchCommitWriteStreams(ctx context.Context, req *storagepb.BatchCommitWriteStreamsRequest, ...) (*storagepb.BatchCommitWriteStreamsResponse, error)

+ func (c *BigQueryWriteClient) Close() error

+ func (c *BigQueryWriteClient) Connection() *grpc.ClientConn

+ func (c *BigQueryWriteClient) CreateWriteStream(ctx context.Context, req *storagepb.CreateWriteStreamRequest, ...) (*storagepb.WriteStream, error)

+ func (c *BigQueryWriteClient) FinalizeWriteStream(ctx context.Context, req *storagepb.FinalizeWriteStreamRequest, ...) (*storagepb.FinalizeWriteStreamResponse, error)

+ func (c *BigQueryWriteClient) FlushRows(ctx context.Context, req *storagepb.FlushRowsRequest, opts ...gax.CallOption) (*storagepb.FlushRowsResponse, error)

+ func (c *BigQueryWriteClient) GetWriteStream(ctx context.Context, req *storagepb.GetWriteStreamRequest, ...) (*storagepb.WriteStream, error)

Jan 23, 2020

Changes in this version

+ func DefaultAuthScopes() []string

+ type BigQueryReadCallOptions struct

+ CreateReadSession []gax.CallOption

+ ReadRows []gax.CallOption

+ SplitReadStream []gax.CallOption

+ type BigQueryReadClient struct

+ CallOptions *BigQueryReadCallOptions

+ func NewBigQueryReadClient(ctx context.Context, opts ...option.ClientOption) (*BigQueryReadClient, error)

+ func (c *BigQueryReadClient) Close() error

+ func (c *BigQueryReadClient) Connection() *grpc.ClientConn

+ func (c *BigQueryReadClient) CreateReadSession(ctx context.Context, req *storagepb.CreateReadSessionRequest, ...) (*storagepb.ReadSession, error)

+ func (c *BigQueryReadClient) ReadRows(ctx context.Context, req *storagepb.ReadRowsRequest, opts ...gax.CallOption) (storagepb.BigQueryRead_ReadRowsClient, error)

+ func (c *BigQueryReadClient) SplitReadStream(ctx context.Context, req *storagepb.SplitReadStreamRequest, ...) (*storagepb.SplitReadStreamResponse, error)