config

Documentation

Index

• type BigQueryConfig
  • func NewBigQueryConfig(projectId string, schema string, table string, credentialsPath string, ...) BigQueryConfig
  • func (bqc *BigQueryConfig) IsValid() error
  • func (bqc *BigQueryConfig) Print()

Types

type BigQueryConfig

type BigQueryConfig struct {
	// ProjectID with the GKE project identifier
	ProjectID string
	// Schema with the BigQuery Schema
	Schema string
	// Table with the BigQuery table name
	Table string
	// CredentialsPath with the Service Account credentials file
	CredentialsPath string
	// SendingTime is the time between database inserts
	SendingTime time.Duration
}

BigQueryConfig with the bigQuery provider configuration

func NewBigQueryConfig

func NewBigQueryConfig(projectId string, schema string, table string, credentialsPath string, loopTime time.Duration) BigQueryConfig

func (*BigQueryConfig) IsValid

func (bqc *BigQueryConfig) IsValid() error

func (*BigQueryConfig) Print

func (bqc *BigQueryConfig) Print()