bquploader

Documentation

Overview

Package bquploader defines a uploader of BigQuery.

Index

• type TargetTable
  • func (t *TargetTable) String() string
• type Uploader
  • func NewUploader(table TargetTable, interval time.Duration, opts ...option.ClientOption) (*Uploader, error)
  • func (u *Uploader) Close()
  • func (u *Uploader) QueueRecord(r interface{})

Types

type TargetTable

type TargetTable struct {
	ProjectID string
	Dataset   string
	TableName string
}

TargetTable represents a fully qualified BigQuery table name.

func (*TargetTable) String

func (t *TargetTable) String() string

type Uploader

type Uploader struct {
	// contains filtered or unexported fields
}

Uploader uploads records to BigQuery at regular intervals.

func NewUploader

func NewUploader(table TargetTable, interval time.Duration, opts ...option.ClientOption) (*Uploader, error)

NewUploader creates a new Uploader.

func (*Uploader) Close

func (u *Uploader) Close()

Close closes the uploader and release all resources.

func (*Uploader) QueueRecord

func (u *Uploader) QueueRecord(r interface{})

QueueRecord queues a record for uploading in the next batch.