signal when ready

gernest · Jul 13, 2024 · f9e8d61 · f9e8d61
1 parent d0c2a12
commit f9e8d61
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/main.go b/main.go
@@ -50,6 +50,7 @@ func newMetrics(db *metrics.Store) *Metrics {
 
 func (m *Metrics) Start(ctx context.Context) {
 	slog.Info("starting metrics processing loop")
+	start := true
 	for {
 		select {
 		case <-ctx.Done():
@@ -60,10 +61,19 @@ func (m *Metrics) Start(ctx context.Context) {
 			if err != nil {
 				slog.Error("failed saving metrics sample", "err", err)
 			}
+			if start {
+				start = false
+				slog.Info("ready to start querying")
+			}
 		}
 	}
 }
 
+func (m *Metrics) Export(_ context.Context, req pmetricotlp.ExportRequest) (pmetricotlp.ExportResponse, error) {
+	m.buffer <- &req
+	return pmetricotlp.NewExportResponse(), nil
+}
+
 func Main() *cli.Command {
 	return &cli.Command{
 		Name:        "frieren",