discoveryutils

Documentation

Index

• Constants
• func DoRequestWithPossibleRetry(hc *fasthttp.HostClient, req *fasthttp.Request, resp *fasthttp.Response, ...) error
• func GetHTTPClient() *http.Client
• func JoinHostPort(host string, port int) string
• func SanitizeLabelName(name string) string
• func TestEqualLabelss(t *testing.T, got, want []*promutils.Labels)
• type Client
  • func NewClient(apiServer string, ac *promauth.Config, proxyURL *proxy.URL, ...) (*Client, error)
  • func (c *Client) APIServer() string
  • 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)

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 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

func TestEqualLabelss

func TestEqualLabelss(t *testing.T, got, want []*promutils.Labels)

TestEqualLabelss tests whether got are equal to want.

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) APIServer

func (c *Client) APIServer() string

APIServer returns the API server address

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.