Add a core attribute to tracing span (#159)

fetcher.go

@@ -101,8 +101,11 @@ func (p *pool) fetchResource(ctx context.Context, from string, resource string,
 		fetchRequestContextErrorTotalMetric.WithLabelValues(resourceType, fmt.Sprintf("%t", errors.Is(ce, context.Canceled)), "fetchResource-init").Add(1)
 		return rm, ce
 	}
+	p.lk.RLock()
+	isCore := p.th.IsCore(from)
+	p.lk.RUnlock()
 
-	ctx, span := spanTrace(ctx, "Pool.FetchResource", trace.WithAttributes(attribute.String("from", from), attribute.String("of", resource), attribute.String("mime", mime)))
+	ctx, span := spanTrace(ctx, "Pool.FetchResource", trace.WithAttributes(attribute.String("from", from), attribute.String("of", resource), attribute.String("mime", mime), attribute.Bool("core", isCore)))
 	defer span.End()
 
 	requestId := uuid.NewString()

tieredhashing/tiered_hashing.go

@@ -52,6 +52,7 @@ type NodeInfo struct {
 	Distance      float32 `json:"distance"`
 	Weight        int     `json:"weight"`
 	ComplianceCid string  `json:"complianceCid"`
+	Core          bool    `json:"core"`
 }
 
 type NodePerf struct {
@@ -530,3 +531,11 @@ func (t *TieredHashing) recordCorrectness(perf *NodePerf, success bool) {
 		t.LastAverageCalcAt = time.Now()
 	}
 }
+
+func (t *TieredHashing) IsCore(n string) bool {
+	nd, ok := t.nodes[n]
+	if !ok {
+		return false
+	}
+	return nd.Core
+}