telemetry

package
v1.6.1-0...-f207c0f Latest Latest
Warning

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

Go to latest
Published: Sep 28, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SignalStart = prefix + "-start"
	SignalPing  = prefix + "-ping"
)

Variables

This section is empty.

Functions

func CreateManager

func CreateManager(
	logger logr.Logger,
	restConfig *rest.Config,
	gatewaysCounter workflows.DiscoveredGatewaysCounter,
	fixedPayload types.Payload,
	reportCfg ReportConfig,
) (telemetry.Manager, error)

CreateManager creates telemetry manager using the provided rest.Config.

func SetupAnonymousReports

func SetupAnonymousReports(
	ctx context.Context,
	kubeCfg *rest.Config,
	clientsProvider GatewayClientsProvider,
	reportCfg ReportConfig,
	instanceID interface{ String() string },
	fixedPayloadCustomizer types.PayloadCustomizer,
) (func(), error)

SetupAnonymousReports sets up and starts the anonymous reporting and returns a cleanup function and an error. In case of no error returned - the caller is responsible to call the returned function - to stop the reports sending.

Types

type GatewayClientsProvider

type GatewayClientsProvider interface {
	GatewayClients() []*adminapi.Client
	GatewayClientsCount() int
}

GatewayClientsProvider is an interface that provides clients for the currently discovered Gateway instances.

type ReportConfig

type ReportConfig struct {
	SplunkEndpoint                   string
	SplunkEndpointInsecureSkipVerify bool
	TelemetryPeriod                  time.Duration
	ReportValues                     ReportValues
}

type ReportValues

type ReportValues struct {
	FeatureGates                   map[string]bool
	MeshDetection                  bool
	PublishServiceNN               k8stypes.NamespacedName
	KonnectSyncEnabled             bool
	GatewayServiceDiscoveryEnabled bool
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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