Fix ShardCreator to use refactored Spectators type

Author: jakobht

service/sharddistributor/canary/processorephemeral/shardcreator.go

@@ -26,7 +26,7 @@ const (
 type ShardCreator struct {
 	logger       *zap.Logger
 	timeSource   clock.TimeSource
-	spectators   map[string]spectatorclient.Spectator // namespace -> spectator
+	spectators   *spectatorclient.Spectators
 	canaryClient sharddistributorv1.ShardDistributorExecutorCanaryAPIYARPCClient
 	namespaces   []string
 
@@ -40,7 +40,7 @@ type ShardCreatorParams struct {
 
 	Logger       *zap.Logger
 	TimeSource   clock.TimeSource
-	Spectators   map[string]spectatorclient.Spectator
+	Spectators   *spectatorclient.Spectators
 	CanaryClient sharddistributorv1.ShardDistributorExecutorCanaryAPIYARPCClient
 }
 
@@ -101,11 +101,12 @@ func (s *ShardCreator) process(ctx context.Context) {
 				s.logger.Info("Creating shard", zap.String("shardKey", shardKey), zap.String("namespace", namespace))
 
 				// Get spectator for this namespace
-				spectator, ok := s.spectators[namespace]
-				if !ok {
+				spectator, err := s.spectators.ForNamespace(namespace)
+				if err != nil {
 					s.logger.Warn("No spectator for namespace, skipping shard creation",
 						zap.String("namespace", namespace),
-						zap.String("shardKey", shardKey))
+						zap.String("shardKey", shardKey),
+						zap.Error(err))
 					continue
 				}