collector

Documentation

Index

• Constants
• func IsInvalidConfig(err error) bool
• type Deployment
  • func NewDeployment(config DeploymentConfig) (*Deployment, error)
  • func (d *Deployment) Collect(ch chan<- prometheus.Metric) error
  • func (d *Deployment) Describe(ch chan<- *prometheus.Desc) error
• type DeploymentConfig
• type RateLimit
  • func NewRateLimit(config RateLimitConfig) (*RateLimit, error)
  • func (u *RateLimit) Collect(ch chan<- prometheus.Metric) error
  • func (u *RateLimit) Describe(ch chan<- *prometheus.Desc) error
• type RateLimitConfig
• type ResourceGroup
  • func NewResourceGroup(config ResourceGroupConfig) (*ResourceGroup, error)
  • func (r *ResourceGroup) Collect(ch chan<- prometheus.Metric) error
  • func (r *ResourceGroup) Describe(ch chan<- *prometheus.Desc) error
• type ResourceGroupConfig
• type SPExpiration
  • func NewSPExpiration(config SPExpirationConfig) (*SPExpiration, error)
  • func (v *SPExpiration) Collect(ch chan<- prometheus.Metric) error
  • func (v *SPExpiration) Describe(ch chan<- *prometheus.Desc) error
• type SPExpirationConfig
• type Set
  • func NewSet(config SetConfig) (*Set, error)
• type SetConfig
• type Usage
  • func NewUsage(config UsageConfig) (*Usage, error)
  • func (u *Usage) Collect(ch chan<- prometheus.Metric) error
  • func (u *Usage) Describe(ch chan<- *prometheus.Desc) error
• type UsageConfig
• type VMSSRateLimit
  • func NewVMSSRateLimit(config VMSSRateLimitConfig) (*VMSSRateLimit, error)
  • func (u *VMSSRateLimit) Collect(ch chan<- prometheus.Metric) error
  • func (u *VMSSRateLimit) Describe(ch chan<- *prometheus.Desc) error
• type VMSSRateLimitConfig
• type VPNConnection
  • func NewVPNConnection(config VPNConnectionConfig) (*VPNConnection, error)
  • func (v *VPNConnection) Collect(ch chan<- prometheus.Metric) error
  • func (v *VPNConnection) Describe(ch chan<- *prometheus.Desc) error
• type VPNConnectionConfig

Constants

const (
	MetricsNamespace = "azure_operator"
)

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

Types

type Deployment

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

func NewDeployment

func NewDeployment(config DeploymentConfig) (*Deployment, error)

NewDeployment exposes metrics about the Azure ARM Deployments for every cluster on this installation. It finds the cluster in the control plane, and uses the cluster Azure credentials to find the Deployments info.

func (*Deployment) Collect

func (d *Deployment) Collect(ch chan<- prometheus.Metric) error

func (*Deployment) Describe

func (d *Deployment) Describe(ch chan<- *prometheus.Desc) error

type DeploymentConfig

type DeploymentConfig struct {
	G8sClient versioned.Interface
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger
}

type RateLimit

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

func NewRateLimit

func NewRateLimit(config RateLimitConfig) (*RateLimit, error)

NewRateLimit exposes metrics about the Azure resource group client rate limit. It creates and fetches a resource group. That way it can inspect the Azure API response to find rate limit headers. It uses the credentials found in the "credential-*" secrets of the control plane.

func (*RateLimit) Collect

func (u *RateLimit) Collect(ch chan<- prometheus.Metric) error

func (*RateLimit) Describe

func (u *RateLimit) Describe(ch chan<- *prometheus.Desc) error

type RateLimitConfig

type RateLimitConfig struct {
	G8sClient versioned.Interface
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger
	Location  string
}

type ResourceGroup

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

func NewResourceGroup

func NewResourceGroup(config ResourceGroupConfig) (*ResourceGroup, error)

NewResourceGroup exposes metrics on the existing resource groups for every subscription. It exposes metrcis about the subscriptions found in the "credential-*" secrets of the control plane.

func (*ResourceGroup) Collect

func (r *ResourceGroup) Collect(ch chan<- prometheus.Metric) error

func (*ResourceGroup) Describe

func (r *ResourceGroup) Describe(ch chan<- *prometheus.Desc) error

type ResourceGroupConfig

type ResourceGroupConfig struct {
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger
}

type SPExpiration

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

func NewSPExpiration

func NewSPExpiration(config SPExpirationConfig) (*SPExpiration, error)

NewSPExpiration exposes metrics about the expiration date of Azure Service Principals. It exposes metrcis about the Service Principals found in the "credential-*" secrets of the control plane.

func (*SPExpiration) Collect

func (v *SPExpiration) Collect(ch chan<- prometheus.Metric) error

func (*SPExpiration) Describe

func (v *SPExpiration) Describe(ch chan<- *prometheus.Desc) error

type SPExpirationConfig

type SPExpirationConfig struct {
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger
}

type Set

type Set struct {
	*collector.Set
}

Set is basically only a wrapper for the operator's collector implementations. It eases the iniitialization and prevents some weird import mess so we do not have to alias packages.

func NewSet

func NewSet(config SetConfig) (*Set, error)

type SetConfig

type SetConfig struct {
	K8sClient                 k8sclient.Interface
	Location                  string
	Logger                    micrologger.Logger
	ControlPlaneResourceGroup string
}

type Usage

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

func NewUsage

func NewUsage(config UsageConfig) (*Usage, error)

NewUsage exposes metrics about the quota usage on Azure so we can alert when we are reaching the quota limits. It exposes quota metrics for every subscription found in the "credential-*" secrets of the control plane.

func (*Usage) Collect

func (u *Usage) Collect(ch chan<- prometheus.Metric) error

func (*Usage) Describe

func (u *Usage) Describe(ch chan<- *prometheus.Desc) error

type UsageConfig

type UsageConfig struct {
	G8sClient versioned.Interface
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger

	Location string
}

type VMSSRateLimit

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

func NewVMSSRateLimit

func NewVMSSRateLimit(config VMSSRateLimitConfig) (*VMSSRateLimit, error)

func (*VMSSRateLimit) Collect

func (u *VMSSRateLimit) Collect(ch chan<- prometheus.Metric) error

func (*VMSSRateLimit) Describe

func (u *VMSSRateLimit) Describe(ch chan<- *prometheus.Desc) error

type VMSSRateLimitConfig

type VMSSRateLimitConfig struct {
	G8sClient versioned.Interface
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger
}

type VPNConnection

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

func NewVPNConnection

func NewVPNConnection(config VPNConnectionConfig) (*VPNConnection, error)

func (*VPNConnection) Collect

func (v *VPNConnection) Collect(ch chan<- prometheus.Metric) error

func (*VPNConnection) Describe

func (v *VPNConnection) Describe(ch chan<- *prometheus.Desc) error

type VPNConnectionConfig

type VPNConnectionConfig struct {
	K8sClient kubernetes.Interface
	Logger    micrologger.Logger

	ResourceGroup string
}