telemetry

Documentation

Index

• type Collector
  • func NewCollector(client client.Client, config *Config, kubeConfig *rest.Config) (*Collector, error)
  • func (c *Collector) NeedLeaderElection() bool
  • func (c *Collector) Start(ctx context.Context) error
  • func (c *Collector) Stop()
• type Config
  • func DefaultConfig() *Config

Types

type Collector

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

Collector handles telemetry data collection and sending

func NewCollector

func NewCollector(client client.Client, config *Config, kubeConfig *rest.Config) (*Collector, error)

NewCollector creates a new telemetry collector

func (*Collector) NeedLeaderElection

func (c *Collector) NeedLeaderElection() bool

NeedLeaderElection implements manager.LeaderElectionRunnable

func (*Collector) Start

func (c *Collector) Start(ctx context.Context) error

Start implements manager.Runnable

func (*Collector) Stop

func (c *Collector) Stop()

Stop halts telemetry collection

type Config

type Config struct {
	// Disable telemetry collection if set to true
	Disabled bool
	// Endpoint to send telemetry data to
	Endpoint string
	// Interval between telemetry data collection
	Interval time.Duration
	// CozystackVersion represents the current version of Cozystack
	CozystackVersion string
}

Config holds telemetry configuration

func DefaultConfig

func DefaultConfig() *Config

DefaultConfig returns default telemetry configuration