tmp

docker/router/Dockerfile

@@ -3,4 +3,4 @@ FROM spqr-base-image
 RUN apt-get update && apt-get install -y postgresql-client
 COPY ./docker/router/ssl/localhost.crt /etc/spqr/ssl/server.crt
 COPY ./docker/router/ssl/localhost.key /etc/spqr/ssl/server.key
-ENTRYPOINT CONFIG_PATH=${ROUTER_CONFIG=/spqr/docker/router/cfg.yaml} COORD_CONFIG_PATH=${COORDINATOR_CONFIG=/spqr/docker/coordinator/cfg.yaml} && CUR_HOST=$(cat ${CONFIG_PATH} | grep "host:") && sed -i "s/${CUR_HOST}/${ROUTER_HOST=${CUR_HOST}}/g" ${CONFIG_PATH} && /spqr/spqr-router run --config ${CONFIG_PATH} --coordinator-config ${COORD_CONFIG_PATH} --proto-debug
+ENTRYPOINT CONFIG_PATH=${ROUTER_CONFIG=/spqr/docker/router/cfg.yaml} COORD_CONFIG_PATH=${COORDINATOR_CONFIG=/spqr/docker/coordinator/cfg.yaml} && CUR_HOST=$(cat ${CONFIG_PATH} | grep "host:") && sed -i "s/${CUR_HOST}/${ROUTER_HOST=${CUR_HOST}}/g" ${CONFIG_PATH} && /spqr/spqr-router run --config ${CONFIG_PATH} --coordinator-config ${COORD_CONFIG_PATH}

router/instance/etcd.go

@@ -2,6 +2,7 @@ package instance
 
 import (
 	"context"
+	"time"
 
 	"github.com/pg-sharding/spqr/pkg/models/distributions"
 	"github.com/pg-sharding/spqr/pkg/models/kr"
@@ -47,11 +48,25 @@ func (e *EtcdMetadataBootstraper) InitializeMetadata(ctx context.Context, r Rout
 		}
 	}
 
-	c, err := etcdConn.GetCoordinator(ctx)
-	if err != nil {
-		return err
-	}
-	if err := r.Console().Mgr().UpdateCoordinator(ctx, c); err != nil {
+	retryCnt := 50
+
+	for {
+		c, err := etcdConn.GetCoordinator(ctx)
+		if err != nil {
+			if retryCnt > 0 {
+				/* await the roiter to appear */
+				time.Sleep(time.Second)
+				retryCnt--
+				continue
+			}
+			return err
+		}
+
+		err = r.Console().Mgr().UpdateCoordinator(ctx, c)
+
+		if err == nil {
+			break
+		}
 		return err
 	}
 

test/feature/conf/router_cluster.yaml

@@ -4,6 +4,7 @@ admin_console_port: '7432'
 grpc_api_port: '7000'
 router_mode: PROXY
 log_level: debug
+log_filename: router.log
 time_quantiles:
   - 0.75
 world_shard_fallback: true