Something went wrong. Try again.
[READ-ONLY] Mirror of https://github.com/openstatusHQ/openstatus. 馃珫 Status page with uptime monitoring & API monitoring as code 馃珫 openstatus.dev
bun drizzle-orm monitoring monitoring-as-code nextjs observability on-call open-source shadcn-ui status-page statuspage synthetic-monitoring tinybird turso uptime uptime-checker uptime-monitor
Something went wrong. Try again.
281 B 路 12 lines
Go
12345678910111213package tinybird
// PendingRows reports the rows buffered for a data source and not yet detached.func (b *Batcher) PendingRows(dataSource string) int { b.mu.Lock() defer b.mu.Unlock() if pending, ok := b.batches[dataSource]; ok { return len(pending.waiters) }
return 0}