bq

Documentation

Overview

Package bq implements bigquery-related logic.

Index

• func GetDeviceConfigProtos(ctx context.Context) []proto.Message
• func GetManufacturingConfigProtos(ctx context.Context) []proto.Message
• func GetPSTTimeStamp(t time.Time) string
• func GetRegisteredAssetsProtos(ctx context.Context) []proto.Message
• func InitBQUploader(ctx context.Context, project, dataset, table string) (*bq.Uploader, error)
• func InitBQUploaderWithClient(ctx context.Context, client *bigquery.Client, dataset, table string) *bq.Uploader

Functions

func GetDeviceConfigProtos

func GetDeviceConfigProtos(ctx context.Context) []proto.Message

GetDeviceConfigProtos prepares the proto messages for all device configs to upload to bq.

func GetManufacturingConfigProtos

func GetManufacturingConfigProtos(ctx context.Context) []proto.Message

GetManufacturingConfigProtos prepares the proto messages for all device configs to upload to bq.

func GetPSTTimeStamp

func GetPSTTimeStamp(t time.Time) string

GetPSTTimeStamp returns the PST timestamp for bq table.

func GetRegisteredAssetsProtos

func GetRegisteredAssetsProtos(ctx context.Context) []proto.Message

GetRegisteredAssetsProtos prepares the proto messages for registered assets to upload to bq.

func InitBQUploader

func InitBQUploader(ctx context.Context, project, dataset, table string) (*bq.Uploader, error)

InitBQUploader initialize a bigquery uploader.

func InitBQUploaderWithClient

func InitBQUploaderWithClient(ctx context.Context, client *bigquery.Client, dataset, table string) *bq.Uploader

InitBQUploaderWithClient initialize a bigquery uploader with a given bigquery client.