add datadog stats for compaction (#25)

talariadb · Jun 2, 2020 · d233adb · d233adb
1 parent 3888dee
commit d233adb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/internal/server/server_ingest.go b/internal/server/server_ingest.go
@@ -36,5 +36,6 @@ func (s *Server) Ingest(ctx context.Context, request *talaria.IngestRequest) (*t
 		}
 	}
 
+	s.monitor.Count("server", "ingestCount", int64(len(blocks)))
 	return nil, nil
 }
diff --git a/internal/storage/compact/compact.go b/internal/storage/compact/compact.go
@@ -20,6 +20,8 @@ import (
 // Assert contract compliance
 var _ storage.Storage = new(Storage)
 
+const ctxTag = "compaction"
+
 // Storage represents compactor storage.
 type Storage struct {
 	compact async.Task       // The compaction worker
@@ -160,6 +162,7 @@ func (s *Storage) merge(keys []key.Key, blocks []block.Block, schema typeof.Sche
 		if err = s.buffer.Delete(keys...); err != nil {
 			s.monitor.Error(err)
 		}
+		s.monitor.Count(ctxTag, "deleteCount", int64(len(keys)))
 		return
 	})
 }