NewPromQueryClient makes a new client but used for Prometheus Query only.
(address string)
| 113 | |
| 114 | // NewPromQueryClient makes a new client but used for Prometheus Query only. |
| 115 | func NewPromQueryClient(address string) (*Client, error) { |
| 116 | // Create querier API client |
| 117 | querierAPIClient, err := promapi.NewClient(promapi.Config{ |
| 118 | Address: "http://" + address, |
| 119 | }) |
| 120 | if err != nil { |
| 121 | return nil, err |
| 122 | } |
| 123 | |
| 124 | c := &Client{ |
| 125 | timeout: 30 * time.Second, |
| 126 | httpClient: &http.Client{}, |
| 127 | querierClient: promv1.NewAPI(querierAPIClient), |
| 128 | } |
| 129 | |
| 130 | return c, nil |
| 131 | } |
| 132 | |
| 133 | func (c *Client) AllUserStats() ([]ingester.UserIDStats, error) { |
| 134 | req, err := http.NewRequest(http.MethodGet, fmt.Sprintf("http://%s/distributor/all_user_stats", c.distributorAddress), nil) |
no outgoing calls