telemetryexport

type Collector ¶

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

Collector owns a child process and its temporary config. The supervisor owns restart policy; Done reports exit, and Stop joins shutdown and removes the config.

func StartCollector(ctx context.Context, previous *Collector, options CollectorOptions) (*Collector, error)

func (c *Collector) Done() <-chan struct{}

func (c *Collector) StartedAt() time.Time

func (c *Collector) Stop()

type CollectorOptions ¶

type CollectorOptions struct {
	Binary      string
	Config      []byte
	HealthURL   string
	Environment []string
	Args        []string
	Logger      *zap.Logger
}

CollectorOptions contains local process configuration. Only explicitly supplied environment values and allowlisted TLS/proxy settings reach the Collector.

type Config ¶

type Config struct {
	StorageDirectory string
	TokenDirectory   string
	GRPCAddress      string
	HTTPAddress      string
	HealthAddress    string
	// CAFile supplements, rather than replaces, the system trust pool
	// (including SSL_CERT_FILE and SSL_CERT_DIR roots) for relay connections.
	CAFile string
}

Config controls local listeners and state, not the remotely selected relay destination. TokenDirectory must be dedicated to relay credentials; disabling export removes it.

func DefaultConfig(directory string) Config

type Options ¶

type Options struct {
	InstallID       string
	Binary          string
	Config          Config
	Client          telemetryAccessTokenClient
	Logger          *zap.Logger
	InitialSettings *Settings
	FetchSettings   func(context.Context) (Settings, error)
	OnEnabled       func(bool)
}

Options separates control-plane settings and host lifecycle integration from token renewal, reconciliation, and Collector process supervision. An empty InstallID makes the supervisor ineligible: Run removes stale credentials and returns without fetching settings. A nil InitialSettings fetches settings before the first reconciliation.

type Settings ¶

type Settings struct {
	Enabled            bool
	RelayEndpoint      string
	ResourceAttributes map[string]string
}

Settings is the remotely selected relay destination and resource metadata. Adapters map control-plane responses into Settings at their boundary.

type VendorSupervisor ¶

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

func NewVendor(options Options) *VendorSupervisor

func (s *VendorSupervisor) Ready() bool

func (s *VendorSupervisor) Run(ctx context.Context)