bq

Aug 29, 2023

Changes in this version

type Telemetry

+ func NewTelemetry(t *model.Telemetry) *Telemetry

Aug 29, 2023

Changes in this version

type Client

+ func NewClientAuth(project string) Client

Aug 29, 2023

Changes in this version

+ func GetTelemetryTableMetadata() *bigquery.TableMetadata

+ type KeyValue struct

+ Key string

+ Value string

Aug 29, 2023

Changes in this version

+ const DatasetDev

+ const TableTelemetry

+ type Client interface

+ Close func() error

+ CreateDataset func(dataset string) error

+ CreateTable func(dataset string, tableID string, metadata *bigquery.TableMetadata) error

+ DatasetIterator func(callback func(dataset *bigquery.Dataset)) error

+ DeleteDataset func(dataset string) error

+ DeleteTable func(dataset string, tableID string) error

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

+ Insert func(dataset string, tableID string, src interface{}) error

+ Query func(q string) error

+ QueryIterator func(q string, params []bigquery.QueryParameter) (Iterator, error)

+ func NewClient(gcpProjectID string) Client

+ func NewClientInMemory() Client

+ type ClientImpl struct

+ func (client *ClientImpl) Close() error

+ func (client *ClientImpl) CreateDataset(dataset string) error

+ func (client *ClientImpl) CreateTable(dataset string, table string, metadata *bigquery.TableMetadata) error

+ func (client *ClientImpl) DatasetIterator(callback func(dataset *bigquery.Dataset)) error

+ func (client *ClientImpl) DeleteDataset(dataset string) error

+ func (client *ClientImpl) DeleteTable(dataset string, table string) error

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

+ func (client *ClientImpl) Insert(datasetID string, tableID string, src interface{}) error

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

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

+ type ClientInMemory struct

+ func (*ClientInMemory) Close() error

+ func (*ClientInMemory) CreateDataset(string) error

+ func (*ClientInMemory) CreateTable(string, string, *bigquery.TableMetadata) error

+ func (*ClientInMemory) DatasetIterator(func(*bigquery.Dataset)) error

+ func (*ClientInMemory) DeleteDataset(string) error

+ func (*ClientInMemory) DeleteTable(string, string) error

+ func (*ClientInMemory) Query(string) error

+ func (*ClientInMemory) QueryIterator(string, []bigquery.QueryParameter) (Iterator, error)

+ func (c *ClientInMemory) GetQueryStats(q string, params []bigquery.QueryParameter) (*bigquery.JobStatistics, error)

+ func (c *ClientInMemory) Insert(string, string, interface{}) error

+ type Iterator interface

+ Next func(dst interface{}) error

+ TotalRows func() uint64

+ type IteratorWrapper struct

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

+ func (i *IteratorWrapper) TotalRows() uint64

+ type Telemetry struct

+ Application string

+ ApplicationVersion string

+ Args []string

+ Command string

+ Flags string

+ Id string

+ MachineId string

+ Platform string

+ Runtime string

+ Time int64

+ func (t *Telemetry) Save() (map[string]bigquery.Value, string, error)