220
continue
221
}
222
>
serverClusterIDs[int32(clusterInfo.InitialFailoverVersion)] = struct{}{}
stream_receiver_monitor.go
223
}
224
streamKeys := make(map[ClusterShardKeyPair]struct{})
225
for _, shardID := range m.ShardController.ShardIDs() {
226
for serverClusterID := range serverClusterIDs {
228
>
for _, serverShardID := range common.MapShardID(
229
>
clusterIDToShardCount[clientClusterID],
230
>
clusterIDToShardCount[serverClusterID],
231
>
clientShardID,
232
>
) {
233
>
m.Logger.Debug(fmt.Sprintf(
234
>
"outbound cluster shard ID %v/%v -> cluster shard ID %v/%v",
235
>
clientClusterID, clientShardID, serverClusterID, serverShardID,
236
>
))
237
>
streamKeys[ClusterShardKeyPair{
238
>
Client: NewClusterShardKey(clientClusterID, clientShardID),
239
>
Server: NewClusterShardKey(serverClusterID, serverShardID),
240
>
}] = struct{}{}
241
>
}
242
}
243
}