lokicompliance

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

type Config struct {
	ReferenceTargetConfig TargetConfig       `yaml:"reference_target_config"`
	TestTargetConfig      TargetConfig       `yaml:"test_target_config"`
	TestCases             []*TestCasePattern `yaml:"test_cases"`
	QueryParameters       QueryParameters    `yaml:"query_parameters"`
}

type GenerateOptions struct {
	Start, End time.Time
	Step       time.Duration
	Lines      int
	Streams    []string
	Client     ht.Client
}

type LogEntry struct {
	Timestamp time.Time
	Level     plog.SeverityNumber

	// HTTP attributes.
	Protocol   string
	Method     string
	ClientIP   netip.Addr
	RemoteIP   netip.Addr
	RemotePort uint16
	Status     int
	Took       time.Duration
	Size       uint64

	SpanID  pcommon.SpanID
	TraceID pcommon.TraceID
}

type LokiAPI interface {
	Query(ctx context.Context, params lokiapi.QueryParams) (*lokiapi.QueryResponse, error)
	QueryRange(ctx context.Context, params lokiapi.QueryRangeParams) (*lokiapi.QueryResponse, error)
}

type QueryParameters struct {
	EndTime        string            `yaml:"end_time"`
	RangeInSeconds float64           `yaml:"range_in_seconds"`
	StepInSeconds  float64           `yaml:"step_in_seconds"`
	Direction      lokiapi.Direction `yaml:"direction"`
	Limit          *int              `yaml:"limit"`
}

type Result struct {
	TestCase          *TestCase       `json:"testCase"`
	Diff              string          `json:"diff"`
	Expected          json.RawMessage `json:"expected"`
	Got               json.RawMessage `json:"got"`
	UnexpectedFailure string          `json:"unexpectedFailure"`
	UnexpectedSuccess bool            `json:"unexpectedSuccess"`
	Unsupported       bool            `json:"unsupported"`
}

type TargetConfig struct {
	// ReadyQuery is a log query to check instance readiness.
	ReadyQuery string `yaml:"ready_query"`
	QueryURL   string `yaml:"query_url"`
	PushURL    string `yaml:"push_url,omitempty"`
}

type TestCase struct {
	Query          string            `json:"query"`
	SkipComparison bool              `json:"skipComparison"`
	ShouldFail     bool              `json:"shouldFail"`
	ShouldBeEmpty  bool              `json:"shouldBeEmpty"`
	Start          time.Time         `json:"start"`
	End            time.Time         `json:"end"`
	Step           time.Duration     `json:"step"`
	Limit          int               `json:"limit"`
	Direction      lokiapi.Direction `json:"direction"`
}

type TestCasePattern struct {
	Query          string `yaml:"query"`
	SkipComparison bool   `yaml:"skip_comparison,omitempty"`
	ShouldFail     bool   `yaml:"should_fail,omitempty"`
	ShouldBeEmpty  bool   `yaml:"should_be_empty,omitempty"`
}