driftlockcbad

type Config struct {
	// Embed the component.Config interface to satisfy the component configuration contract
	component.Config `mapstructure:",squash"`

	WindowSize  int     `mapstructure:"window_size"`
	HopSize     int     `mapstructure:"hop_size"`
	Threshold   float64 `mapstructure:"threshold"`
	Determinism bool    `mapstructure:"determinism"`

	// Kafka configuration for publishing OTLP events
	Kafka KafkaConfig `mapstructure:"kafka"`

	// Redis configuration for distributed state management
	Redis RedisConfig `mapstructure:"redis"`
}

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

type DetectorConfig struct {
	BaselineSize                   int
	WindowSize                     int
	HopSize                        int
	MaxCapacity                    int
	PValueThreshold                float64
	NCDThreshold                   float64
	PermutationCount               int
	Seed                           uint64
	CompressionRatioDropThreshold  float64
	EntropyChangeThreshold         float64
	CompositeThreshold             float64
	RequireStatisticalSignificance bool
	CompressionAlgorithm           string
}

type EnhancedMetrics struct {
	NCD                        float64
	PValue                     float64
	BaselineCompressionRatio   float64
	WindowCompressionRatio     float64
	BaselineEntropy            float64
	WindowEntropy              float64
	IsAnomaly                  bool
	ConfidenceLevel            float64
	IsStatisticallySignificant bool
	CompressionRatioChange     float64
	EntropyChange              float64
	Explanation                string
	RecommendedNCDThreshold    float64
	RecommendedWindowSize      int
	DataStabilityScore         float64
}

type KafkaConfig struct {
	Enabled        bool     `mapstructure:"enabled"`
	Brokers        []string `mapstructure:"brokers"`
	ClientID       string   `mapstructure:"client_id"`
	EventsTopic    string   `mapstructure:"events_topic"`
	TLSEnabled     bool     `mapstructure:"tls_enabled"`
	BatchSize      int      `mapstructure:"batch_size"`
	BatchTimeoutMs int      `mapstructure:"batch_timeout_ms"`
}

type Metrics struct {
	NCD                      float64
	PValue                   float64
	BaselineCompressionRatio float64
	WindowCompressionRatio   float64
	BaselineEntropy          float64
	WindowEntropy            float64
	IsAnomaly                bool
	ConfidenceLevel          float64
}

type NumericFieldExtractor struct {
	// IncludePatterns: if non-empty, only fields matching these patterns are tracked
	IncludePatterns []string
	// ExcludePatterns: fields matching these patterns are ignored
	ExcludePatterns []string
}

type NumericStats struct {
	N    int64   // Count of values seen
	Mean float64 // Running mean
	M2   float64 // Sum of squared differences from mean (for variance)
	Min  float64 // Minimum value seen
	Max  float64 // Maximum value seen
	// contains filtered or unexported fields
}

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

type NumericStatsSnapshot struct {
	N      int64   `json:"n"`
	Mean   float64 `json:"mean"`
	StdDev float64 `json:"std_dev"`
	Min    float64 `json:"min"`
	Max    float64 `json:"max"`
}

type RedisConfig struct {
	Enabled  bool   `mapstructure:"enabled"`
	Addr     string `mapstructure:"addr"`
	Password string `mapstructure:"password"`
	DB       int    `mapstructure:"db"`
	Prefix   string `mapstructure:"prefix"`
}

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

type TokenizerConfig struct {
	EnableUUID   bool `json:"enable_uuid"`   // Replace UUIDs with <UUID>
	EnableHash   bool `json:"enable_hash"`   // Replace hex hashes with <HASH>
	EnableBase64 bool `json:"enable_base64"` // Replace Base64 with <B64>
	EnableJWT    bool `json:"enable_jwt"`    // Replace JWTs with <JWT>
}

type TokenizerStats struct {
	JWTCount    int64
	UUIDCount   int64
	HashCount   int64
	Base64Count int64
	BytesSaved  int64
}

type ValueOutlier struct {
	FieldPath    string  `json:"field_path"`
	Value        float64 `json:"value"`
	ExpectedMean float64 `json:"expected_mean"`
	StdDev       float64 `json:"std_dev"`
	ZScore       float64 `json:"z_score"`
	SampleCount  int64   `json:"sample_count"`
}