Documentation
¶
Index ¶
- type Config
- type Instance
- func (i *Instance) ApplyConfig(cfg InstanceConfig) error
- func (i *Instance) GetExporters() map[configmodels.DataType]map[configmodels.Exporter]component.Exporter
- func (i *Instance) GetExtensions() map[configmodels.Extension]component.ServiceExtension
- func (i *Instance) GetFactory(kind component.Kind, componentType configmodels.Type) component.Factory
- func (i *Instance) ReportFatalError(err error)
- func (i *Instance) Stop()
- type InstanceConfig
- type PushConfig
- type Tempo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Whether the Tempo subsystem should be enabled.
Enabled bool `yaml:"-"`
Configs []InstanceConfig `yaml:"configs"`
}
Config controls the configuration of Tempo trace pipelines.
func (*Config) UnmarshalYAML ¶
func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error
UnmarshalYAML implements yaml.Unmarshaler.
type Instance ¶ added in v0.12.0
type Instance struct {
// contains filtered or unexported fields
}
Instance wraps the OpenTelemetry collector to enable tracing pipelines
func NewInstance ¶ added in v0.12.0
func NewInstance(reg prometheus.Registerer, cfg InstanceConfig, logger *zap.Logger) (*Instance, error)
New creates and starts Loki log collection.
func (*Instance) ApplyConfig ¶ added in v0.13.0
func (i *Instance) ApplyConfig(cfg InstanceConfig) error
func (*Instance) GetExporters ¶ added in v0.12.0
func (i *Instance) GetExporters() map[configmodels.DataType]map[configmodels.Exporter]component.Exporter
GetExporters implements component.Host
func (*Instance) GetExtensions ¶ added in v0.12.0
func (i *Instance) GetExtensions() map[configmodels.Extension]component.ServiceExtension
GetExtensions implements component.Host
func (*Instance) GetFactory ¶ added in v0.12.0
func (i *Instance) GetFactory(kind component.Kind, componentType configmodels.Type) component.Factory
GetFactory implements component.Host
func (*Instance) ReportFatalError ¶ added in v0.12.0
func (i *Instance) ReportFatalError(err error)
ReportFatalError implements component.Host
type InstanceConfig ¶ added in v0.12.0
type InstanceConfig struct {
Name string `yaml:"name"`
PushConfig PushConfig `yaml:"push_config"`
// Receivers: https://github.com/open-telemetry/opentelemetry-collector/blob/1962d7cd2b371129394b0242b120835e44840192/receiver/README.md
Receivers map[string]interface{} `yaml:"receivers"`
// Attributes: https://github.com/open-telemetry/opentelemetry-collector/blob/1962d7cd2b371129394b0242b120835e44840192/processor/attributesprocessor/config.go#L30
Attributes map[string]interface{} `yaml:"attributes"`
// prom service discovery
ScrapeConfigs []interface{} `yaml:"scrape_configs"`
}
InstanceConfig configures an individual Tempo trace pipeline.
type PushConfig ¶ added in v0.7.2
type PushConfig struct {
Endpoint string `yaml:"endpoint"`
Insecure bool `yaml:"insecure"`
InsecureSkipVerify bool `yaml:"insecure_skip_verify"`
BasicAuth *prom_config.BasicAuth `yaml:"basic_auth,omitempty"`
Batch map[string]interface{} `yaml:"batch,omitempty"` // https://github.com/open-telemetry/opentelemetry-collector/blob/1962d7cd2b371129394b0242b120835e44840192/processor/batchprocessor/config.go#L24
SendingQueue map[string]interface{} `yaml:"sending_queue,omitempty"` // https://github.com/open-telemetry/opentelemetry-collector/blob/1962d7cd2b371129394b0242b120835e44840192/exporter/exporterhelper/queued_retry.go#L30
RetryOnFailure map[string]interface{} `yaml:"retry_on_failure,omitempty"` // https://github.com/open-telemetry/opentelemetry-collector/blob/1962d7cd2b371129394b0242b120835e44840192/exporter/exporterhelper/queued_retry.go#L54
}
PushConfig controls the configuration of exporting to Grafana Cloud
type Tempo ¶
type Tempo struct {
// contains filtered or unexported fields
}
Tempo wraps the OpenTelemetry collector to enable tracing pipelines
func New ¶
func New(reg prom_client.Registerer, cfg Config, level logging.Level) (*Tempo, error)
New creates and starts Loki log collection.
func (*Tempo) ApplyConfig ¶ added in v0.13.0
func (t *Tempo) ApplyConfig(cfg Config) error
ApplyConfig updates Tempo with a new Config.