Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidParams = errors.New("[err] invalid params") ErrTimeout = errors.New("[err] timeout") )
Functions ¶
This section is empty.
Types ¶
type ErrorHandler ¶
type ErrorHandler func(error)
type Streamer ¶
type Streamer interface { AddRow(ctx context.Context, row Row) error AddRowSync(ctx context.Context, row Row) error }
func NewStreamer ¶
func NewStreamer(cfg *Config, errFunc ErrorHandler) (Streamer, error)
NewStreamer returns bigquery streamer which inserts data with bulk parallel.
type TableSchema ¶
type TableSchema struct { DatasetId string // bigquery datasetId Prefix string // bigquery table prefix Meta *bigquery.TableMetadata // bigquery table meta Period TablePeriod // TablePeriod AddNewColumns bool // add new columns to existing table }
type WorkerDispatcher ¶
type WorkerDispatcher struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.