telemetry

Documentation

Overview

Package telemetry provides telemetry functionality for the ToolHive operator.

Index

• type LeaderTelemetryRunnable
  • func (*LeaderTelemetryRunnable) NeedsLeaderElection() bool
  • func (t *LeaderTelemetryRunnable) Start(ctx context.Context) error
• type Service
  • func NewService(k8sClient client.Client, namespace string) *Service
  • func (s *Service) CheckForUpdates(ctx context.Context) error
  • func (s *Service) StartTelemetryWorker(ctx context.Context)

Types

type LeaderTelemetryRunnable

type LeaderTelemetryRunnable struct {
	TelemetryService *Service
}

LeaderTelemetryRunnable runs telemetry checks only when this instance is the leader

func (*LeaderTelemetryRunnable) NeedsLeaderElection

func (*LeaderTelemetryRunnable) NeedsLeaderElection() bool

NeedsLeaderElection indicates whether this runnable needs leader election

func (*LeaderTelemetryRunnable) Start

func (t *LeaderTelemetryRunnable) Start(ctx context.Context) error

Start starts the telemetry runner

type Service

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

Service handles telemetry operations for the operator

func NewService

func NewService(k8sClient client.Client, namespace string) *Service

NewService creates a new Service instance

func (*Service) CheckForUpdates

func (s *Service) CheckForUpdates(ctx context.Context) error

CheckForUpdates checks for updates and sends telemetry data

func (*Service) StartTelemetryWorker

func (s *Service) StartTelemetryWorker(ctx context.Context)

StartTelemetryWorker starts a background worker that periodically checks for updates This should only be called by the leader