@@ -58,6 +58,7 @@ type MySQLConfigurationSettings struct {
 	HttpCheckPort        int      // port for HTTP check. -1 to disable.
 	HttpCheckPath        string   // If non-empty, requires HttpCheckPort
 	IgnoreHosts          []string // If non empty, substrings to indicate hosts to be ignored/skipped
+	VitessCell           string   // Name of the Vitess cell for polling tablet hosts
 
 	Clusters map[string](*MySQLClusterConfigurationSettings) // cluster name -> cluster config
 }
@@ -114,6 +115,9 @@ func (settings *MySQLConfigurationSettings) postReadAdjustments() error {
 		if len(clusterSettings.IgnoreHosts) == 0 {
 			clusterSettings.IgnoreHosts = settings.IgnoreHosts
 		}
+		if !clusterSettings.VitessSettings.IsEmpty() && clusterSettings.VitessSettings.Cell == "" {
+			clusterSettings.VitessSettings.Cell = settings.VitessCell
+		}
 	}
 	return nil
 }
@@ -6,6 +6,7 @@ package config
 
 type VitessConfigurationSettings struct {
 	API         string
+	Cell        string
 	Keyspace    string
 	Shard       string
 	TimeoutSecs uint
 
@@ -16,9 +16,10 @@ const defaultTimeout = time.Duration(5) * time.Second
 
 // Tablet represents information about a running instance of vttablet.
 type Tablet struct {
-	MysqlHostname string              `json:"mysql_hostname,omitempty"`
-	MysqlPort     int32               `json:"mysql_port,omitempty"`
-	Type          topodata.TabletType `json:"type,omitempty"`
+	Alias         *topodata.TabletAlias `json:"alias,omitempty"`
+	MysqlHostname string                `json:"mysql_hostname,omitempty"`
+	MysqlPort     int32                 `json:"mysql_port,omitempty"`
+	Type          topodata.TabletType   `json:"type,omitempty"`
 }
 
 // IsValidReplica returns a bool reflecting if a tablet type is REPLICA
@@ -41,8 +42,11 @@ func constructAPIURL(settings config.VitessConfigurationSettings) (url string) {
 }
 
 // filterReplicaTablets parses a list of tablets, returning replica tablets only
-func filterReplicaTablets(tablets []Tablet) (replicas []Tablet) {
+func filterReplicaTablets(settings config.VitessConfigurationSettings, tablets []Tablet) (replicas []Tablet) {
 	for _, tablet := range tablets {
+		if settings.Cell != "" && tablet.Alias.Cell != settings.Cell {
+			continue
+		}
 		if tablet.IsValidReplica() {
 			replicas = append(replicas, tablet)
 		}
@@ -72,5 +76,5 @@ func ParseTablets(settings config.VitessConfigurationSettings) (tablets []Tablet
 	}
 
 	err = json.Unmarshal(body, &tablets)
-	return filterReplicaTablets(tablets), err
+	return filterReplicaTablets(settings, tablets), err
 }
@@ -18,27 +18,37 @@ func TestParseTablets(t *testing.T) {
 		case "/api/keyspace/test/tablets/00":
 			data, _ := json.Marshal([]Tablet{
 				{
+					Alias:         &topodata.TabletAlias{Cell: "ash1"},
 					MysqlHostname: "master",
 					Type:          topodata.TabletType_MASTER,
 				},
 				{
+					Alias:         &topodata.TabletAlias{Cell: "ac4"},
 					MysqlHostname: "replica",
 					Type:          topodata.TabletType_REPLICA,
 				},
 				{
+					Alias:         &topodata.TabletAlias{Cell: "va3"},
+					MysqlHostname: "replica",
+					Type:          topodata.TabletType_REPLICA,
+				},
+				{
+					Alias:         &topodata.TabletAlias{Cell: "ac4"},
 					MysqlHostname: "spare",
 					Type:          topodata.TabletType_SPARE,
 				},
 				{
+					Alias:         &topodata.TabletAlias{Cell: "va3"},
 					MysqlHostname: "batch",
 					Type:          topodata.TabletType_BATCH,
 				},
 				{
+					Alias:         &topodata.TabletAlias{Cell: "ac4"},
 					MysqlHostname: "backup",
 					Type:          topodata.TabletType_BACKUP,
 				},
 				{
-
+					Alias:         &topodata.TabletAlias{Cell: "ash1"},
 					MysqlHostname: "restore",
 					Type:          topodata.TabletType_RESTORE,
 				},
@@ -62,8 +72,8 @@ func TestParseTablets(t *testing.T) {
 			t.Fatalf("Expected no error, got %q", err)
 		}
 
-		if len(tablets) != 1 {
-			t.Fatalf("Expected 1 tablet, got %d", len(tablets))
+		if len(tablets) != 2 {
+			t.Fatalf("Expected 2 tablets, got %d", len(tablets))
 		}
 
 		if tablets[0].MysqlHostname != "replica" {
@@ -75,6 +85,26 @@ func TestParseTablets(t *testing.T) {
 		}
 	})
 
+	t.Run("with-cell", func(t *testing.T) {
+		tablets, err := ParseTablets(config.VitessConfigurationSettings{
+			API:      vitessApi.URL,
+			Cell:     "ac4",
+			Keyspace: "test",
+			Shard:    "00",
+		})
+		if err != nil {
+			t.Fatalf("Expected no error, got %q", err)
+		}
+
+		if len(tablets) > 1 {
+			t.Fatalf("Expected 1 tablet, got %d", len(tablets))
+		}
+
+		if tablets[0].Alias.Cell != "ac4" {
+			t.Fatalf("Expected vitess cell %s, got %s", "ac4", tablets[0].Alias.Cell)
+		}
+	})
+
 	t.Run("not-found", func(t *testing.T) {
 		tablets, err := ParseTablets(config.VitessConfigurationSettings{
 			API:      vitessApi.URL,
Original file line number	Diff line number	Diff line change
`@@ -58,6 +58,7 @@ type MySQLConfigurationSettings struct {`
`58`	`58`	`HttpCheckPort int // port for HTTP check. -1 to disable.`
`59`	`59`	`HttpCheckPath string // If non-empty, requires HttpCheckPort`
`60`	`60`	`IgnoreHosts []string // If non empty, substrings to indicate hosts to be ignored/skipped`
	`61`	`+ VitessCell string // Name of the Vitess cell for polling tablet hosts`
`61`	`62`
`62`	`63`	`Clusters map[string](*MySQLClusterConfigurationSettings) // cluster name -> cluster config`
`63`	`64`	`}`
`@@ -114,6 +115,9 @@ func (settings *MySQLConfigurationSettings) postReadAdjustments() error {`
`114`	`115`	`if len(clusterSettings.IgnoreHosts) == 0 {`
`115`	`116`	`clusterSettings.IgnoreHosts = settings.IgnoreHosts`
`116`	`117`	`}`
	`118`	`+ if !clusterSettings.VitessSettings.IsEmpty() && clusterSettings.VitessSettings.Cell == "" {`
	`119`	`+ clusterSettings.VitessSettings.Cell = settings.VitessCell`
	`120`	`+ }`
`117`	`121`	`}`
`118`	`122`	`return nil`
`119`	`123`	`}`
Original file line number	Diff line number	Diff line change
`@@ -16,9 +16,10 @@ const defaultTimeout = time.Duration(5) * time.Second`
`16`	`16`
`17`	`17`	`// Tablet represents information about a running instance of vttablet.`
`18`	`18`	`type Tablet struct {`
`19`		- MysqlHostname string `json:"mysql_hostname,omitempty"`
`20`		- MysqlPort int32 `json:"mysql_port,omitempty"`
`21`		- Type topodata.TabletType `json:"type,omitempty"`
	`19`	+ Alias *topodata.TabletAlias `json:"alias,omitempty"`
	`20`	+ MysqlHostname string `json:"mysql_hostname,omitempty"`
	`21`	+ MysqlPort int32 `json:"mysql_port,omitempty"`
	`22`	+ Type topodata.TabletType `json:"type,omitempty"`
`22`	`23`	`}`
`23`	`24`
`24`	`25`	`// IsValidReplica returns a bool reflecting if a tablet type is REPLICA`
`@@ -41,8 +42,11 @@ func constructAPIURL(settings config.VitessConfigurationSettings) (url string) {`
`41`	`42`	`}`
`42`	`43`
`43`	`44`	`// filterReplicaTablets parses a list of tablets, returning replica tablets only`
`44`		`-func filterReplicaTablets(tablets []Tablet) (replicas []Tablet) {`
	`45`	`+func filterReplicaTablets(settings config.VitessConfigurationSettings, tablets []Tablet) (replicas []Tablet) {`
`45`	`46`	`for _, tablet := range tablets {`
	`47`	`+ if settings.Cell != "" && tablet.Alias.Cell != settings.Cell {`
	`48`	`+ continue`
	`49`	`+ }`
`46`	`50`	`if tablet.IsValidReplica() {`
`47`	`51`	`replicas = append(replicas, tablet)`
`48`	`52`	`}`
`@@ -72,5 +76,5 @@ func ParseTablets(settings config.VitessConfigurationSettings) (tablets []Tablet`
`72`	`76`	`}`
`73`	`77`
`74`	`78`	`err = json.Unmarshal(body, &tablets)`
`75`		`- return filterReplicaTablets(tablets), err`
	`79`	`+ return filterReplicaTablets(settings, tablets), err`
`76`	`80`	`}`