bigquerydb

Documentation

Index

• type BigqueryClient
  • func NewClient(logger log.Logger, ...) *BigqueryClient
  • func (c *BigqueryClient) Collect(ch chan<- prometheus.Metric)
  • func (c *BigqueryClient) Describe(ch chan<- *prometheus.Desc)
  • func (c BigqueryClient) Name() string
  • func (c *BigqueryClient) Read(req *prompb.ReadRequest) (*prompb.ReadResponse, error)
  • func (c *BigqueryClient) Write(timeseries []*prompb.TimeSeries) error
• type Item
  • func (i *Item) Save() (map[string]bigquery.Value, string, error)

Types

type BigqueryClient

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

BigqueryClient allows sending batches of Prometheus samples to Bigquery.

func NewClient

func NewClient(logger log.Logger, googleAPIjsonkeypath, googleProjectID, googleAPIdatasetID, googleAPItableID string, remoteTimeout time.Duration) *BigqueryClient

NewClient creates a new Client.

func (*BigqueryClient) Collect

func (c *BigqueryClient) Collect(ch chan<- prometheus.Metric)

Collect implements prometheus.Collector.

func (*BigqueryClient) Describe

func (c *BigqueryClient) Describe(ch chan<- *prometheus.Desc)

Describe implements prometheus.Collector.

func (BigqueryClient) Name

func (c BigqueryClient) Name() string

Name identifies the client as a BigQuery client.

func (*BigqueryClient) Read

func (c *BigqueryClient) Read(req *prompb.ReadRequest) (*prompb.ReadResponse, error)

Read queries the database and returns the results to Prometheus

func (*BigqueryClient) Write

func (c *BigqueryClient) Write(timeseries []*prompb.TimeSeries) error

Write sends a batch of samples to BigQuery via the client.

type Item

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

Item represents a row item.

func (*Item) Save

func (i *Item) Save() (map[string]bigquery.Value, string, error)

Save implements the ValueSaver interface.