discoveryutils

Documentation

Index

• Constants
• func DoRequestWithPossibleRetry(hc *fasthttp.HostClient, req *fasthttp.Request, resp *fasthttp.Response, ...) error
• func GetHTTPClient() *http.Client
• func InternString(s string) string
• func JoinHostPort(host string, port int) string
• func SanitizeLabelName(name string) string
• type Client
  • func NewClient(apiServer string, ac *promauth.Config, proxyURL *proxy.URL, ...) (*Client, error)
  • func (c *Client) Addr() string
  • func (c *Client) GetAPIResponse(path string) ([]byte, error)
  • func (c *Client) GetAPIResponseWithReqParams(path string, modifyRequestParams func(request *fasthttp.Request)) ([]byte, error)
  • func (c *Client) GetBlockingAPIResponse(path string, inspectResponse func(resp *fasthttp.Response)) ([]byte, error)
• type ConfigMap
  • func NewConfigMap() *ConfigMap
  • func (cm *ConfigMap) Delete(key interface{}) interface{}
  • func (cm *ConfigMap) Get(key interface{}, newConfig func() (interface{}, error)) (interface{}, error)
• type SortedLabels
  • func GetSortedLabels(m map[string]string) SortedLabels
  • func (sls *SortedLabels) GetByName(name string) string
  • func (sls *SortedLabels) UnmarshalJSON(data []byte) error

Constants

const BlockingClientReadTimeout = 10 * time.Minute

BlockingClientReadTimeout is the maximum duration for waiting the response from GetBlockingAPI*

Functions

func DoRequestWithPossibleRetry

func DoRequestWithPossibleRetry(hc *fasthttp.HostClient, req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time, requestCounter, retryCounter *metrics.Counter) error

DoRequestWithPossibleRetry performs the given req at hc and stores the response at resp.

func GetHTTPClient

func GetHTTPClient() *http.Client

GetHTTPClient returns default client for http API requests.

func InternString

func InternString(s string) string

InternString returns interned s.

This may be needed for reducing the amounts of allocated memory.

func JoinHostPort

func JoinHostPort(host string, port int) string

JoinHostPort returns host:port.

Host may be dns name, ipv4 or ipv6 address.

func SanitizeLabelName

func SanitizeLabelName(name string) string

SanitizeLabelName replaces anything that doesn't match client_label.LabelNameRE with an underscore.

This has been copied from Prometheus sources at util/strutil/strconv.go

Types

type Client

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

Client is http client, which talks to the given apiServer.

func NewClient

func NewClient(apiServer string, ac *promauth.Config, proxyURL *proxy.URL, proxyAC *promauth.Config) (*Client, error)

NewClient returns new Client for the given args.

func (*Client) Addr

func (c *Client) Addr() string

Addr returns the address the client connects to.

func (*Client) GetAPIResponse

func (c *Client) GetAPIResponse(path string) ([]byte, error)

GetAPIResponse returns response for the given absolute path.

func (*Client) GetAPIResponseWithReqParams

func (c *Client) GetAPIResponseWithReqParams(path string, modifyRequestParams func(request *fasthttp.Request)) ([]byte, error)

GetAPIResponseWithReqParams returns response for given absolute path with optional callback for request. modifyRequestParams should never reference data from request.

func (*Client) GetBlockingAPIResponse

func (c *Client) GetBlockingAPIResponse(path string, inspectResponse func(resp *fasthttp.Response)) ([]byte, error)

GetBlockingAPIResponse returns response for given absolute path with blocking client and optional callback for api response, inspectResponse - should never reference data from response.

type ConfigMap

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

ConfigMap is a map for storing discovery api configs.

It automatically removes old configs which weren't accessed recently.

func NewConfigMap

func NewConfigMap() *ConfigMap

NewConfigMap creates ConfigMap

func (*ConfigMap) Delete

func (cm *ConfigMap) Delete(key interface{}) interface{}

Delete deletes config for the given key from cm and returns it.

func (*ConfigMap) Get

func (cm *ConfigMap) Get(key interface{}, newConfig func() (interface{}, error)) (interface{}, error)

Get returns config for the given key.

Key must be a pointer.

It creates new config map with newConfig() call if cm doesn't contain config under the given key.

type SortedLabels

type SortedLabels []prompbmarshal.Label

SortedLabels represents sorted labels.

func GetSortedLabels

func GetSortedLabels(m map[string]string) SortedLabels

GetSortedLabels returns SortedLabels built from m.

func (*SortedLabels) GetByName

func (sls *SortedLabels) GetByName(name string) string

GetByName returns the label with the given name from sls.

func (*SortedLabels) UnmarshalJSON

func (sls *SortedLabels) UnmarshalJSON(data []byte) error

UnmarshalJSON unmarshals JSON from data.