logqlanalyzer

type Label struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type LineResult struct {
	OriginLine   string        `json:"origin_line"`
	StageRecords []StageRecord `json:"stage_records"`
}

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

type PipelineAnalyzer interface {
	AnalyzeLine(line string) []StageAnalysisRecord
}

type Request struct {
	Query string   `json:"query"`
	Logs  []string `json:"logs"`
}

type Result struct {
	StreamSelector string       `json:"stream_selector"`
	Stages         []string     `json:"stages"`
	Results        []LineResult `json:"results"`
}

type StageAnalysisRecord struct {
	Processed    bool
	LineBefore   string
	LabelsBefore labels.Labels
	LineAfter    string
	LabelsAfter  labels.Labels
	FilteredOut  bool
}

type StageAnalysisRecorder struct {
	log.Stage
	// contains filtered or unexported fields
}

type StageRecord struct {
	LineBefore   string  `json:"line_before"`
	LabelsBefore []Label `json:"labels_before"`
	LineAfter    string  `json:"line_after"`
	LabelsAfter  []Label `json:"labels_after"`
	FilteredOut  bool    `json:"filtered_out"`
}