Path	Lines of Code
replication.http	139
src/main/kotlin/org/opensearch/index/translog/ReplicationTranslogDeletionPolicy.kt	115
src/main/kotlin/org/opensearch/replication/MappingNotAvailableException.kt	6
src/main/kotlin/org/opensearch/replication/ReplicationEngine.kt	24
src/main/kotlin/org/opensearch/replication/ReplicationException.kt	16
src/main/kotlin/org/opensearch/replication/ReplicationPlugin.kt	268
src/main/kotlin/org/opensearch/replication/ReplicationSettings.kt	34
src/main/kotlin/org/opensearch/replication/action/autofollow/AutoFollowMasterNodeAction.kt	9
src/main/kotlin/org/opensearch/replication/action/autofollow/AutoFollowMasterNodeRequest.kt	47
src/main/kotlin/org/opensearch/replication/action/autofollow/TransportAutoFollowMasterNodeAction.kt	103
src/main/kotlin/org/opensearch/replication/action/autofollow/TransportUpdateAutoFollowPatternAction.kt	55
src/main/kotlin/org/opensearch/replication/action/autofollow/UpdateAutoFollowPatternAction.kt	9
src/main/kotlin/org/opensearch/replication/action/autofollow/UpdateAutoFollowPatternRequest.kt	123
src/main/kotlin/org/opensearch/replication/action/changes/GetChangesAction.kt	8
src/main/kotlin/org/opensearch/replication/action/changes/GetChangesRequest.kt	32
src/main/kotlin/org/opensearch/replication/action/changes/GetChangesResponse.kt	18
src/main/kotlin/org/opensearch/replication/action/changes/TransportGetChangesAction.kt	127
src/main/kotlin/org/opensearch/replication/action/index/ReplicateIndexAction.kt	8
src/main/kotlin/org/opensearch/replication/action/index/ReplicateIndexMasterNodeAction.kt	9
src/main/kotlin/org/opensearch/replication/action/index/ReplicateIndexMasterNodeRequest.kt	47
src/main/kotlin/org/opensearch/replication/action/index/ReplicateIndexRequest.kt	138
src/main/kotlin/org/opensearch/replication/action/index/ReplicateIndexResponse.kt	10
src/main/kotlin/org/opensearch/replication/action/index/TransportReplicateIndexAction.kt	101
src/main/kotlin/org/opensearch/replication/action/index/TransportReplicateIndexMasterNodeAction.kt	125
src/main/kotlin/org/opensearch/replication/action/index/block/TransportUpddateIndexBlockAction.kt	67
src/main/kotlin/org/opensearch/replication/action/index/block/UpdateIndexBlockAction.kt	9
src/main/kotlin/org/opensearch/replication/action/index/block/UpdateIndexBlockRequest.kt	49
src/main/kotlin/org/opensearch/replication/action/pause/PauseIndexReplicationAction.kt	9
src/main/kotlin/org/opensearch/replication/action/pause/PauseIndexReplicationRequest.kt	64
src/main/kotlin/org/opensearch/replication/action/pause/TransportPauseIndexReplicationAction.kt	84
src/main/kotlin/org/opensearch/replication/action/replay/ReplayChangesAction.kt	8
src/main/kotlin/org/opensearch/replication/action/replay/ReplayChangesRequest.kt	38
src/main/kotlin/org/opensearch/replication/action/replay/ReplayChangesResponse.kt	10
src/main/kotlin/org/opensearch/replication/action/replay/TransportReplayChangesAction.kt	192
src/main/kotlin/org/opensearch/replication/action/replicationstatedetails/TransportUpdateReplicationStateDetails.kt	53
src/main/kotlin/org/opensearch/replication/action/replicationstatedetails/UpdateReplicationStateAction.kt	9
src/main/kotlin/org/opensearch/replication/action/replicationstatedetails/UpdateReplicationStateDetailsRequest.kt	34
src/main/kotlin/org/opensearch/replication/action/repository/GetFileChunkAction.kt	8
src/main/kotlin/org/opensearch/replication/action/repository/GetFileChunkRequest.kt	33
src/main/kotlin/org/opensearch/replication/action/repository/GetFileChunkResponse.kt	26
src/main/kotlin/org/opensearch/replication/action/repository/GetStoreMetadataAction.kt	8
src/main/kotlin/org/opensearch/replication/action/repository/GetStoreMetadataRequest.kt	14
src/main/kotlin/org/opensearch/replication/action/repository/GetStoreMetadataResponse.kt	17
src/main/kotlin/org/opensearch/replication/action/repository/ReleaseLeaderResourcesAction.kt	9
src/main/kotlin/org/opensearch/replication/action/repository/ReleaseLeaderResourcesRequest.kt	14
src/main/kotlin/org/opensearch/replication/action/repository/RemoteClusterRepositoryRequest.kt	44
src/main/kotlin/org/opensearch/replication/action/repository/TransportGetFileChunkAction.kt	61
src/main/kotlin/org/opensearch/replication/action/repository/TransportGetStoreMetadataAction.kt	44
src/main/kotlin/org/opensearch/replication/action/repository/TransportReleaseLeaderResourcesAction.kt	45
src/main/kotlin/org/opensearch/replication/action/resume/ResumeIndexReplicationAction.kt	9
src/main/kotlin/org/opensearch/replication/action/resume/ResumeIndexReplicationRequest.kt	51
src/main/kotlin/org/opensearch/replication/action/resume/TransportResumeIndexReplicationAction.kt	152
src/main/kotlin/org/opensearch/replication/action/setup/SetupChecksAction.kt	9
src/main/kotlin/org/opensearch/replication/action/setup/SetupChecksRequest.kt	42
src/main/kotlin/org/opensearch/replication/action/setup/TransportSetupChecksAction.kt	146
src/main/kotlin/org/opensearch/replication/action/setup/TransportValidatePermissionsAction.kt	26
src/main/kotlin/org/opensearch/replication/action/setup/ValidatePermissionsAction.kt	9
src/main/kotlin/org/opensearch/replication/action/setup/ValidatePermissionsRequest.kt	50
src/main/kotlin/org/opensearch/replication/action/stats/AutoFollowStatsAction.kt	79
src/main/kotlin/org/opensearch/replication/action/stats/AutoFollowStatsRequest.kt	25
src/main/kotlin/org/opensearch/replication/action/stats/FollowerNodeStatsResponse.kt	23
src/main/kotlin/org/opensearch/replication/action/stats/FollowerStatsAction.kt	11
src/main/kotlin/org/opensearch/replication/action/stats/FollowerStatsRequest.kt	13
src/main/kotlin/org/opensearch/replication/action/stats/FollowerStatsResponse.kt	93
src/main/kotlin/org/opensearch/replication/action/stats/LeaderNodeStatsResponse.kt	23
src/main/kotlin/org/opensearch/replication/action/stats/LeaderStatsAction.kt	11
src/main/kotlin/org/opensearch/replication/action/stats/LeaderStatsRequest.kt	13
src/main/kotlin/org/opensearch/replication/action/stats/LeaderStatsResponse.kt	59
src/main/kotlin/org/opensearch/replication/action/stats/NodeStatsRequest.kt	13
src/main/kotlin/org/opensearch/replication/action/stats/TransportAutoFollowStatsAction.kt	31
src/main/kotlin/org/opensearch/replication/action/stats/TransportFollowerStatsAction.kt	43
src/main/kotlin/org/opensearch/replication/action/stats/TransportLeaderStatsAction.kt	65
src/main/kotlin/org/opensearch/replication/action/status/ReplicationStatusAction.kt	11
src/main/kotlin/org/opensearch/replication/action/status/ReplicationStatusResponse.kt	97
src/main/kotlin/org/opensearch/replication/action/status/ShardInfoRequest.kt	42
src/main/kotlin/org/opensearch/replication/action/status/ShardInfoResponse.kt	175
src/main/kotlin/org/opensearch/replication/action/status/ShardsInfoAction.kt	11
src/main/kotlin/org/opensearch/replication/action/status/TranportShardsInfoAction.kt	89
src/main/kotlin/org/opensearch/replication/action/status/TransportReplicationStatusAction.kt	134
src/main/kotlin/org/opensearch/replication/action/stop/StopIndexReplicationAction.kt	9
src/main/kotlin/org/opensearch/replication/action/stop/StopIndexReplicationRequest.kt	52
src/main/kotlin/org/opensearch/replication/action/stop/TransportStopIndexReplicationAction.kt	166
src/main/kotlin/org/opensearch/replication/action/update/TransportUpdateIndexReplicationAction.kt	78
src/main/kotlin/org/opensearch/replication/action/update/UpdateIndexReplicationAction.kt	9
src/main/kotlin/org/opensearch/replication/action/update/UpdateIndexReplicationRequest.kt	64
src/main/kotlin/org/opensearch/replication/metadata/ReplicationMetadataManager.kt	175
src/main/kotlin/org/opensearch/replication/metadata/ReplicationOverallState.kt	4
src/main/kotlin/org/opensearch/replication/metadata/TransportUpdateMetadataAction.kt	246
src/main/kotlin/org/opensearch/replication/metadata/UpdateIndexBlockTask.kt	61
src/main/kotlin/org/opensearch/replication/metadata/UpdateMetadataAction.kt	10
src/main/kotlin/org/opensearch/replication/metadata/UpdateMetadataRequest.kt	47
src/main/kotlin/org/opensearch/replication/metadata/UpdateReplicationMetadata.kt	64
src/main/kotlin/org/opensearch/replication/metadata/state/ReplicationStateMetadata.kt	127
src/main/kotlin/org/opensearch/replication/metadata/store/AddReplicationMetadataRequest.kt	3
src/main/kotlin/org/opensearch/replication/metadata/store/DeleteReplicationMetadataRequest.kt	5
src/main/kotlin/org/opensearch/replication/metadata/store/GetReplicationMetadataRequest.kt	5
src/main/kotlin/org/opensearch/replication/metadata/store/GetReplicationMetadataResponse.kt	5
src/main/kotlin/org/opensearch/replication/metadata/store/ReplicationMetadata.kt	129
src/main/kotlin/org/opensearch/replication/metadata/store/ReplicationMetadataStore.kt	229
src/main/kotlin/org/opensearch/replication/metadata/store/ReplicationStoreMetadataType.kt	4
src/main/kotlin/org/opensearch/replication/metadata/store/UpdateReplicationMetadataRequest.kt	6
src/main/kotlin/org/opensearch/replication/repository/RemoteClusterMultiChunkTransfer.kt	88
src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepositoriesService.kt	22
src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepository.kt	300
src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRepositoryFileChunk.kt	10
src/main/kotlin/org/opensearch/replication/repository/RemoteClusterRestoreLeaderService.kt	85
src/main/kotlin/org/opensearch/replication/repository/RestoreContext.kt	37
src/main/kotlin/org/opensearch/replication/rest/AutoFollowStatsHandler.kt	44
src/main/kotlin/org/opensearch/replication/rest/FollowerStatsHandler.kt	44
src/main/kotlin/org/opensearch/replication/rest/LeaderStatsHandler.kt	44
src/main/kotlin/org/opensearch/replication/rest/PauseIndexReplicationHandler.kt	33
src/main/kotlin/org/opensearch/replication/rest/ReplicateIndexHandler.kt	31
src/main/kotlin/org/opensearch/replication/rest/ReplicationStatusHandler.kt	32
src/main/kotlin/org/opensearch/replication/rest/ResumeIndexReplicationHandler.kt	33
src/main/kotlin/org/opensearch/replication/rest/StopIndexReplicationHandler.kt	29
src/main/kotlin/org/opensearch/replication/rest/UpdateAutoFollowPatternsHandler.kt	34
src/main/kotlin/org/opensearch/replication/rest/UpdateIndexHandler.kt	38
src/main/kotlin/org/opensearch/replication/seqno/RemoteClusterRetentionLeaseHelper.kt	106
src/main/kotlin/org/opensearch/replication/seqno/RemoteClusterStats.kt	99
src/main/kotlin/org/opensearch/replication/seqno/RemoteClusterTranslogService.kt	46
src/main/kotlin/org/opensearch/replication/task/CrossClusterReplicationTask.kt	181
src/main/kotlin/org/opensearch/replication/task/IndexCloseListener.kt	43
src/main/kotlin/org/opensearch/replication/task/ReplicationState.kt	17
src/main/kotlin/org/opensearch/replication/task/autofollow/AutoFollowExecutor.kt	38
src/main/kotlin/org/opensearch/replication/task/autofollow/AutoFollowParams.kt	46
src/main/kotlin/org/opensearch/replication/task/autofollow/AutoFollowTask.kt	213
src/main/kotlin/org/opensearch/replication/task/index/IndexReplicationExecutor.kt	60
src/main/kotlin/org/opensearch/replication/task/index/IndexReplicationParams.kt	60
src/main/kotlin/org/opensearch/replication/task/index/IndexReplicationState.kt	110
src/main/kotlin/org/opensearch/replication/task/index/IndexReplicationTask.kt	732
src/main/kotlin/org/opensearch/replication/task/shard/FollowerClusterStats.kt	90
src/main/kotlin/org/opensearch/replication/task/shard/ShardReplicationChangesTracker.kt	61
src/main/kotlin/org/opensearch/replication/task/shard/ShardReplicationExecutor.kt	65
src/main/kotlin/org/opensearch/replication/task/shard/ShardReplicationParams.kt	92
src/main/kotlin/org/opensearch/replication/task/shard/ShardReplicationState.kt	94
src/main/kotlin/org/opensearch/replication/task/shard/ShardReplicationTask.kt	241
src/main/kotlin/org/opensearch/replication/task/shard/TranslogSequencer.kt	75
src/main/kotlin/org/opensearch/replication/util/Coroutines.kt	195
src/main/kotlin/org/opensearch/replication/util/Extensions.kt	161
src/main/kotlin/org/opensearch/replication/util/Injectables.kt	21
src/main/kotlin/org/opensearch/replication/util/SecurityContext.kt	82
src/main/kotlin/org/opensearch/replication/util/ValidationUtil.kt	65