discoveryutils

Documentation

Index

• Constants
• func GetHTTPClient() *http.Client
• 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 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

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.