analysis

type BreakdownDef struct {
	Name  string `yaml:"name"`
	Query string `yaml:"query"`
}

type BreakdownDiff struct {
	Name string
	// Keyed は key / value 列があって行ごとに突き合わせられたか。false なら行数だけ比べる。
	Keyed      bool
	RowsBefore *int `json:",omitempty"`
	RowsAfter  *int `json:",omitempty"`
	// Top1 / Top3 は上位1件・3件の構成比（偏りの変化を見る）。
	Top1Before float64
	Top1After  float64
	Top3Before float64
	Top3After  float64
	// NewInTop は after で上位に入り、before の上位に無かった key。
	NewInTop []string `json:",omitempty"`
	Rows     []KeyDiff
}

type BreakdownResult struct {
	Name    string
	Columns []string
	Rows    [][]string
	// Share は value 列があるときの構成比（Rows と同じ並び）。
	Share     []float64 `json:",omitempty"`
	TotalRows int
	Error     string `json:",omitempty"`
}

type Bucket struct {
	// Offset は区間の開始（Origin からの秒）。
	Offset   int
	Requests int
	S2xx     int
	S3xx     int
	S4xx     int
	S5xx     int
	// Canceled は 499（クライアントが待ちきれずに切った）。S4xx には入れない。
	Canceled  int
	P50       float64
	P99       float64
	Endpoints map[string]int     `json:",omitempty"`
	Series    map[string]float64 `json:",omitempty"`
}

type Config struct {
	// Bucket は時系列の区間幅（秒）。
	Bucket int `yaml:"bucket"`
	// Top は内訳・エンドポイント表に出す件数。
	Top int `yaml:"top"`

	HTTPLog HTTPLogConfig `yaml:"httplog"`

	Series     []SeriesDef    `yaml:"series"`
	Breakdowns []BreakdownDef `yaml:"breakdowns"`
	Lifecycles []LifecycleDef `yaml:"lifecycles"`
}

type ConfigHash struct {
	// Analysis は集計したときの analysis.yml。
	Analysis string
	// DBQuery は dbquery を実行したときの dbquery.yml（dbquery の結果に記録されている）。
	DBQuery string
}

type Diff struct {
	Before string
	After  string
	Score  *ScoreDiff `json:",omitempty"`
	// Warnings は比較の前提が崩れているもの（設定の食い違い、片方の警告など）。
	Warnings []string `json:",omitempty"`

	Series     []SeriesDiff
	Requests   []MetricDiff
	Endpoints  []EndpointDiff
	Lifecycles []LifecycleDiff
	Breakdowns []BreakdownDiff
}

type EndpointDiff struct {
	Key         string
	CountBefore int
	CountAfter  int
	ShareBefore float64
	ShareAfter  float64
}

type HTTPLogConfig struct {
	// Label は使う httplog の Label。空なら同じ収集の httplog を全部まとめる。
	Label string `yaml:"label"`
	// TimeKey は時刻の LTSV キー。msec（nginx の $msec）か time（$time_local）。
	// 既定は msec で、行に無ければ time を見る。
	TimeKey string `yaml:"time_key"`
	// EntityKey はライフサイクルの識別子に使う LTSV キー（セッション cookie など）。
	EntityKey string `yaml:"entity_key"`
}

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

type Input struct {
	GroupId string
	// Origin は時系列の 0 秒（unix 秒）。GroupId の時刻 = 収集開始 = initialize の直後。
	Origin   float64
	Requests []Request
	// SkippedLines は時刻が読めず捨てた LTSV の行数。
	SkippedLines int
	Queries      map[string]*dbquery.QueryResult
	// Warnings は材料を集める段階で見つかった問題（収集中・収集失敗のエントリなど）。
	Warnings []string

	// Score はこの収集に紐づいたベンチのスコア。無ければ nil。
	Score *ScoreInfo
	// ConfigHash は集計に使った設定のハッシュ。走行間の比較で定義の食い違いを見つけるのに使う。
	ConfigHash ConfigHash
}

type KeyDiff struct {
	Key    string
	Before *float64 `json:",omitempty"`
	After  *float64 `json:",omitempty"`
}

type LifecycleDef struct {
	Name string `yaml:"name"`
	// Source は httplog（識別子 = httplog.entity_key、状態 = "METHOD 正規化済みURI"）か、
	// query:<dbquery の name>（列 entity, state, t）。
	Source string `yaml:"source"`
	Steps  []Step `yaml:"steps"`
}

type LifecycleDiff struct {
	Name           string
	EntitiesBefore *int `json:",omitempty"`
	EntitiesAfter  *int `json:",omitempty"`
	Steps          []StepDiff
}

type LifecycleResult struct {
	Name string
	// Entities は最初の状態に到達したエンティティの数。
	Entities int
	Steps    []StepResult
	Error    string `json:",omitempty"`
}

type MetricDiff struct {
	Name   string
	Before float64
	After  float64
}

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

type Quantiles struct {
	P50 float64
	P90 float64
	P99 float64
	Max float64
}

type Report struct {
	GroupId    string
	Origin     time.Time
	Bucket     int
	Warnings   []string   `json:",omitempty"`
	Score      *ScoreInfo `json:",omitempty"`
	ConfigHash ConfigHash

	// Totals は走行全体のリクエストの集計（収集開始より後のもの）。
	Totals Totals
	// SeriesStats は時系列の系列ごとの集計（累積の系列は除く）。
	SeriesStats []SeriesStat

	Timeline   Timeline
	Lifecycles []LifecycleResult
	Breakdowns []BreakdownResult
}

type Request struct {
	// T は unix 秒（小数あり）。
	T        float64
	Method   string
	Endpoint string // matching_groups でまとめた URI
	Status   int
	ReqTime  float64
	Entity   string
}

type ScoreDiff struct {
	Before *ScoreInfo `json:",omitempty"`
	After  *ScoreInfo `json:",omitempty"`
}

type ScoreInfo struct {
	Value  int64
	Passed bool
}

type SeriesDef struct {
	Name  string `yaml:"name"`
	Query string `yaml:"query"`
	// Agg は区間内の集約方法。sum（既定）/ count / max / last。
	Agg string `yaml:"agg"`
	// Cumulative を true にすると区間ごとの値に加えて累積を出す（得点の積み上がりを見る）。
	Cumulative bool `yaml:"cumulative"`
}

type SeriesDiff struct {
	Name      string
	Before    *float64 `json:",omitempty"`
	After     *float64 `json:",omitempty"`
	T50Before *int     `json:",omitempty"`
	T50After  *int     `json:",omitempty"`
	T90Before *int     `json:",omitempty"`
	T90After  *int     `json:",omitempty"`
}

type SeriesStat struct {
	Name string
	// Agg は区間内の集約方法（sum / count / max / last）。ライフサイクルの開始・完了数は count。
	Agg string
	// Total は走行全体の値。sum / count は合計、max は最大、last は最後の区間の値。
	Total float64
	// T50 / T90 は sum / count の系列が合計の 50% / 90% に達した区間の終わり（収集開始からの秒）。
	// 得点が前倒しで積み上がるようになったか（終盤の失速が直ったか）を見る。
	T50 *int `json:",omitempty"`
	T90 *int `json:",omitempty"`
}

type Step struct {
	Name string `yaml:"name"`
	// Match は状態に当てる正規表現。
	Match string `yaml:"match"`
	// contains filtered or unexported fields
}

type StepDiff struct {
	Name   string
	Before *StepResult `json:",omitempty"`
	After  *StepResult `json:",omitempty"`
}

type StepResult struct {
	Name string
	// Reached はこの状態まで順に到達したエンティティの数。
	Reached int
	// Rate は1つ前の状態に到達したうち、この状態まで進んだ割合。
	Rate float64
	// StoppedHere はこの状態を最後に先へ進まなかったエンティティの数（離脱・途中で走行終了の両方を含む）。
	StoppedHere int
	// PerEntity は到達したエンティティ1つあたり、この状態のイベントが何回あったか（順序を問わない）。
	PerEntity float64
	// FromPrev は1つ前の状態からの所要秒数。
	FromPrev *Quantiles `json:",omitempty"`
}

type Timeline struct {
	// Series は Buckets[].Series に入っている系列名（表示順）。
	Series []string
	// Endpoints は件数の多いエンドポイント（Buckets[].Endpoints のキー）。
	Endpoints []string
	Buckets   []Bucket
}

type Totals struct {
	Requests int
	S2xx     int
	S3xx     int
	S4xx     int
	S5xx     int
	Canceled int
	P50      float64
	P99      float64
	// PeakRequests は区間あたりの最大リクエスト数、PeakOffset はその区間の開始。
	PeakRequests int
	PeakOffset   int
	// Endpoints は全エンドポイントの件数（Timeline.Endpoints と違って上位に絞らない）。
	Endpoints map[string]int `json:",omitempty"`
}