bq

Documentation

Index

• Constants
• type Client
  • func NewClient(gcpProjectID string) Client
• type ClientImpl
  • func (client *ClientImpl) GetQueryStats(q string, params []bigquery.QueryParameter) (*bigquery.JobStatistics, error)
  • func (client *ClientImpl) Query(q string) error
  • func (client *ClientImpl) QueryIterator(q string, params []bigquery.QueryParameter) (Iterator, error)
• type Iterator
• type IteratorWrapper
  • func (i *IteratorWrapper) Next(dst interface{}) error

Constants

const (
	EnvKeyBQToken = "BIGQUERY_KEY"
)

Types

type Client

type Client interface {
	QueryIterator(q string, params []bigquery.QueryParameter) (Iterator, error)
}

func NewClient

func NewClient(gcpProjectID string) Client

type ClientImpl

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

func (*ClientImpl) GetQueryStats

func (client *ClientImpl) GetQueryStats(q string, params []bigquery.QueryParameter) (*bigquery.JobStatistics, error)

func (*ClientImpl) Query

func (client *ClientImpl) Query(q string) error

func (*ClientImpl) QueryIterator

func (client *ClientImpl) QueryIterator(q string, params []bigquery.QueryParameter) (Iterator, error)

type Iterator

type Iterator interface {
	Next(dst interface{}) error
}

type IteratorWrapper

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

func (*IteratorWrapper) Next

func (i *IteratorWrapper) Next(dst interface{}) error