metricsclient

Documentation

Index

• func DefaultTransport(logger log.Logger) *http.Transport
• func MTLSTransport(logger log.Logger, caCertFile, tlsCrtFile, tlsKeyFile string) (*http.Transport, error)
• func Read(r io.Reader) ([]*clientmodel.MetricFamily, error)
• func Write(w io.Writer, families []*clientmodel.MetricFamily) error
• type Client
  • func New(logger log.Logger, metrics *ClientMetrics, client *http.Client, maxBytes int64, ...) *Client
  • func (c *Client) RemoteWrite(ctx context.Context, req *http.Request, families []*clientmodel.MetricFamily, ...) error
  • func (c *Client) Retrieve(ctx context.Context, req *http.Request) ([]*clientmodel.MetricFamily, error)
  • func (c *Client) RetrieveRecordingMetrics(ctx context.Context, req *http.Request, name string) ([]*clientmodel.MetricFamily, error)
• type ClientMetrics
• type HTTPError
  • func (e *HTTPError) Error() string
• type MetricsData
• type MetricsJson
• type MetricsResult
• type PartitionedMetrics

Functions

func DefaultTransport

func DefaultTransport(logger log.Logger) *http.Transport

func MTLSTransport

func MTLSTransport(logger log.Logger, caCertFile, tlsCrtFile, tlsKeyFile string) (*http.Transport, error)

func Read

func Read(r io.Reader) ([]*clientmodel.MetricFamily, error)

// TODO(saswatamcode): This is no longer used, remove it in the future.

func Write

func Write(w io.Writer, families []*clientmodel.MetricFamily) error

TODO(saswatamcode): This is no longer used, remove it in the future.

Types

type Client

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

func New

func New(logger log.Logger, metrics *ClientMetrics, client *http.Client, maxBytes int64, timeout time.Duration, metricsName string) *Client

func (*Client) RemoteWrite

func (c *Client) RemoteWrite(ctx context.Context, req *http.Request,
	families []*clientmodel.MetricFamily, interval time.Duration) error

RemoteWrite is used to push the metrics to remote thanos endpoint.

func (*Client) Retrieve

func (c *Client) Retrieve(ctx context.Context, req *http.Request) ([]*clientmodel.MetricFamily, error)

func (*Client) RetrieveRecordingMetrics

func (c *Client) RetrieveRecordingMetrics(
	ctx context.Context,
	req *http.Request,
	name string) ([]*clientmodel.MetricFamily, error)

type ClientMetrics

type ClientMetrics struct {
	FederateRequests           *prometheus.CounterVec
	ForwardRemoteWriteRequests *prometheus.CounterVec
}

type HTTPError

type HTTPError struct {
	StatusCode int
	Message    string
}

func (*HTTPError) Error

func (e *HTTPError) Error() string

type MetricsData

type MetricsData struct {
	Type   string          `json:"resultType"`
	Result []MetricsResult `json:"result"`
}

type MetricsJson

type MetricsJson struct {
	Status string      `json:"status"`
	Data   MetricsData `json:"data"`
}

type MetricsResult

type MetricsResult struct {
	Metric map[string]string `json:"metric"`
	Value  []interface{}     `json:"value"`
}

type PartitionedMetrics

type PartitionedMetrics struct {
	Families []*clientmodel.MetricFamily
}