bigquery

Documentation

Index

• type BigQueryService
  • func NewBigQueryService(bq *bigquery.Client) (*BigQueryService, error)
  • func (s *BigQueryService) Close() error
  • func (s *BigQueryService) Insert(ctx context.Context, dataset *bigquery.Dataset, table string, ...) error
• type StreamingInsertError
  • func (e *StreamingInsertError) Error() string
• type StreamingInsertErrors
  • func (e *StreamingInsertErrors) Append(err *StreamingInsertError)
  • func (e *StreamingInsertErrors) Error() string
  • func (e *StreamingInsertErrors) ErrorOrNil() error

Types

type BigQueryService

type BigQueryService struct {
	BQ *bigquery.Client
}

func NewBigQueryService

func NewBigQueryService(bq *bigquery.Client) (*BigQueryService, error)

func (*BigQueryService) Close

func (s *BigQueryService) Close() error

func (*BigQueryService) Insert

func (s *BigQueryService) Insert(ctx context.Context, dataset *bigquery.Dataset, table string, sss []*bigquery.StructSaver) error

InsertStructSaverToBigQuery is StructSaverをBigQueryにStreamingInsertでInsertする InsertはAtomicには行われない。 Error時は StreamingInsertErrors を返す。

type StreamingInsertError

type StreamingInsertError struct {
	InsertID string
	Err      error
}

func (*StreamingInsertError) Error

func (e *StreamingInsertError) Error() string

type StreamingInsertErrors

type StreamingInsertErrors struct {
	Errors []*StreamingInsertError
	// contains filtered or unexported fields
}

func (*StreamingInsertErrors) Append

func (e *StreamingInsertErrors) Append(err *StreamingInsertError)

func (*StreamingInsertErrors) Error

func (e *StreamingInsertErrors) Error() string

func (*StreamingInsertErrors) ErrorOrNil

func (e *StreamingInsertErrors) ErrorOrNil() error