chore(unified-storage): contextualize the index build logger (#106025)
This commit is contained in:
@@ -540,13 +540,15 @@ func (s *searchSupport) build(ctx context.Context, nsr NamespacedResource, size
|
||||
ctx, span := s.tracer.Start(ctx, tracingPrexfixSearch+"Build")
|
||||
defer span.End()
|
||||
|
||||
logger := s.log.With("namespace", nsr.Namespace, "group", nsr.Group, "resource", nsr.Resource)
|
||||
|
||||
builder, err := s.builders.get(ctx, nsr)
|
||||
if err != nil {
|
||||
return nil, 0, err
|
||||
}
|
||||
fields := s.builders.GetFields(nsr)
|
||||
|
||||
s.log.Debug("Building index", "resource", nsr.Resource, "size", size, "rv", rv)
|
||||
logger.Debug("Building index", "resource", nsr.Resource, "size", size, "rv", rv)
|
||||
|
||||
index, err := s.search.BuildIndex(ctx, nsr, size, rv, fields, func(index ResourceIndex) (int64, error) {
|
||||
rv, err = s.storage.ListIterator(ctx, &resourcepb.ListRequest{
|
||||
@@ -578,7 +580,7 @@ func (s *searchSupport) build(ctx context.Context, nsr NamespacedResource, size
|
||||
// Convert it to an indexable document
|
||||
doc, err := builder.BuildDocument(ctx, key, iter.ResourceVersion(), iter.Value())
|
||||
if err != nil {
|
||||
s.log.Error("error building search document", "key", SearchID(key), "err", err)
|
||||
logger.Error("error building search document", "key", SearchID(key), "err", err)
|
||||
continue
|
||||
}
|
||||
|
||||
@@ -609,7 +611,7 @@ func (s *searchSupport) build(ctx context.Context, nsr NamespacedResource, size
|
||||
// Record the number of objects indexed for the kind/resource
|
||||
docCount, err := index.DocCount(ctx, "")
|
||||
if err != nil {
|
||||
s.log.Warn("error getting doc count", "error", err)
|
||||
logger.Warn("error getting doc count", "error", err)
|
||||
}
|
||||
if s.indexMetrics != nil {
|
||||
s.indexMetrics.IndexedKinds.WithLabelValues(nsr.Resource).Add(float64(docCount))
|
||||
|
||||
Reference in New Issue
Block a user