metricsclient

Documentation

Index

• func DefaultTransport(logger log.Logger, isTLS bool) *http.Transport
• func MTLSTransport(logger log.Logger) (*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, client *http.Client, maxBytes int64, timeout time.Duration, ...) *Client
  • func (c *Client) RemoteWrite(ctx context.Context, req *http.Request, families []*clientmodel.MetricFamily, ...) error
  • func (c *Client) RetrievRecordingMetrics(ctx context.Context, req *http.Request, name string) ([]*clientmodel.MetricFamily, error)
  • func (c *Client) Retrieve(ctx context.Context, req *http.Request) ([]*clientmodel.MetricFamily, error)
  • func (c *Client) Send(ctx context.Context, req *http.Request, families []*clientmodel.MetricFamily) error
• type MetricsData
• type MetricsJson
• type MetricsResult
• type PartitionedMetrics

Functions

func DefaultTransport

func DefaultTransport(logger log.Logger, isTLS bool) *http.Transport

func MTLSTransport

func MTLSTransport(logger log.Logger) (*http.Transport, error)

func Read

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

func Write

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

Types

type Client

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

func New

func New(logger log.Logger, 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) RetrievRecordingMetrics

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

func (*Client) Retrieve

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

func (*Client) Send

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

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
}