analysis

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

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

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

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

	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 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 Step struct {
	Name string `yaml:"name"`
	// Match は状態に当てる正規表現。
	Match string `yaml:"match"`
	// contains filtered or unexported fields
}

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
}