prometheus

Documentation

Index

• Constants
• Variables
• func ListOptions(name string) metav1.ListOptions
• func NewConfigGenerator(logger log.Logger) *configGenerator
• func NewPrometheusCollector(s cache.Store) *prometheusCollector
• func PrometheusStatus(kclient kubernetes.Interface, p *monitoringv1.Prometheus) (*monitoringv1.PrometheusStatus, []v1.Pod, error)
• type BasicAuthCredentials
• type Config
• 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, reconcileErrorsCounter *prometheus.CounterVec, ...)
  • func (c *Operator) Run(stopc <-chan struct{}) error

Constants

const (
	DefaultPrometheusVersion = "v2.5.0"
	DefaultThanosVersion     = "v0.1.0"
)

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",
		"v2.3.1",
		"v2.3.2",
		"v2.4.0",
		"v2.4.1",
		"v2.4.2",
		"v2.4.3",
		"v2.5.0",
	}
)

Functions

func ListOptions

func ListOptions(name string) metav1.ListOptions

func NewConfigGenerator

func NewConfigGenerator(logger log.Logger) *configGenerator

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
	Namespaces                   []string
	Labels                       Labels
	CrdGroup                     string
	CrdKinds                     monitoringv1.CrdKinds
	EnableValidation             bool
	LocalHost                    string
	LogLevel                     string
	LogFormat                    string
	ManageCRDs                   bool
}

Config defines configuration parameters for the Operator.

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

Set implements 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 life 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, reconcileErrorsCounter *prometheus.CounterVec, triggerByCounter *prometheus.CounterVec)

RegisterMetrics registers Prometheus metrics on the given Prometheus registerer.

func (*Operator) Run

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

Run the controller.