bigquery

Documentation

Index

• Constants
• type BQCredentialsT
• type HandleT
  • func (bq *HandleT) CrashRecover(config warehouseutils.ConfigT) (err error)
  • func (bq *HandleT) Export() (err error)
  • func (bq *HandleT) MigrateSchema() (err error)
  • func (bq *HandleT) Process(config warehouseutils.ConfigT) (err error)

Constants

const (
	GCPProjectID   = "project"
	GCPCredentials = "credentials"
)

String constants for bigquery destination config

Types

type BQCredentialsT

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

type HandleT

type HandleT struct {
	BQContext     context.Context
	DbHandle      *sql.DB
	Db            *bigquery.Client
	Namespace     string
	CurrentSchema map[string]map[string]string
	Warehouse     warehouseutils.WarehouseT
	ProjectID     string
	Upload        warehouseutils.UploadT
}

func (*HandleT) CrashRecover

func (bq *HandleT) CrashRecover(config warehouseutils.ConfigT) (err error)

func (*HandleT) Export

func (bq *HandleT) Export() (err error)

func (*HandleT) MigrateSchema

func (bq *HandleT) MigrateSchema() (err error)

func (*HandleT) Process

func (bq *HandleT) Process(config warehouseutils.ConfigT) (err error)