Add top-level spans

Author: AlCutter

internal/scti/handlers.go

@@ -345,14 +345,23 @@ func addChainInternal(ctx context.Context, opts *HandlerOptions, log *log, w htt
 }
 
 func addChain(ctx context.Context, opts *HandlerOptions, log *log, w http.ResponseWriter, r *http.Request) (int, error) {
+	ctx, span := tracer.Start(ctx, "tesseract.addChain")
+	defer span.End()
+
 	return addChainInternal(ctx, opts, log, w, r, false)
 }
 
 func addPreChain(ctx context.Context, opts *HandlerOptions, log *log, w http.ResponseWriter, r *http.Request) (int, error) {
+	ctx, span := tracer.Start(ctx, "tesseract.addPreChain")
+	defer span.End()
+
 	return addChainInternal(ctx, opts, log, w, r, true)
 }
 
-func getRoots(_ context.Context, opts *HandlerOptions, log *log, w http.ResponseWriter, _ *http.Request) (int, error) {
+func getRoots(ctx context.Context, opts *HandlerOptions, log *log, w http.ResponseWriter, _ *http.Request) (int, error) {
+	_, span := tracer.Start(ctx, "tesseract.getRoots")
+	defer span.End()
+
 	// Pull out the raw certificates from the parsed versions
 	rawCerts := make([][]byte, 0, len(log.chainValidationOpts.trustedRoots.RawCertificates()))
 	for _, cert := range log.chainValidationOpts.trustedRoots.RawCertificates() {

storage/otel.go

@@ -0,0 +1,25 @@
+// Copyright 2025 The Tessera authors. All Rights Reserved.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package storage
+
+import (
+	"go.opentelemetry.io/otel"
+)
+
+const name = "github.com/transparency-dev/static-ct/storage"
+
+var (
+	tracer = otel.Tracer(name)
+)

storage/storage.go

@@ -68,6 +68,9 @@ func NewCTStorage(logStorage *tessera.Appender, issuerStorage IssuerStorage, ded
 
 // Add stores CT entries.
 func (cts *CTStorage) Add(ctx context.Context, entry *ctonly.Entry) tessera.IndexFuture {
+	ctx, span := tracer.Start(ctx, "tesseract.storage.Add")
+	defer span.End()
+
 	// TODO(phboneff): add deduplication and chain storage
 	return cts.storeData(ctx, entry)
 }
@@ -76,6 +79,9 @@ func (cts *CTStorage) Add(ctx context.Context, entry *ctonly.Entry) tessera.Inde
 //
 // If an object is already stored under this hash, continues.
 func (cts *CTStorage) AddIssuerChain(ctx context.Context, chain []*x509.Certificate) error {
+	ctx, span := tracer.Start(ctx, "tesseract.storage.AddIssuerChain")
+	defer span.End()
+
 	kvs := []KV{}
 	for _, c := range chain {
 		id := sha256.Sum256(c.Raw)
@@ -125,6 +131,9 @@ func cachedStoreIssuers(s IssuerStorage) func(context.Context, []KV) error {
 
 // AddCertDedupInfo stores <cert_hash, SCTDedupInfo> in the deduplication storage.
 func (cts CTStorage) AddCertDedupInfo(ctx context.Context, c *x509.Certificate, sctDedupInfo dedup.SCTDedupInfo) error {
+	ctx, span := tracer.Start(ctx, "tesseract.storage.AddCertDedupInfo")
+	defer span.End()
+
 	key := sha256.Sum256(c.Raw)
 	if err := cts.dedupStorage.Add(ctx, []dedup.LeafDedupInfo{{LeafID: key[:], SCTDedupInfo: sctDedupInfo}}); err != nil {
 		return fmt.Errorf("error storing SCTDedupInfo %+v of \"%x\": %v", sctDedupInfo, key, err)
@@ -134,6 +143,9 @@ func (cts CTStorage) AddCertDedupInfo(ctx context.Context, c *x509.Certificate,
 
 // GetCertDedupInfo fetches the SCTDedupInfo of a given certificate from the deduplication storage.
 func (cts CTStorage) GetCertDedupInfo(ctx context.Context, c *x509.Certificate) (dedup.SCTDedupInfo, bool, error) {
+	ctx, span := tracer.Start(ctx, "tesseract.storageGetCertDedupInfo")
+	defer span.End()
+
 	key := sha256.Sum256(c.Raw)
 	sctC, ok, err := cts.dedupStorage.Get(ctx, key[:])
 	if err != nil {