metrics

Documentation

Index

• Constants
• type ControllerMetrics
  • func NewControllerMetrics() *ControllerMetrics
  • func (im *ControllerMetrics) DeleteIngress(ingKey string)
  • func (im *ControllerMetrics) DeleteL4ILBService(svcKey string)
  • func (im *ControllerMetrics) DeleteNegService(svcKey string)
  • func (im *ControllerMetrics) Run(stopCh <-chan struct{})
  • func (im *ControllerMetrics) SetIngress(ingKey string, ing IngressState)
  • func (im *ControllerMetrics) SetL4ILBService(svcKey string, state L4ILBServiceState)
  • func (im *ControllerMetrics) SetNegService(svcKey string, negState NegServiceState)
• type IngressMetricsCollector
• type IngressState
  • func NewIngressState(ing *v1beta1.Ingress, svcPorts []utils.ServicePort) IngressState
• type L4ILBMetricsCollector
• type L4ILBServiceState
• type NegMetricsCollector
• type NegServiceState
• type VmPrimaryIpNegType
  • func NewVmPrimaryIpNegType(trafficPolicyLocal bool) *VmPrimaryIpNegType

Constants

const GLBC_NAMESPACE = "glbc"

Types

type ControllerMetrics

type ControllerMetrics struct {
	sync.Mutex
	// contains filtered or unexported fields
}

ControllerMetrics contains the state of the all ingresses.

func NewControllerMetrics

func NewControllerMetrics() *ControllerMetrics

NewControllerMetrics initializes ControllerMetrics and starts a go routine to compute and export metrics periodically.

func (*ControllerMetrics) DeleteIngress

func (im *ControllerMetrics) DeleteIngress(ingKey string)

DeleteIngress implements IngressMetricsCollector.

func (*ControllerMetrics) DeleteL4ILBService

func (im *ControllerMetrics) DeleteL4ILBService(svcKey string)

DeleteL4ILBService implements L4ILBMetricsCollector.

func (*ControllerMetrics) DeleteNegService

func (im *ControllerMetrics) DeleteNegService(svcKey string)

DeleteNegService implements NegMetricsCollector.

func (*ControllerMetrics) Run

func (im *ControllerMetrics) Run(stopCh <-chan struct{})

func (*ControllerMetrics) SetIngress

func (im *ControllerMetrics) SetIngress(ingKey string, ing IngressState)

SetIngress implements IngressMetricsCollector.

func (*ControllerMetrics) SetL4ILBService

func (im *ControllerMetrics) SetL4ILBService(svcKey string, state L4ILBServiceState)

SetL4ILBService implements L4ILBMetricsCollector.

func (*ControllerMetrics) SetNegService

func (im *ControllerMetrics) SetNegService(svcKey string, negState NegServiceState)

SetNegService implements NegMetricsCollector.

type IngressMetricsCollector

type IngressMetricsCollector interface {
	// SetIngress adds/updates ingress state for given ingress key.
	SetIngress(ingKey string, ing IngressState)
	// DeleteIngress removes the given ingress key.
	DeleteIngress(ingKey string)
}

IngressMetricsCollector is an interface to update/delete ingress states in the cache that is used for computing ingress usage metrics.

type IngressState

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

IngressState defines an ingress and its associated service ports.

func NewIngressState

func NewIngressState(ing *v1beta1.Ingress, svcPorts []utils.ServicePort) IngressState

NewIngressState returns ingress state for given ingress and service ports.

type L4ILBMetricsCollector

type L4ILBMetricsCollector interface {
	// SetL4ILBService adds/updates L4 ILB service state for given service key.
	SetL4ILBService(svcKey string, state L4ILBServiceState)
	// DeleteL4ILBService removes the given L4 ILB service key.
	DeleteL4ILBService(svcKey string)
}

L4ILBMetricsCollector is an interface to update/delete L4 ILb service states in the cache that is used for computing L4 ILB usage metrics.

type L4ILBServiceState

type L4ILBServiceState struct {
	// EnabledGlobalAccess specifies if Global Access is enabled.
	EnabledGlobalAccess bool
	// EnabledCustomSubNet specifies if Custom Subnet is enabled.
	EnabledCustomSubnet bool
}

L4ILBServiceState defines if global access and subnet features are enabled for an L4 ILB service.

type NegMetricsCollector

type NegMetricsCollector interface {
	// SetNegService adds/updates neg state for given service key.
	SetNegService(svcKey string, negState NegServiceState)
	// DeleteNegService removes the given service key.
	DeleteNegService(svcKey string)
}

NegMetricsCollector is an interface to update/delete Neg states in the cache that is used for computing neg usage metrics.

type NegServiceState

type NegServiceState struct {
	// standaloneNeg is the count of standalone NEG
	StandaloneNeg int
	// ingressNeg is the count of NEGs created for ingress
	IngressNeg int
	// asmNeg is the count of NEGs created for ASM
	AsmNeg int
	// VmPrimaryIpNeg specifies if a service uses GCE_VM_PRIMARY_IP NEG.
	VmPrimaryIpNeg *VmPrimaryIpNegType
}

NegServiceState contains all the neg usage associated with one service

type VmPrimaryIpNegType

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

VmPrimaryIpNegType contains whether a GCE_VM_PRIMARY_IP NEG is requesting for local traffic (or service external policy set to local).

func NewVmPrimaryIpNegType

func NewVmPrimaryIpNegType(trafficPolicyLocal bool) *VmPrimaryIpNegType

NewVmPrimaryIpNegType returns a new VmPrimaryIpNegType.