preprocessor

type Aggregator interface {
	// Process handles a log line and returns zero or more completed messages.
	// label is the result of labeling this message; aggregators that don't use it may ignore it.
	Process(msg *message.Message, label Label) []*message.Message

	// Flush returns any buffered messages and clears internal state.
	Flush() []*message.Message

	// IsEmpty returns true if the aggregator has no buffered data.
	IsEmpty() bool
}

type DiagnosticRow struct {
	TokenString string
	LabelString string

	Count     int64
	LastIndex int64
	// contains filtered or unexported fields
}

type Heuristic interface {
	// ProcessAndContinue processes a log message and annotates the context with a label. It returns false if the message should be done processing.
	// Heuristic implementations may mutate the message context but must do so synchronously.
	ProcessAndContinue(*messageContext) bool
}

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

type JSONAggregator interface {
	// Process handles one incoming message. It may buffer the message and return
	// nothing (incomplete JSON), return it unchanged (non-JSON or already complete),
	// or return a compacted single-line version (multi-part JSON).
	Process(msg *message.Message) []*message.Message

	// Flush returns any messages still buffered inside the aggregator.
	Flush() []*message.Message

	// IsEmpty reports whether the aggregator has no buffered state.
	IsEmpty() bool
}

type JSONDetector struct{}

type JSONState int

type Label uint32

type Labeler interface {
	Label(content []byte, tokens []Token, tokenIndices []int) Label
}

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

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

type NoopLabeler struct{}

type NoopSampler struct{}

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

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

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

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

type Sampler interface {
	// Process handles a completed log message and returns it, or nil to drop it.
	Process(msg *message.Message) *message.Message

	// Flush flushes any buffered state and returns a pending message, or nil if empty.
	Flush() *message.Message
}

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

type Token byte

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

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

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

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