drain

type Chunk struct {
	Samples []logproto.PatternSample
}

type Chunks []Chunk

type Config struct {
	LogClusterDepth      int
	SimTh                float64
	MaxChildren          int
	ExtraDelimiters      []string
	MaxClusters          int
	ParamString          string
	MaxEvictionRatio     float64
	MaxAllowedLineLength int
	MaxChunkAge          time.Duration
	SampleInterval       time.Duration
	// contains filtered or unexported fields
}

type DedupingTokenizer struct {
	LineTokenizer
	// contains filtered or unexported fields
}

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

type Limits interface {
	PatternIngesterTokenizableJSONFields(userID string) []string
}

type LineTokenizer interface {
	Tokenize(line string, tokens []string, state interface{}, linesDropped *prometheus.CounterVec) ([]string, interface{})
	Join(tokens []string, state interface{}) string
	Clone(tokens []string, state interface{}) ([]string, interface{})
}

type LogCluster struct {
	Size        int
	Tokens      []string
	TokenState  interface{}
	Stringer    func([]string, interface{}) string
	Volume      int64
	SampleCount int64

	Chunks Chunks
	// contains filtered or unexported fields
}

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

type Metrics struct {
	PatternsEvictedTotal  prometheus.Counter
	PatternsPrunedTotal   prometheus.Counter
	PatternsDetectedTotal prometheus.Counter
	LinesSkipped          *prometheus.CounterVec
	TokensPerLine         prometheus.Observer
	StatePerLine          prometheus.Observer
}

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