telemetry

Documentation

Index

• Constants
• func AddObjectCountProviderOrLog[T constraints.SupportedKonnectEntityType, TEnt constraints.EntityType[T]](w telemetry.Workflow, dyn dynamic.Interface, restMapper meta.RESTMapper, ...)
• func CreateManager(signal string, restConfig *rest.Config, log logr.Logger, meta metadata.Info, ...) (telemetry.Manager, error)
• func NewAIgatewayCountProvider(dyn dynamic.Interface, restMapper meta.RESTMapper) (provider.Provider, error)
• func NewControlPlaneCountProvider(dyn dynamic.Interface, restMapper meta.RESTMapper) (provider.Provider, error)
• func NewControlPlaneRequestedReplicasCountProvider(cl client.Client) (provider.Provider, error)
• func NewDataPlaneCountProvider(dyn dynamic.Interface, restMapper meta.RESTMapper) (provider.Provider, error)
• func NewDataPlaneRequestedReplicasCountProvider(cl client.Client) (provider.Provider, error)
• func NewObjectCountProvider[T constraints.SupportedKonnectEntityType, TEnt constraints.EntityType[T]](dyn dynamic.Interface, restMapper meta.RESTMapper, group string, ...) (provider.Provider, error)
• func NewStandaloneControlPlaneCountProvider(cl client.Client) (provider.Provider, error)
• func NewStandaloneDataPlaneCountProvider(cl client.Client) (provider.Provider, error)
• type Config
• type Payload

Constants

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

const (
	SignalStart = "gateway-operator-start"
	SignalPing  = "gateway-operator-ping"
)

Functions

func AddObjectCountProviderOrLog

func AddObjectCountProviderOrLog[
	T constraints.SupportedKonnectEntityType,
	TEnt constraints.EntityType[T],
](
	w telemetry.Workflow,
	dyn dynamic.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 metadata.Info, cfg Config) (telemetry.Manager, error)

CreateManager creates telemetry manager using the provided rest.Config.

func NewAIgatewayCountProvider

func NewAIgatewayCountProvider(dyn dynamic.Interface, restMapper meta.RESTMapper) (provider.Provider, error)

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

func NewControlPlaneCountProvider

func NewControlPlaneCountProvider(dyn dynamic.Interface, restMapper meta.RESTMapper) (provider.Provider, error)

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

func NewControlPlaneRequestedReplicasCountProvider

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

func NewDataPlaneCountProvider

func NewDataPlaneCountProvider(dyn dynamic.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],
](dyn dynamic.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