Versions in this module Expand all Collapse all v1 v1.0.0 Dec 24, 2015 Changes in this version + func NewBigQueryService(c *jwt.Config) (service *bigquery.Service, err error) + func NewJWTConfig(keyPath string) (c *jwt.Config, err error) + type AllRowsRejectedError struct + func (err *AllRowsRejectedError) DatasetID() string + func (err *AllRowsRejectedError) Error() string + func (err *AllRowsRejectedError) ProjectID() string + func (err *AllRowsRejectedError) TableID() string + type MultiStreamer struct + Errors chan error + func NewMultiStreamer(jwtConfig *jwt.Config, numStreamers int, maxRows int, maxDelay time.Duration, ...) (*MultiStreamer, error) + func (b *MultiStreamer) QueueRow(projectID, datasetID, tableID string, jsonRow map[string]bigquery.JsonValue) + func (b *MultiStreamer) Start() + func (b *MultiStreamer) Stop() + type RowError struct + func (err *RowError) BQError() bigquery.ErrorProto + func (err *RowError) DatasetID() string + func (err *RowError) Error() string + func (err *RowError) Index() int64 + func (err *RowError) JsonValue() map[string]bigquery.JsonValue + func (err *RowError) ProjectID() string + func (err *RowError) TableID() string + type Streamer struct + Errors chan error + MaxDelay time.Duration + MaxRetryInsert int + SleepBeforeRetry time.Duration + Start func() + Stop func() + func NewStreamer(service *bigquery.Service, maxRows int, maxDelay time.Duration, ...) (b *Streamer, err error) + func (b *Streamer) QueueRow(projectID, datasetID, tableID string, jsonRow map[string]bigquery.JsonValue) + type TooManyFailedInsertRetriesError struct + func (err *TooManyFailedInsertRetriesError) DatasetID() string + func (err *TooManyFailedInsertRetriesError) Error() string + func (err *TooManyFailedInsertRetriesError) NumFailedRetries() int + func (err *TooManyFailedInsertRetriesError) ProjectID() string + func (err *TooManyFailedInsertRetriesError) TableID() string
Go to main page