prometheus

Documentation

Index

• Constants
• Variables
• func CMToRule(cm *v1.ConfigMap) ([]monitoringv1.PrometheusRule, error)
• func ListOptions(name string) metav1.ListOptions
• func NewPrometheusCollector(s cache.Store) *prometheusCollector
• func PrometheusStatus(kclient kubernetes.Interface, p *monitoringv1.Prometheus) (*monitoringv1.PrometheusStatus, []v1.Pod, error)
• type BasicAuthCredentials
• type Config
• type ConfigMapReference
• type ConfigMapReferenceList
  • func (l *ConfigMapReferenceList) Len() int
  • func (l *ConfigMapReferenceList) Less(i, j int) bool
  • func (l *ConfigMapReferenceList) Swap(i, j int)
• type Labels
  • func (labels *Labels) Merge(otherLabels map[string]string) map[string]string
  • func (labels *Labels) Set(value string) error
  • func (labels *Labels) String() string
• type Operator
  • func New(conf Config, logger log.Logger) (*Operator, error)
  • func (c *Operator) RegisterMetrics(r prometheus.Registerer)
  • func (c *Operator) Run(stopc <-chan struct{}) error

Constants

const (
	DefaultPrometheusVersion = "v2.3.1"
	DefaultThanosVersion     = "v0.1.0-rc.1"
)

Variables

var (
	CompatibilityMatrix = []string{
		"v1.4.0",
		"v1.4.1",
		"v1.5.0",
		"v1.5.1",
		"v1.5.2",
		"v1.5.3",
		"v1.6.0",
		"v1.6.1",
		"v1.6.2",
		"v1.6.3",
		"v1.7.0",
		"v1.7.1",
		"v1.7.2",
		"v1.8.0",
		"v2.0.0",
		"v2.2.1",
	}
)

Functions

func CMToRule

func CMToRule(cm *v1.ConfigMap) ([]monitoringv1.PrometheusRule, error)

CMToRule takes a rule config map and transforms it to possibly multiple rule file crds. It is used in `cmd/po-rule-cm-to-rule-file-crds`. Thereby it needs to be public.

func ListOptions

func ListOptions(name string) metav1.ListOptions

func NewPrometheusCollector

func NewPrometheusCollector(s cache.Store) *prometheusCollector

func PrometheusStatus

func PrometheusStatus(kclient kubernetes.Interface, p *monitoringv1.Prometheus) (*monitoringv1.PrometheusStatus, []v1.Pod, error)

PrometheusStatus evaluates the current status of a Prometheus deployment with respect to its specified resource object. It return the status and a list of pods that are not updated.

Types

type BasicAuthCredentials

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

type Config

type Config struct {
	Host                         string
	KubeletObject                string
	TLSInsecure                  bool
	TLSConfig                    rest.TLSClientConfig
	ConfigReloaderImage          string
	PrometheusConfigReloader     string
	AlertmanagerDefaultBaseImage string
	PrometheusDefaultBaseImage   string
	ThanosDefaultBaseImage       string
	Namespace                    string
	Labels                       Labels
	CrdGroup                     string
	CrdKinds                     monitoringv1.CrdKinds
	EnableValidation             bool
	DisableAutoUserGroup         bool
	LogLevel                     string
}

Config defines configuration parameters for the Operator.

type ConfigMapReference

type ConfigMapReference struct {
	Key      string `json:"key"`
	Checksum string `json:"checksum"`
}

type ConfigMapReferenceList

type ConfigMapReferenceList struct {
	Items []*ConfigMapReference `json:"items"`
}

func (*ConfigMapReferenceList) Len

func (l *ConfigMapReferenceList) Len() int

func (*ConfigMapReferenceList) Less

func (l *ConfigMapReferenceList) Less(i, j int) bool

func (*ConfigMapReferenceList) Swap

func (l *ConfigMapReferenceList) Swap(i, j int)

type Labels

type Labels struct {
	LabelsString string
	LabelsMap    map[string]string
}

func (*Labels) Merge

func (labels *Labels) Merge(otherLabels map[string]string) map[string]string

Merge labels create a new map with labels merged.

func (*Labels) Set

func (labels *Labels) Set(value string) error

Implement the flag.Set interface

func (*Labels) String

func (labels *Labels) String() string

Implement the flag.Value interface

type Operator

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

Operator manages lify cycle of Prometheus deployments and monitoring configurations.

func New

func New(conf Config, logger log.Logger) (*Operator, error)

New creates a new controller.

func (*Operator) RegisterMetrics

func (c *Operator) RegisterMetrics(r prometheus.Registerer)

func (*Operator) Run

func (c *Operator) Run(stopc <-chan struct{}) error

Run the controller.