config

Documentation

Index

• Constants
• func ConstantBackoff(min, _ time.Duration, _ int, _ *http.Response) time.Duration
• type ClusterFilterParameters
• type CollectionParameters
• type DensifyParameters
• type ForwarderParameters
• type Parameters
  • func ReadConfig() (p *Parameters, err error)
• type PrometheusParameters
• type ProxyParameters
• type RetryConfig
  • func (rc *RetryConfig) NewClient(rt http.RoundTripper, logger interface{}) (*http.Client, error)
  • func (rc *RetryConfig) Validate() (err error)
• type UrlConfig
• type ValueOrPath
  • func NewValueOrPath(s string, fileOnly, shouldRead bool) (vop *ValueOrPath, e error)
  • func (vop *ValueOrPath) IsEmpty() bool
  • func (vop *ValueOrPath) IsFile() bool
  • func (vop *ValueOrPath) Path() string
  • func (vop *ValueOrPath) Value() string

Constants

const (
	DefaultPolicy     = "default"
	ExponentialPolicy = "exponential"
	JitterPolicy      = "jitter"
	ConstantPolicy    = "const"
)

policies

const (
	Http          = "http"
	Https         = Http + "s"
	NoPort uint64 = 99999 // 0 is a valid (system) port, so need something > maxPort

)

const (
	Empty = ""
	Comma = ","
	Dot   = "."
)

Functions

func ConstantBackoff

func ConstantBackoff(min, _ time.Duration, _ int, _ *http.Response) time.Duration

Types

type ClusterFilterParameters

type ClusterFilterParameters struct {
	Name        string         `yaml:"name"`
	Identifiers model.LabelSet `yaml:"identifiers,omitempty"`
}

type CollectionParameters

type CollectionParameters struct {
	Include       map[string]bool `yaml:"include,omitempty"`
	Interval      string          `yaml:"interval"`
	IntervalSize  uint64          `yaml:"interval_size"`
	History       uint64          `yaml:"history"`
	HistoryInt    int             `yaml:"-"`
	Offset        uint64          `yaml:"offset"`
	OffsetInt     int             `yaml:"-"`
	SampleRate    uint64          `yaml:"sample_rate"`
	SampleRateSt  string          `yaml:"-"`
	NodeGroupList string          `yaml:"node_group_list"`
}

type DensifyParameters

type DensifyParameters struct {
	UrlConfig   *UrlConfig   `yaml:"url"`
	Endpoint    string       `yaml:"endpoint"`
	RetryConfig *RetryConfig `yaml:"retry,omitempty"`
}

type ForwarderParameters

type ForwarderParameters struct {
	Densify *DensifyParameters `yaml:"densify"`
	Proxy   *ProxyParameters   `yaml:"proxy,omitempty"`
	Prefix  string             `yaml:"prefix,omitempty"`
}

type Parameters

type Parameters struct {
	Forwarder  *ForwarderParameters       `yaml:"forwarder"`
	Prometheus *PrometheusParameters      `yaml:"prometheus"`
	Collection *CollectionParameters      `yaml:"collection"`
	Clusters   []*ClusterFilterParameters `yaml:"clusters"`
	Debug      bool                       `yaml:"debug"`
}

func ReadConfig

func ReadConfig() (p *Parameters, err error)

type PrometheusParameters

type PrometheusParameters struct {
	UrlConfig   *UrlConfig         `yaml:"url"`
	BearerToken string             `yaml:"bearer_token,omitempty"`
	CaCertPath  string             `yaml:"ca_cert,omitempty"`
	SigV4Config *sigv4.SigV4Config `yaml:"sigv4,omitempty"`
	RetryConfig *RetryConfig       `yaml:"retry,omitempty"`
}

type ProxyParameters

type ProxyParameters struct {
	UrlConfig *UrlConfig `yaml:"url"`
	Auth      string     `yaml:"auth,omitempty"`
	Server    string     `yaml:"server,omitempty"`
	Domain    string     `yaml:"domain,omitempty"`
}

type RetryConfig

type RetryConfig struct {
	WaitMin     time.Duration `yaml:"wait_min"`
	WaitMax     time.Duration `yaml:"wait_max"`
	MaxAttempts int           `yaml:"max_attempts"`
	Policy      string        `yaml:"policy,omitempty"`
	// contains filtered or unexported fields
}

func (*RetryConfig) NewClient

func (rc *RetryConfig) NewClient(rt http.RoundTripper, logger interface{}) (*http.Client, error)

NewClient should be called only after Validate has been called, to make sure that rc is a valid RetryConfig

func (*RetryConfig) Validate

func (rc *RetryConfig) Validate() (err error)

Validate must be called once, after rc has been constructed / unmarshalled

type UrlConfig

type UrlConfig struct {
	Scheme            string `yaml:"scheme"`
	Host              string `yaml:"host"`
	Port              uint64 `yaml:"port"`
	Username          string `yaml:"username,omitempty"`
	Password          string `yaml:"password,omitempty"`
	EncryptedPassword string `yaml:"encrypted_password,omitempty"`
	Url               string `yaml:"-"`
}

type ValueOrPath

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

func NewValueOrPath

func NewValueOrPath(s string, fileOnly, shouldRead bool) (vop *ValueOrPath, e error)

func (*ValueOrPath) IsEmpty

func (vop *ValueOrPath) IsEmpty() bool

func (*ValueOrPath) IsFile

func (vop *ValueOrPath) IsFile() bool

func (*ValueOrPath) Path

func (vop *ValueOrPath) Path() string

func (*ValueOrPath) Value

func (vop *ValueOrPath) Value() string