otel

Documentation

Index

• Constants
• Variables
• func AgentEndpoint(serviceName string) string
• func PromCfgToString(cfgs []yaml.MapSlice) string
• func ProtoDurToString(dur *durationpb.Duration) string
• type AggregatorConfig
  • func (o AggregatorConfig) MetricReceivers() []string
• type AggregatorOTELConfig
• type AggregatorOTELExporters
• type AggregatorOTELProcessors
• type LoggingConfig
• type MetricsConfig
  • func (in *MetricsConfig) DeepCopy() *MetricsConfig
  • func (in *MetricsConfig) DeepCopyInto(out *MetricsConfig)
• type NodeConfig
  • func (d NodeConfig) MetricReceivers() []string
• type NodeOTELConfig
• type NodeOTELExporters
• type NodeOTELProcessors
• type OTELSpec
  • func (in *OTELSpec) DeepCopy() *OTELSpec
  • func (in *OTELSpec) DeepCopyInto(out *OTELSpec)
• type ScrapeConfig
  • func (in *ScrapeConfig) DeepCopy() *ScrapeConfig
  • func (in *ScrapeConfig) DeepCopyInto(out *ScrapeConfig)
• type WALConfig
  • func (in *WALConfig) DeepCopy() *WALConfig
  • func (in *WALConfig) DeepCopyInto(out *WALConfig)

Constants

const (
	CollectorName             = "opni"
	MetricsCrdName            = "opni-monitoring"
	MetricsFeatureFlag        = "otel-metrics"
	MetricsServiceAccountName = "opni-otel-prometheus-agent"
)

Variables

var (
	OTELTemplates *template.Template
)

Functions

func AgentEndpoint

func AgentEndpoint(serviceName string) string

func PromCfgToString

func PromCfgToString(cfgs []yaml.MapSlice) string

func ProtoDurToString

func ProtoDurToString(dur *durationpb.Duration) string

Types

type AggregatorConfig

type AggregatorConfig struct {
	AgentEndpoint string
	LogsEnabled   bool
	Metrics       MetricsConfig
	Containerized bool
	LogLevel      string
	OTELConfig    AggregatorOTELConfig
}

func (AggregatorConfig) MetricReceivers

func (o AggregatorConfig) MetricReceivers() []string

type AggregatorOTELConfig

type AggregatorOTELConfig struct {
	Processors *AggregatorOTELProcessors
	Exporters  *AggregatorOTELExporters
}

type AggregatorOTELExporters

type AggregatorOTELExporters struct {
	OTLPHTTP otlphttpexporter.Config
}

type AggregatorOTELProcessors

type AggregatorOTELProcessors struct {
	Batch         batchprocessor.Config
	MemoryLimiter memorylimiterprocessor.Config
}

type LoggingConfig

type LoggingConfig struct {
	Enabled   bool
	Receivers []string
}

type MetricsConfig

type MetricsConfig struct {
	Enabled             bool
	LogLevel            string
	ListenPort          int
	RemoteWriteEndpoint string
	WALDir              string
	// It becomes easier to marshal []promcfg.ScrapeConfig to yaml strings
	DiscoveredScrapeCfg string
	Spec                *OTELSpec
}

func (*MetricsConfig) DeepCopy

func (in *MetricsConfig) DeepCopy() *MetricsConfig

func (*MetricsConfig) DeepCopyInto

func (in *MetricsConfig) DeepCopyInto(out *MetricsConfig)

type NodeConfig

type NodeConfig struct {
	Instance      string
	Logs          LoggingConfig
	Metrics       MetricsConfig
	Containerized bool
	LogLevel      string
	OTELConfig    NodeOTELConfig
}

func (NodeConfig) MetricReceivers

func (d NodeConfig) MetricReceivers() []string

type NodeOTELConfig

type NodeOTELConfig struct {
	Processors *NodeOTELProcessors
	Exporters  *NodeOTELExporters
}

type NodeOTELExporters

type NodeOTELExporters struct {
	OTLP otlpexporter.Config
}

type NodeOTELProcessors

type NodeOTELProcessors struct {
	MemoryLimiter memorylimiterprocessor.Config
}

type OTELSpec

type OTELSpec struct {
	AdditionalScrapeConfigs []*ScrapeConfig `json:"additionalScrapeConfigs,omitempty"`
	Wal                     *WALConfig      `json:"wal,omitempty"`
	HostMetrics             *bool           `json:"hostMetrics,omitempty"`
}

func (*OTELSpec) DeepCopy

func (in *OTELSpec) DeepCopy() *OTELSpec

func (*OTELSpec) DeepCopyInto

func (in *OTELSpec) DeepCopyInto(out *OTELSpec)

type ScrapeConfig

type ScrapeConfig struct {
	JobName        string   `json:"jobName,omitempty"`
	Targets        []string `json:"targets,omitempty"`
	ScrapeInterval string   `json:"scrapeInterval,omitempty"`
}

func (*ScrapeConfig) DeepCopy

func (in *ScrapeConfig) DeepCopy() *ScrapeConfig

func (*ScrapeConfig) DeepCopyInto

func (in *ScrapeConfig) DeepCopyInto(out *ScrapeConfig)

type WALConfig

type WALConfig struct {
	Enabled           bool                 `json:"enabled,omitempty"`
	BufferSize        int64                `json:"bufferSize,omitempty"`
	TruncateFrequency *durationpb.Duration `json:"truncateFrequency,omitempty"`
}

func (*WALConfig) DeepCopy

func (in *WALConfig) DeepCopy() *WALConfig

func (*WALConfig) DeepCopyInto

func (in *WALConfig) DeepCopyInto(out *WALConfig)