logqlanalyzer

Documentation

Index

• func CorsMiddleware() mux.MiddlewareFunc
• type Label
• type LineResult
• type LogQLAnalyzeHandler
  • func (s *LogQLAnalyzeHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type PipelineAnalyzer
  • func NewPipelineAnalyzer(origin log.Pipeline, streamLabels labels.Labels) PipelineAnalyzer
• type Request
• type Result
• type StageAnalysisRecord
• type StageAnalysisRecorder
  • func (s StageAnalysisRecorder) Process(ts int64, line []byte, lbs *log.LabelsBuilder) ([]byte, bool)
  • func (s StageAnalysisRecorder) RequiredLabelNames() []string
• type StageRecord

Functions

func CorsMiddleware

func CorsMiddleware() mux.MiddlewareFunc

Types

type Label

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

type LineResult

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

type LogQLAnalyzeHandler

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

func (*LogQLAnalyzeHandler) ServeHTTP

func (s *LogQLAnalyzeHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

type PipelineAnalyzer

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

func NewPipelineAnalyzer

func NewPipelineAnalyzer(origin log.Pipeline, streamLabels labels.Labels) PipelineAnalyzer

type Request

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

type Result

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

type StageAnalysisRecord

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

type StageAnalysisRecorder

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

func (StageAnalysisRecorder) Process

func (s StageAnalysisRecorder) Process(ts int64, line []byte, lbs *log.LabelsBuilder) ([]byte, bool)

func (StageAnalysisRecorder) RequiredLabelNames

func (s StageAnalysisRecorder) RequiredLabelNames() []string

type StageRecord

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"`
}