batch

Documentation

Index

• type Client
  • func NewClient(projectID, dataSetID, tableID string, ignoreUnknownValues bool, ...) (*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, ignoreUnknownValues bool, sourceFormat bigquery.DataFormat, writeDisposition bigquery.TableWriteDisposition, schema *bigquery.Schema, logger log.Logger, opts ...option.ClientOption) (*Client, error)

NewClient creates a new Client.

func (*Client) Close

func (bqc *Client) Close() error

Close implements bqClient::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 bqClient::Put