bq

Documentation

Index

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

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.