Method getUsage

controlplane/compute_billing_api.go:50–84

getUsage returns usage aggregated since the last ack — one row per key (org, team, query_source, worker size) per UTC day — plus the watermark window. watermark_low is the server cursor (what billing last acked; billing should cross-check it against its own record), watermark_high is what billing ac

(c *gin.Context)

// interval), so it is safe to serve — and later delete on ack.
func (h *billingAPIHandler) latestClosedBucket() time.Time {
	return h.now().UTC().Add(-computeBucketWidth - computeBucketGrace).Truncate(computeBucketWidth)
}

// getUsage returns usage aggregated since the last ack — compute: one row per
// key (org, team, query_source, worker size) per UTC day; storage: one row
// per (org, team) per UTC day — plus the shared watermark window. watermark_low is the server cursor (what billing last acked;
// billing should cross-check it against its own record), watermark_high is
// what billing acks after processing.
func (h *billingAPIHandler) getUsage(c *gin.Context) {
	low, _, err := h.store.ComputeBillingCursor()
	if err != nil {
		c.JSON(http.StatusInternalServerError, gin.H{"error": "read billing cursor: " + err.Error()})
		return
	}
	low = low.UTC() // zero time (never acked) serves everything buffered

	high := h.latestClosedBucket()
	if !high.After(low) {
		// Nothing closed beyond the cursor yet (fresh deploy or a pull racing
		// right behind an ack). An empty window with high == low is a valid
		// response: billing acks it as a no-op.
		c.JSON(http.StatusOK, gin.H{
			"watermark_low":  low.Format(time.RFC3339),
			"watermark_high": low.Format(time.RFC3339),
			"usage":          []configstore.ComputeUsageRow{},
			"storage":        []configstore.StorageUsageRow{},
		})
		return
	}

	rows, err := h.store.AggregateComputeUsage(low, high)
	if err != nil {
		c.JSON(http.StatusInternalServerError, gin.H{"error": "aggregate usage: " + err.Error()})
		return
	}
	if rows == nil {
		rows = []configstore.ComputeUsageRow{}
	}