check if cfg is specified

pg-sharding · Sep 20, 2024 · 9cb16b5 · 9cb16b5
1 parent fd4e78e
commit 9cb16b5
Showing 1 changed file with 11 additions and 7 deletions.
diff --git a/coordinator/provider/coordinator.go b/coordinator/provider/coordinator.go
@@ -277,15 +277,19 @@ func (qc *qdbCoordinator) watchRouters(ctx context.Context) {
 }
 
 func NewCoordinator(tlsconfig *tls.Config, db qdb.XQDB) (*qdbCoordinator, error) {
-	shards, err := config.LoadShardDataCfg(config.CoordinatorConfig().ShardDataCfg)
-	if err != nil {
-		return nil, err
-	}
-
-	for id, cfg := range shards.ShardsData {
-		if err := db.AddShard(context.TODO(), qdb.NewShard(id, cfg.Hosts)); err != nil {
+	if config.CoordinatorConfig().ShardDataCfg != "" {
+		shards, err := config.LoadShardDataCfg(config.CoordinatorConfig().ShardDataCfg)
+		if err != nil {
 			return nil, err
 		}
+
+		if shards != nil {
+			for id, cfg := range shards.ShardsData {
+				if err := db.AddShard(context.TODO(), qdb.NewShard(id, cfg.Hosts)); err != nil {
+					return nil, err
+				}
+			}
+		}
 	}
 
 	return &qdbCoordinator{