1879
}
1880
1882
>
clusterInfo[s.clusterMetadata.GetCurrentClusterName()].ShardCount,
1883
>
clusterInfo[clusterName].ShardCount,
1884
>
s.shardID,
1885
>
) {
1886
>
ackTaskID := v.AckedReplicationTaskIDs[remoteShardID] // default to 0
1887
>
ackTimestamp := v.AckedReplicationTimestamps[remoteShardID]
1888
>
if ackTimestamp.IsZero() {
1889
ackTimestamp = time.Unix(0, 0)
1890
}
1892
>
remoteClusters[clusterName] = &historyservice.ShardReplicationStatusPerCluster{
1893
>
AckedTaskId: ackTaskID,
1894
>
AckedTaskVisibilityTime: timestamppb.New(ackTimestamp),
1895
>
}
1896
>
} else if record.AckedTaskId > ackTaskID {
1897
remoteClusters[clusterName] = &historyservice.ShardReplicationStatusPerCluster{
1898
AckedTaskId: ackTaskID,