collector

Documentation

Index

• func IsAlreadyRegisteredError(err error) bool
• func IsInvalidConfig(err error) bool
• func IsWrongTypeError(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 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

Functions

func IsAlreadyRegisteredError

func IsAlreadyRegisteredError(err error) bool

IsAlreadyRegisteredError asserts alreadyRegisteredError.

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func IsWrongTypeError

func IsWrongTypeError(err error) bool

IsWrongTypeError asserts wrongTypeError.

Types

type Deployment

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

func NewDeployment

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

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

	// EnvironmentName is the name of the Azure environment used to compute the
	// azure.Environment type. See also
	// https://godoc.org/github.com/Azure/go-autorest/autorest/azure#Environment.
	EnvironmentName string
}

type RateLimit

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

func NewRateLimit

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

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

	// EnvironmentName is the name of the Azure environment used to compute the
	// azure.Environment type. See also
	// https://godoc.org/github.com/Azure/go-autorest/autorest/azure#Environment.
	EnvironmentName        string
	Location               string
	CPAzureClientSetConfig client.AzureClientSetConfig
}

type ResourceGroup

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

func NewResourceGroup

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

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

	EnvironmentName string
}

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
	Logger    micrologger.Logger

	AzureSetting             setting.Azure
	HostAzureClientSetConfig client.AzureClientSetConfig
}

type Usage

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

func NewUsage

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

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

	// EnvironmentName is the name of the Azure environment used to compute the
	// azure.Environment type. See also
	// https://godoc.org/github.com/Azure/go-autorest/autorest/azure#Environment.
	EnvironmentName string
	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

	// EnvironmentName is the name of the Azure environment used to compute the
	// azure.Environment type. See also
	// https://godoc.org/github.com/Azure/go-autorest/autorest/azure#Environment.
	EnvironmentName        string
	Location               string
	CPAzureClientSetConfig client.AzureClientSetConfig
}

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

	AzureSetting             setting.Azure
	HostAzureClientSetConfig client.AzureClientSetConfig
}