storage

Documentation

Index

• type Client
  • func NewClient(projectID, dataSetID, tableID string, encoder encoding.Encoder, ...) (*Client, error)
  • func (bqc *Client) Close() error
  • func (bqc *Client) Flush() error
  • func (bqc *Client) Put(data interface{}) (bool, error)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client implements the standard/official BQ (cloud) Client, using the regular insertAll API with retry logic added on top of that. By default the workers will also batch its received rows rather than writing them one by one, this can be disabled by setting the batchSize value to the value of 1.

func NewClient

func NewClient(projectID, dataSetID, tableID string, encoder encoding.Encoder, dp *descriptorpb.DescriptorProto, logger log.Logger, opts ...option.ClientOption) (*Client, error)

NewClient creates a new BQ Storage Client. See the documentation of Client for more information how to use it.

func (*Client) Close

func (bqc *Client) Close() error

Close implements b,fxigquery.Client::Close

func (*Client) Flush

func (bqc *Client) Flush() error

Flush implements bigquery.Client::Flush

func (*Client) Put

func (bqc *Client) Put(data interface{}) (bool, error)

Put implements bigquery.Client::Put