src/main/kotlin/org/opensearch/replication/action/replay/TransportReplayChangesAction.kt (2 lines): - line 134: val response = ReplayChangesResponse() // TODO: Figure out what to add to response - line 190: //TODO: call .masterNodeTimeout() with the setting indices.mapping.dynamic_timeout src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt (2 lines): - line 179: // TODO: Update any state as required - line 223: * TODO: Implement this after analysing all the use-cases src/main/kotlin/org/opensearch/replication/action/changes/TransportGetChangesAction.kt (2 lines): - line 73: // TODO: Figure out if we need to acquire a primary permit here - line 90: // TODO: Figure out a better way to wait for the global checkpoint to be synced to the translog src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepositoriesService.kt (2 lines): - line 27: // TODO: Proxy support from ES 7.7. Needs additional handling based on those settings - line 36: //TODO: Check to see if register should happen based on every seed node update src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRestoreLeaderService.kt (1 line): - line 43: // TODO: Listen for the index events and release relevant resources. src/main/kotlin/org/opensearch/replication/util/Extensions.kt (1 line): - line 118: // TODO Remove this check for IndexNotFoundException: https://github.com/opensearch-project/cross-cluster-replication/issues/78 src/main/kotlin/org/opensearch/replication/action/status/ReplicationStatusResponse.kt (1 line): - line 102: // TODO: Modify this to have predictable fields