chqenforcerprocessor

Documentation

Index

• func NewFactory() processor.Factory
• type Config
  • func (c *Config) Validate() error
• type ContextID
• type LogsConfig
  • func (cfg *LogsConfig) Validate() error
• type MetricAggregationConfig
  • func (c *MetricAggregationConfig) Validate() error
• type MetricStat
  • func (m *MetricStat) Increment(tag string, count int, _ int64) error
  • func (m *MetricStat) Initialize() error
  • func (m *MetricStat) Key() uint64
  • func (m *MetricStat) Matches(other stats.StatsObject) bool
• type StatisticsConfig
  • func (c *StatisticsConfig) Validate() error
• type StatsEnrichment
• type TracesConfig

Functions

func NewFactory

func NewFactory() processor.Factory

NewFactory creates a factory for S3 exporter.

Types

type Config

type Config struct {
	Statistics               StatisticsConfig        `mapstructure:"statistics"`
	MetricAggregation        MetricAggregationConfig `mapstructure:"metric_aggregation"`
	LogsConfig               LogsConfig              `mapstructure:"logs"`
	TracesConfig             TracesConfig            `mapstructure:"traces"`
	ConfigurationExtension   *component.ID           `mapstructure:"configuration_extension"`
	DropDecorationAttributes bool                    `mapstructure:"drop_decoration_attributes"`
}

func (*Config) Validate

func (c *Config) Validate() error

type ContextID

type ContextID string

type LogsConfig

type LogsConfig struct {
	StatsEnrichments []StatsEnrichment `mapstructure:"stats_enrichment"`
}

func (*LogsConfig) Validate

func (cfg *LogsConfig) Validate() error

Validate function for LogsConfig

type MetricAggregationConfig

type MetricAggregationConfig struct {
	Interval time.Duration `mapstructure:"interval"`
}

func (*MetricAggregationConfig) Validate

func (c *MetricAggregationConfig) Validate() error

type MetricStat

type MetricStat struct {
	MetricName  string
	TagName     string
	ServiceName string
	Phase       chqpb.Phase
	VendorID    string
	Count       int64
	HLL         hll.HllSketch
}

func (*MetricStat) Increment

func (m *MetricStat) Increment(tag string, count int, _ int64) error

func (*MetricStat) Initialize

func (m *MetricStat) Initialize() error

func (*MetricStat) Key

func (m *MetricStat) Key() uint64

func (*MetricStat) Matches

func (m *MetricStat) Matches(other stats.StatsObject) bool

type StatisticsConfig

type StatisticsConfig struct {
	confighttp.ClientConfig `mapstructure:",squash"`
	Interval                time.Duration `mapstructure:"interval"`
	Phase                   string        `mapstructure:"phase"`
	Vendor                  string        `mapstructure:"vendor"`
}

func (*StatisticsConfig) Validate

func (c *StatisticsConfig) Validate() error

type StatsEnrichment

type StatsEnrichment struct {
	Context ContextID `mapstructure:"context"`
	Tags    []string  `mapstructure:"tags"`
}

type TracesConfig

type TracesConfig struct {
	StatsEnrichments []StatsEnrichment `mapstructure:"stats_enrichment"`
}