aggregator

Documentation

Index

• Variables
• type Aggregator
  • func NewAggregator(options *AggregatorOptions) (*Aggregator, error)
  • func (a *Aggregator) Run(stopCh <-chan struct{}) error
• type AggregatorOptions

Variables

var (
	OngoingTrace = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Name: "lunettes_ongoing_trace",
			Help: "traces ongoing(not completed yet)",
		},
		[]string{"trace_type"},
	)
)

Types

type Aggregator

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

func NewAggregator

func NewAggregator(options *AggregatorOptions) (*Aggregator, error)

func (*Aggregator) Run

func (a *Aggregator) Run(stopCh <-chan struct{}) error

type AggregatorOptions

type AggregatorOptions struct {
	MetricsAddr                 string
	Workers                     int
	QPS                         float32
	Burst                       int
	TraceTimeout                time.Duration
	KubeConfigFile              string
	Cluster                     string
	JaegerCollector             string
	OTLPCollector               string
	ElasticSearchEndpoint       string
	ElasticSearchUser           string
	ElasticSearchPassword       string
	ElasticSearchIndexName      string
	ElasticSearchBufferDuration time.Duration
	ElasticSearchFetchInterval  time.Duration
	FeatureGates                string
	APIServerEnabled            bool
	APIServerListenAddr         string
	APIServerTraceStatsIndex    string
	EnableTrace                 bool
}