telemetry

package
v2.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 5, 2026 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// DataPlaneK8sResourceName is the registered name of resource in kubernetes for dataplanes.
	DataPlaneK8sResourceName = "dataplanes"
	// DataPlaneCountKind is the kind of provider reporting number of dataplanes.
	DataPlaneCountKind = provider.Kind("dataplanes_count")

	// ControlPlaneK8sResourceName is the registered name of resource in kubernetes for controlplanes.
	ControlPlaneK8sResourceName = "controlplanes"
	// ControlPlaneCountKind is the kind of provider reporting number of controlplanes.
	ControlPlaneCountKind = provider.Kind("controlplanes_count")

	// AIGatewayK8sResourceName is the registered name of resource in kubernetes for AIgateways.
	AIGatewayK8sResourceName = "aigateways"
	// AIGatewayCountKind is the kind of provider reporting number of AIGateways.
	AIGatewayCountKind = provider.Kind("aigateways_count")

	// StandaloneDataPlaneCountProviderName is the name of the standalone dataplane count provider.
	StandaloneDataPlaneCountProviderName = "standalone_dataplanes"

	// StandaloneControlPlaneCountProviderName is the name of the standalone controlplane count provider.
	StandaloneControlPlaneCountProviderName = "standalone_controlplanes"

	// RequestedDataPlaneReplicasCountProviderName is the name of the provider reporting requested replicas count for dataplanes.
	RequestedDataPlaneReplicasCountProviderName = "requested_dataplanes_replicas"

	// RequestedControlPlaneReplicasCountProviderName is the name of the provider reporting requested replicas count for controlplanes.
	RequestedControlPlaneReplicasCountProviderName = "requested_controlplanes_replicas"
)
View Source
const (
	// GatewayCountProviderName is the name of the gateway count provider.
	GatewayCountProviderName = "gateways"
	// GatewayCountProviderKind is the kind of the gateway count provider.
	GatewayCountProviderKind = telemetryprovider.Kind("gateway_count")

	// GatewayCountKey is the key for count of all gateways regardless of the controller.
	GatewayCountKey = "k8s_gateways_count"
	// ReconciledGatewayCountKey is the key for count of gateways reconciled by the controller.
	ReconciledGatewayCountKey = "k8s_gateways_reconciled_count"
	// ProgrammedGatewayCountKey is the key for count of gateways successfully configured ("Programmed") by the controller.
	ProgrammedGatewayCountKey = "k8s_gateways_programmed_count"
	// AttachedRouteCountKey is the key for the total count of attached routes to all programmed gateways.
	AttachedRouteCountKey = "k8s_gateways_attached_routes_count"
	// HybridGatewayCountKey is the key for count of Konnect hybrid gateways.
	HybridGatewayCountKey = "konnect_hybrid_gateways_count"
	// ProgrammedHybridGatewayCountKey is the key for count of programmed Konnect hybrid gateways.
	ProgrammedHybridGatewayCountKey = "konnect_hybrid_gateways_programmed_count"
	// HybridGatewayAttachedRouteKey is the total count of attached routes to the programmed hybrid gateways.
	HybridGatewayAttachedRouteKey = "konnect_hybrid_gateways_attached_routes_count"
)
View Source
const (
	SignalStart = "gateway-operator-start"
	SignalPing  = "gateway-operator-ping"
)

Variables

This section is empty.

Functions

func AddObjectCountProviderOrLog

func AddObjectCountProviderOrLog[
	T constraints.SupportedKonnectEntityType,
	TEnt constraints.EntityType[T],
](
	w telemetry.Workflow,
	metadataClient metadata.Interface,
	restMapper meta.RESTMapper,
	log logr.Logger,
	group string,
	version string,
)

AddObjectCountProviderOrLog adds a provider for counting objects of the specified type to the workflow. If this fails to create the provider, it logs the error on Info level (as this is not a critical operation).

func CreateManager

func CreateManager(signal string, restConfig *rest.Config, log logr.Logger, meta mgrmetadata.Info, cfg Config) (telemetry.Manager, error)

CreateManager creates telemetry manager using the provided rest.Config.

func NewAIgatewayCountProvider

func NewAIgatewayCountProvider(m metadata.Interface, restMapper meta.RESTMapper) (provider.Provider, error)

NewAIgatewayCountProvider creates a provider for number of dataplanes in the cluster.

func NewControlPlaneCountProvider

func NewControlPlaneCountProvider(m metadata.Interface, restMapper meta.RESTMapper) (provider.Provider, error)

NewControlPlaneCountProvider creates a provider for number of dataplanes in the cluster.

func NewDataPlaneCountProvider

func NewDataPlaneCountProvider(m metadata.Interface, restMapper meta.RESTMapper) (provider.Provider, error)

NewDataPlaneCountProvider creates a provider for number of dataplanes in the cluster.

func NewDataPlaneRequestedReplicasCountProvider

func NewDataPlaneRequestedReplicasCountProvider(cl client.Client) (provider.Provider, error)

func NewObjectCountProvider

func NewObjectCountProvider[
	T constraints.SupportedKonnectEntityType,
	TEnt constraints.EntityType[T],
](metadataClient metadata.Interface, restMapper meta.RESTMapper, group string, version string) (provider.Provider, error)

NewObjectCountProvider creates a provider for number of objects in the cluster.

func NewStandaloneControlPlaneCountProvider

func NewStandaloneControlPlaneCountProvider(cl client.Client) (provider.Provider, error)

func NewStandaloneDataPlaneCountProvider

func NewStandaloneDataPlaneCountProvider(cl client.Client) (provider.Provider, error)

Types

type Config

type Config struct {
	DataPlaneControllerEnabled          bool
	DataPlaneBlueGreenControllerEnabled bool
	ControlPlaneControllerEnabled       bool
	GatewayControllerEnabled            bool
	KonnectControllerEnabled            bool
	AIGatewayControllerEnabled          bool
	KongPluginInstallationEnabled       bool
}

Config holds the configuration that is sent to telemetry manager.

type Payload

type Payload = types.ProviderReport

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL