promremote

type Client ¶

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

func NewClient(url, token string) *Client

func (c *Client) WriteProto(
	ctx context.Context,
	promWR *prompb.WriteRequest,
	opts WriteOptions,
) (WriteResult, WriteError)

func (c *Client) WriteTimeSeries(
	ctx context.Context,
	seriesList TSList,
	opts WriteOptions,
) (WriteResult, WriteError)

type Datapoint ¶

type Datapoint struct {
	Timestamp time.Time
	Value     float64
}

A Datapoint is a single data value reported at a given time.

type Label ¶

type Label struct {
	Name  string
	Value string
}

Label is a metric label.

type TSList ¶

type TSList []TimeSeries

TSList is a slice of TimeSeries.

type TimeSeries ¶

type TimeSeries struct {
	Labels    []Label
	Datapoint Datapoint
}

TimeSeries are made of labels and a datapoint.

func ConvertMetric(metric prometheus.Metric, name string) TimeSeries

type WriteError ¶

type WriteError interface {
	error
	StatusCode() int
}

WriteError is an error that can also return the HTTP status code if the response is what caused an error.

type WriteOptions ¶

type WriteOptions struct {
	// Headers to append or override the outgoing headers.
	Headers map[string]string
}

WriteOptions specifies additional write options.

type WriteResult ¶

type WriteResult struct {
	StatusCode int
}

WriteResult returns the successful HTTP status code.