bq

package
v0.0.0-...-e560ebb Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2021 License: BSD-3-Clause Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Inserter

type Inserter interface {
	Insert(context.Context, ...bigquery.ValueSaver) error
	Close()
	CloseAndDrain(context.Context)
}

Inserter implements an interface to interact with Bigquery. TODO: consider moving the interface to the consumer side.

func NewInserter

func NewInserter(ctx context.Context, op Options) (Inserter, error)

NewInserter instantiates new Inserter.

type Options

type Options struct {
	Target        *result_flow.BigqueryConfig
	HTTPClient    *http.Client
	InsertRPCMock func(context.Context, *bqapi.TableDataInsertAllRequest) (*bqapi.TableDataInsertAllResponse, error)
}

Options presents the options for the interface to interact with Bigquery.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL