telemetry

Documentation

Index

• Constants
• Variables
• func CreateManager(restConfig *rest.Config, gatewaysCounter workflows.DiscoveredGatewaysCounter, ...) (telemetry.Manager, error)
• func SetupAnonymousReports(ctx context.Context, kubeCfg *rest.Config, ...) (func(), error)
• type GatewayClientsProvider
• type InstanceIDProvider
• type Payload
• type ReportValues

Constants

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

Variables

var (
	SplunkEndpoint                   = "kong-hf.konghq.com:61833"
	SplunkEndpointInsecureSkipVerify = false
	TelemetryPeriod                  = time.Hour
)

Functions

func CreateManager

func CreateManager(restConfig *rest.Config, gatewaysCounter workflows.DiscoveredGatewaysCounter, fixedPayload Payload, rv ReportValues) (telemetry.Manager, error)

CreateManager creates telemetry manager using the provided rest.Config.

func SetupAnonymousReports

func SetupAnonymousReports(
	ctx context.Context,
	kubeCfg *rest.Config,
	clientsProvider GatewayClientsProvider,
	rv ReportValues,
	instanceIDProvider InstanceIDProvider,
) (func(), error)

SetupAnonymousReports sets up and starts the anonymous reporting and returns a cleanup function and an error. The caller is responsible to call the returned function - when the returned error is not nil - 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 InstanceIDProvider

type InstanceIDProvider interface {
	GetID() uuid.UUID
}

type Payload

type Payload = types.ProviderReport

type ReportValues

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