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) DeleteServiceAttachment(saKey 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)
  • func (im *ControllerMetrics) SetServiceAttachment(saKey string, state pscmetrics.PSCState)
• type IngressMetricsCollector
• type IngressState
  • func NewIngressState(ing *v1.Ingress, fc *frontendconfigv1beta1.FrontendConfig, ...) IngressState
• type L4ILBMetricsCollector
• type L4ILBServiceState
• type NegMetricsCollector
• type NegServiceState
• type VmIpNegType
  • func NewVmIpNegType(trafficPolicyLocal bool) *VmIpNegType

Constants

const (

	// StaticGlobalIPNameKey tells the Ingress controller to use a specific GCE
	// static ip for its forwarding rules. If specified, the Ingress controller
	// assigns the static ip by this name to the forwarding rules of the given
	// Ingress. The controller *does not* manage this ip, it is the users
	// responsibility to create/delete it.
	StaticGlobalIPNameKey = "kubernetes.io/ingress.global-static-ip-name"

	// SSLCertKey is the annotation key used by controller to record GCP ssl cert.
	SSLCertKey = "ingress.kubernetes.io/ssl-cert"
)

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) DeleteServiceAttachment

func (im *ControllerMetrics) DeleteServiceAttachment(saKey string)

DeleteServiceAttachment removes sa state to the map to be counted during metrics computation. DeleteServiceAttachment implments PSCMetricsCollector.

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.

func (*ControllerMetrics) SetServiceAttachment

func (im *ControllerMetrics) SetServiceAttachment(saKey string, state pscmetrics.PSCState)

SetServiceAttachment adds sa state to the map to be counted during metrics computation. SetServiceAttachment implments PSCMetricsCollector.

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 *v1.Ingress, fc *frontendconfigv1beta1.FrontendConfig, 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
	// InSuccess specifies if the ILB service VIP is configured.
	InSuccess 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
	// VmIpNeg specifies if a service uses GCE_VM_IP NEG.
	VmIpNeg *VmIpNegType
	// CustomNamedNeg is the count of standalone negs with custom names
	CustomNamedNeg int
	// SuccessfulNeg is the count of successful NEG syncer creations
	SuccessfulNeg int
	// SuccessfulNeg is the count of errors in NEG syncer creations
	ErrorNeg int
}

NegServiceState contains all the neg usage associated with one service

type VmIpNegType

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

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

func NewVmIpNegType

func NewVmIpNegType(trafficPolicyLocal bool) *VmIpNegType

NewVmIpNegType returns a new VmIpNegType.