usp_bigquery

Documentation

Index

• type BigQueryAdapter
  • func NewBigQueryAdapter(conf BigQueryConfig) (*BigQueryAdapter, chan struct{}, error)
  • func (bq *BigQueryAdapter) Close() error
• type BigQueryConfig
  • func (bq *BigQueryConfig) Validate() error

Types

type BigQueryAdapter

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

func NewBigQueryAdapter

func NewBigQueryAdapter(conf BigQueryConfig) (*BigQueryAdapter, chan struct{}, error)

func (*BigQueryAdapter) Close

func (bq *BigQueryAdapter) Close() error

type BigQueryConfig

type BigQueryConfig struct {
	ClientOptions       uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	ProjectId           string                  `json:"project_id" yaml:"project_id"`
	BigQueryProject     string                  `json:"bigquery_project" yaml:"bigquery_project"`
	DatasetName         string                  `json:"dataset_name" yaml:"dataset_name"`
	TableName           string                  `json:"table_name" yaml:"table_name"`
	ServiceAccountCreds string                  `json:"service_account_creds,omitempty" yaml:"service_account_creds,omitempty"`
	SqlQuery            string                  `json:"sql_query" yaml:"sql_query"`
	QueryInterval       string                  `json:"query_interval" yaml:"query_interval"`
	IsOneTimeLoad       bool                    `json:"is_one_time_load" yaml:"is_one_time_load"`
}

func (*BigQueryConfig) Validate

func (bq *BigQueryConfig) Validate() error