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 LoggingConfig
• type MetricsConfig
• type NodeConfig
  • func (d NodeConfig) MetricReceivers() []string
• type OTELSpec
  • func (o *OTELSpec) DeepCopyInto(out *OTELSpec)
• type ScrapeConfig
• type WALConfig

Constants

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

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
}

func (AggregatorConfig) MetricReceivers

func (o AggregatorConfig) MetricReceivers() []string

type LoggingConfig

type LoggingConfig struct {
	Enabled   bool
	Receivers []string
}

type MetricsConfig

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

type NodeConfig

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

func (NodeConfig) MetricReceivers

func (d NodeConfig) MetricReceivers() []string

type OTELSpec

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

func (*OTELSpec) DeepCopyInto

func (o *OTELSpec) DeepCopyInto(out *OTELSpec)

type ScrapeConfig

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

type WALConfig

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