[processor/ratelimit] Fix gubernator peer info address in testing (#894)

* Fix gubernator peer info address

* Use same address as gubernator functional test

* Fix gubernatorRateLimiter.Start respawning existing daemon

Author: ericywl

processor/ratelimitprocessor/gubernator.go

@@ -159,19 +159,27 @@ func (r *gubernatorRateLimiter) Start(ctx context.Context, host component.Host)
 		r.windowConfigurator = wc.(WindowConfigurator)
 	}
 
-	r.daemon, err = gubernator.SpawnDaemon(ctx, r.daemonCfg)
-	if err != nil {
-		return fmt.Errorf("failed to spawn gubernator daemon: %w", err)
+	if r.daemon == nil {
+		r.daemon, err = gubernator.SpawnDaemon(ctx, r.daemonCfg)
+		if err != nil {
+			return fmt.Errorf("failed to spawn gubernator daemon: %w", err)
+		}
 	}
 
-	r.clientConn, err = grpc.NewClient(r.daemonCfg.GRPCListenAddress,
-		grpc.WithTransportCredentials(insecure.NewCredentials()),
-		grpc.WithStatsHandler(otelgrpc.NewClientHandler(otelgrpc.WithTracerProvider(r.tracerProvider))),
-	)
-	if err != nil {
-		return fmt.Errorf("failed to create gRPC client connection: %w", err)
+	if r.clientConn == nil {
+		r.clientConn, err = grpc.NewClient(r.daemonCfg.GRPCListenAddress,
+			grpc.WithTransportCredentials(insecure.NewCredentials()),
+			grpc.WithStatsHandler(otelgrpc.NewClientHandler(otelgrpc.WithTracerProvider(r.tracerProvider))),
+		)
+		if err != nil {
+			return fmt.Errorf("failed to create gRPC client connection: %w", err)
+		}
 	}
-	r.client = gubernator.NewV1Client(r.clientConn)
+
+	if r.client == nil {
+		r.client = gubernator.NewV1Client(r.clientConn)
+	}
+
 	return nil
 }
 

processor/ratelimitprocessor/gubernator_test.go

@@ -131,8 +131,7 @@ func newGubernatorRateLimiterFrom(t *testing.T, cfg *Config, daemon *gubernator.
 
 func startGubernatorCluster(t *testing.T, c chan<- gubernator.HitEvent) *gubernator.Daemon {
 	var err error
-	const local = "127.0.0.1:0"
-	peers := []gubernator.PeerInfo{{GRPCAddress: local, HTTPAddress: local}}
+	peers := []gubernator.PeerInfo{{GRPCAddress: "127.0.0.1:9990", HTTPAddress: "127.0.0.1:9980"}}
 	if c != nil {
 		err = cluster.StartWith(peers, cluster.WithEventChannel(c))
 	} else {