collector

Documentation

Index

• type C
  • func New(prometheusURL string, targetNodeSelector map[string]string) *C
  • func (c *C) NeedLeaderElection() bool
  • func (c *C) PayloadCh() <-chan *v1.SendClusterTelemetryRequest_Payload
  • func (c *C) SetupWithManager(mgr ctrl.Manager) error
  • func (c *C) Start(ctx context.Context) error

Types

type C

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

C is a collector that collects telemetry data.

func New

func New(prometheusURL string, targetNodeSelector map[string]string) *C

New returns a new collector instance.

func (*C) NeedLeaderElection

func (c *C) NeedLeaderElection() bool

NeedLeaderElection implements LeaderElectionRunnable and always returns true.

func (*C) PayloadCh

func (c *C) PayloadCh() <-chan *v1.SendClusterTelemetryRequest_Payload

PayloadCh returns a read-only channel that can be used to receive telemetry payloads.

func (*C) SetupWithManager

func (c *C) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager registers the collector with the manager.

func (*C) Start

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

Start starts the collector.