prometheus

type Client interface {
	// WriteProto writes the Prom proto WriteRequest to the specified endpoint.
	WriteProto(
		ctx context.Context,
		req *prompb.WriteRequest,
		opts WriteOptions,
	) (WriteResult, WriteError)

	// WriteTimeSeries converts the []TimeSeries to Protobuf then writes it to the specified endpoint.
	WriteTimeSeries(
		ctx context.Context,
		ts TSList,
		opts WriteOptions,
	) (WriteResult, WriteError)
}

type Config struct {
	// WriteURL is the URL which the client uses to write to prometheus.
	WriteURL string `yaml:"writeURL"`

	//HTTPClientTimeout is the timeout that is set for the client.
	HTTPClientTimeout time.Duration `yaml:"httpClientTimeout"`

	// If not nil, http client is used instead of constructing one.
	HTTPClient *http.Client

	// UserAgent is the `User-Agent` header in the request.
	UserAgent string `yaml:"userAgent"`
}

type ConfigOption func(*Config)

type Datapoint struct {
	Timestamp time.Time
	Value     float64
}

type Label struct {
	Name  string
	Value string
}

type TSList []TimeSeries

type TimeSeries struct {
	Labels    []Label
	Datapoint Datapoint
}

type WriteError interface {
	error
	StatusCode() int
}

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

type WriteResult struct {
	StatusCode  int
	PayloadSize int
}