internal

Documentation

Index

• func ExecuteQueryAndFetchRows(query, addressFilter string, applyAddressFilter bool) ([]string, [][]string, error)
• func WriteCSV(fileName string, header []string, rows [][]string) error
• func WriteJSON(fileName string, headers []string, rows [][]string) error
• type BigQueryQuerier
  • func NewBigQueryQuerier() (*BigQueryQuerier, error)
  • func (bq *BigQueryQuerier) Close()

Functions

func ExecuteQueryAndFetchRows

func ExecuteQueryAndFetchRows(query, addressFilter string, applyAddressFilter bool) ([]string, [][]string, error)

func WriteCSV

func WriteCSV(fileName string, header []string, rows [][]string) error

func WriteJSON

func WriteJSON(fileName string, headers []string, rows [][]string) error

Types

type BigQueryQuerier

type BigQueryQuerier struct {
	Client *bigquery.Client
	Ctx    context.Context
}

func NewBigQueryQuerier

func NewBigQueryQuerier() (*BigQueryQuerier, error)

func (*BigQueryQuerier) Close

func (bq *BigQueryQuerier) Close()