Method Show

pkg/org/usage_handler.go:55–127

(w http.ResponseWriter, req bunrouter.Request)

}

func (h *UsageHandler) Show(w http.ResponseWriter, req bunrouter.Request) error {
	ctx := req.Context()

	interval := 24 * time.Hour
	timeLT := time.Now().Truncate(interval).Add(interval)
	timeGTE := timeLT.AddDate(0, -1, 0)

	usage := new(Usage)
	if err := h.CH.NewSelect().
		ColumnExpr("sum(rows) AS spans").
		ColumnExpr("sum(data_uncompressed_bytes) AS bytes").
		ColumnExpr("parseDateTime(partition, '%Y-%m-%d') AS time").
		TableExpr("system.parts").
		Where("database = ?", h.CH.Config().Database).
		Where("table = ?", "spans_data").
		Where("min_time >= ?", timeGTE).
		Where("active").
		GroupExpr("partition").
		OrderExpr("time ASC").
		ScanColumns(ctx, usage); err != nil {
		return err
	}

	usage.Spans = bunutil.Fill(usage.Spans, usage.Time, 0, timeGTE, timeLT, interval)
	usage.Bytes = bunutil.Fill(usage.Bytes, usage.Time, 0, timeGTE, timeLT, interval)
	usage.Time = bunutil.FillTime(usage.Time, timeGTE, timeLT, interval)

	subq := h.CH.NewSelect().
		ColumnExpr("60 * uniqCombined64(15)(d.attrs_hash) AS datapoints").
		ColumnExpr("d.time").
		ColumnExpr("60 AS minutes").
		TableExpr("datapoint_hours AS d").
		Where("d.time >= ?", timeGTE).
		Where("d.time < ?", timeLT).
		GroupExpr("d.project_id, d.time")

	usage2 := new(Usage2)
	if err := h.CH.NewSelect().
		ColumnExpr("sum(d.datapoints) AS datapoints").
		ColumnExpr("toStartOfDay(d.time) AS time").
		ColumnExpr("sum(d.minutes) AS minutes").
		TableExpr("(?) AS d", subq).
		GroupExpr("toStartOfDay(d.time)").
		OrderExpr("time ASC").
		ScanColumns(ctx, usage2); err != nil {
		return err
	}

	usage.Timeseries = make([]uint64, len(usage2.Datapoints))
	for i, datapoints := range usage2.Datapoints {
		usage.Timeseries[i] = datapoints / usage2.Minutes[i]
	}
	usage.Timeseries = bunutil.Fill(usage.Timeseries, usage2.Time, 0, timeGTE, timeLT, interval)

	spans := sum(usage.Spans)
	bytes := sum(usage.Bytes)
	datapoints := sum(usage2.Datapoints)
	minutes := sum(usage2.Minutes)