test_class.declarator: PARTITIONER = "org.apache.cassandra.dht.RandomPartitioner"
test_class.modifier: private static final
test_class.original_string: private static final String PARTITIONER = "org.apache.cassandra.dht.RandomPartitioner";
test_class.type: String
test_class.var_name: PARTITIONER
test_class.declarator: SEED_HOST = "127.0.0.1"
test_class.modifier: private static final
test_class.original_string: private static final String SEED_HOST = "127.0.0.1";
test_class.type: String
test_class.var_name: SEED_HOST
test_class.declarator: INCREMENTAL = false
test_class.modifier: private static final
test_class.original_string: private static final Boolean INCREMENTAL = false;
test_class.type: Boolean
test_class.var_name: INCREMENTAL
test_class.declarator: TABLES = Sets.newHashSet("testTable")
test_class.modifier: private static final
test_class.original_string: private static final Set<String> TABLES = Sets.newHashSet("testTable");
test_class.type: Set<String>
test_class.var_name: TABLES
test_class.declarator: NODES = Collections.emptySet()
test_class.modifier: private static final
test_class.original_string: private static final Set<String> NODES = Collections.emptySet();
test_class.type: Set<String>
test_class.var_name: NODES
test_class.declarator: DATACENTERS = Collections.emptySet()
test_class.modifier: private static final
test_class.original_string: private static final Set<String> DATACENTERS = Collections.emptySet();
test_class.type: Set<String>
test_class.var_name: DATACENTERS
test_class.declarator: NODES_MAP = Maps.newHashMap("node1", "127.0.0.1")
test_class.modifier: private static final
test_class.original_string: private static final Map<String, String> NODES_MAP = Maps.newHashMap("node1", "127.0.0.1");
test_class.type: Map<String, String>
test_class.var_name: NODES_MAP
test_class.declarator: BLACKLISTED_TABLES = Collections.emptySet()
test_class.modifier: private static final
test_class.original_string: private static final Set<String> BLACKLISTED_TABLES = Collections.emptySet();
test_class.type: Set<String>
test_class.var_name: BLACKLISTED_TABLES
test_class.declarator: REPAIR_THREAD_COUNT = 2
test_class.modifier: private static final
test_class.original_string: private static final int REPAIR_THREAD_COUNT = 2;
test_class.type: int
test_class.var_name: REPAIR_THREAD_COUNT
test_class.declarator: OWNER = "test"
test_class.modifier: private static final
test_class.original_string: private static final String OWNER = "test";
test_class.type: String
test_class.var_name: OWNER
test_class.declarator: THREAD_CNT = 1
test_class.modifier: private static final
test_class.original_string: private static final int THREAD_CNT = 1;
test_class.type: int
test_class.var_name: THREAD_CNT
test_class.declarator: REPAIR_TIMEOUT_S = 60
test_class.modifier: private static final
test_class.original_string: private static final int REPAIR_TIMEOUT_S = 60;
test_class.type: int
test_class.var_name: REPAIR_TIMEOUT_S
test_class.declarator: RETRY_DELAY_S = 10
test_class.modifier: private static final
test_class.original_string: private static final int RETRY_DELAY_S = 10;
test_class.type: int
test_class.var_name: RETRY_DELAY_S
test_class.declarator: TIME_CREATE = 42L
test_class.modifier: private static final
test_class.original_string: private static final long TIME_CREATE = 42L;
test_class.type: long
test_class.var_name: TIME_CREATE
test_class.declarator: TIME_START = 43L
test_class.modifier: private static final
test_class.original_string: private static final long TIME_START = 43L;
test_class.type: long
test_class.var_name: TIME_START
test_class.declarator: SAMPLE_URI = URI.create("http://reaper_host/repair_run/")
test_class.modifier: private static final
test_class.original_string: private static final URI SAMPLE_URI = URI.create("http://reaper_host/repair_run/");
test_class.type: URI
test_class.var_name: SAMPLE_URI
test_class.declarator: SEGMENT_CNT = 6
test_class.modifier: private static final
test_class.original_string: private static final int SEGMENT_CNT = 6;
test_class.type: int
test_class.var_name: SEGMENT_CNT
test_class.declarator: REPAIR_INTENSITY = 0.5f
test_class.modifier: private static final
test_class.original_string: private static final double REPAIR_INTENSITY = 0.5f;
test_class.type: double
test_class.var_name: REPAIR_INTENSITY
test_class.declarator: REPAIR_PARALLELISM = RepairParallelism.SEQUENTIAL
test_class.modifier: private static final
test_class.original_string: private static final RepairParallelism REPAIR_PARALLELISM = RepairParallelism.SEQUENTIAL;
test_class.type: RepairParallelism
test_class.var_name: REPAIR_PARALLELISM
test_class.declarator: STCS = "SizeTieredCompactionStrategy"
test_class.modifier: private static final
test_class.original_string: private static final String STCS = "SizeTieredCompactionStrategy";
test_class.type: String
test_class.var_name: STCS
test_class.declarator: TOKENS = Lists.newArrayList(
        BigInteger.valueOf(0L),
        BigInteger.valueOf(100L),
        BigInteger.valueOf(200L))
test_class.modifier: private static final
test_class.original_string: private static final List<BigInteger> TOKENS = Lists.newArrayList(
        BigInteger.valueOf(0L),
        BigInteger.valueOf(100L),
        BigInteger.valueOf(200L));
test_class.type: List<BigInteger>
test_class.var_name: TOKENS
test_class.declarator: clustername = "testcluster_" + RandomStringUtils.randomAlphabetic(6)
test_class.modifier: private final
test_class.original_string: private final String clustername = "testcluster_" + RandomStringUtils.randomAlphabetic(6);
test_class.type: String
test_class.var_name: clustername
test_class.declarator: keyspace = "testkeyspace_" + RandomStringUtils.randomAlphabetic(6)
test_class.modifier: private final
test_class.original_string: private final String keyspace = "testkeyspace_" + RandomStringUtils.randomAlphabetic(6);
test_class.type: String
test_class.var_name: keyspace
test_class.declarator: context
test_class.modifier: private
test_class.original_string: private AppContext context;
test_class.type: AppContext
test_class.var_name: context
test_class.declarator: uriInfo
test_class.modifier: private
test_class.original_string: private UriInfo uriInfo;
test_class.type: UriInfo
test_class.var_name: uriInfo
test_class.declarator: proxy
test_class.modifier: private
test_class.original_string: private JmxProxy proxy;
test_class.type: JmxProxy
test_class.var_name: proxy
test_class.file: src/server/src/test/java/io/cassandrareaper/resources/RepairRunResourceTest.java
test_class.identifier: RepairRunResourceTest
test_case.body: @Test
    public void testPauseNotExistingRun() throws InterruptedException, ReaperException {
      RepairRunResource resource = new RepairRunResource(context);
      Response response = resource.modifyRunState(uriInfo, UUIDs.timeBased(),
          Optional.of(RepairRun.RunState.PAUSED.toString()));
      assertEquals(Response.Status.NOT_FOUND.getStatusCode(), response.getStatus());
      assertEquals(0, context.storage.getRepairRunsWithState(RepairRun.RunState.RUNNING).size());
    }
test_case.class_method_signature: RepairRunResourceTest.testPauseNotExistingRun()
test_case.full_signature: @Test public void testPauseNotExistingRun()
test_case.identifier: testPauseNotExistingRun
test_case.invocations: modifyRunState timeBased of toString assertEquals getStatusCode getStatus assertEquals size getRepairRunsWithState
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testPauseNotExistingRun()
focal_class.declarator: LOG = LoggerFactory.getLogger(RepairRunResource.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(RepairRunResource.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: context
focal_class.modifier: private final
focal_class.original_string: private final AppContext context;
focal_class.type: AppContext
focal_class.var_name: context
focal_class.declarator: repairUnitService
focal_class.modifier: private final
focal_class.original_string: private final RepairUnitService repairUnitService;
focal_class.type: RepairUnitService
focal_class.var_name: repairUnitService
focal_class.declarator: repairRunService
focal_class.modifier: private final
focal_class.original_string: private final RepairRunService repairRunService;
focal_class.type: RepairRunService
focal_class.var_name: repairRunService
focal_class.file: src/server/src/main/java/io/cassandrareaper/resources/RepairRunResource.java
focal_class.identifier: RepairRunResource
focal_class.class_method_signature: RepairRunResource.RepairRunResource(AppContext context)
focal_class.full_signature: public  RepairRunResource(AppContext context)
focal_class.identifier: RepairRunResource
focal_class.modifiers: public
focal_class.parameters: (AppContext context)
focal_class.signature:  RepairRunResource(AppContext context)
focal_class.class_method_signature: RepairRunResource.addRepairRun(
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.full_signature: @POST public Response addRepairRun(
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.identifier: addRepairRun
focal_class.modifiers: @POST public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.return: Response
focal_class.signature: Response addRepairRun(
        @Context UriInfo uriInfo,
        @QueryParam("clusterName") Optional<String> clusterName,
        @QueryParam("keyspace") Optional<String> keyspace,
        @QueryParam("tables") Optional<String> tableNamesParam,
        @QueryParam("owner") Optional<String> owner,
        @QueryParam("cause") Optional<String> cause,
        @QueryParam("segmentCount") Optional<Integer> segmentCountPerNode,
        @QueryParam("repairParallelism") Optional<String> repairParallelism,
        @QueryParam("intensity") Optional<String> intensityStr,
        @QueryParam("incrementalRepair") Optional<String> incrementalRepairStr,
        @QueryParam("nodes") Optional<String> nodesToRepairParam,
        @QueryParam("datacenters") Optional<String> datacentersToRepairParam,
        @QueryParam("blacklistedTables") Optional<String> blacklistedTableNamesParam,
        @QueryParam("repairThreadCount") Optional<Integer> repairThreadCountParam)
focal_class.class_method_signature: RepairRunResource.checkRequestForAddRepair(
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.full_signature: @Nullable static Response checkRequestForAddRepair(
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.identifier: checkRequestForAddRepair
focal_class.modifiers: @Nullable static
focal_class.parameters: (
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.return: Response
focal_class.signature: Response checkRequestForAddRepair(
        AppContext context,
        Optional<String> clusterName,
        Optional<String> keyspace,
        Optional<String> tableNamesParam,
        Optional<String> owner,
        Optional<Integer> segmentCountPerNode,
        Optional<String> repairParallelism,
        Optional<String> intensityStr,
        Optional<String> incrementalRepairStr,
        Optional<String> nodesStr,
        Optional<String> datacentersStr,
        Optional<String> blacklistedTableNamesParam,
        Optional<Integer> repairThreadCountStr)
focal_class.class_method_signature: RepairRunResource.modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.full_signature: @PUT @Path("/{id}/state/{state}") public Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.identifier: modifyRunState
focal_class.modifiers: @PUT @Path("/{id}/state/{state}") public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.return: Response
focal_class.signature: Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_class.class_method_signature: RepairRunResource.modifyRunIntensity(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.full_signature: @PUT @Path("/{id}/intensity/{intensity}") public Response modifyRunIntensity(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.identifier: modifyRunIntensity
focal_class.modifiers: @PUT @Path("/{id}/intensity/{intensity}") public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.return: Response
focal_class.signature: Response modifyRunIntensity(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("intensity") Optional<String> intensityStr)
focal_class.class_method_signature: RepairRunResource.oldModifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.full_signature: @PUT @Path("/{id}") @Deprecated public Response oldModifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.identifier: oldModifyRunState
focal_class.modifiers: @PUT @Path("/{id}") @Deprecated public
focal_class.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.return: Response
focal_class.signature: Response oldModifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @QueryParam("state") Optional<String> stateStr)
focal_class.class_method_signature: RepairRunResource.isStarting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isStarting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isStarting
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isStarting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isPausing(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isPausing(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isPausing
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isPausing(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isResuming(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isResuming(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isResuming
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isResuming(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isRetrying(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isRetrying(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isRetrying
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isRetrying(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isAborting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.full_signature: private static boolean isAborting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.identifier: isAborting
focal_class.modifiers: private static
focal_class.parameters: (RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.return: boolean
focal_class.signature: boolean isAborting(RepairRun.RunState oldState, RepairRun.RunState newState)
focal_class.class_method_signature: RepairRunResource.isUnitAlreadyRepairing(RepairRun repairRun)
focal_class.full_signature: private boolean isUnitAlreadyRepairing(RepairRun repairRun)
focal_class.identifier: isUnitAlreadyRepairing
focal_class.modifiers: private
focal_class.parameters: (RepairRun repairRun)
focal_class.return: boolean
focal_class.signature: boolean isUnitAlreadyRepairing(RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.getSegmentAmountForRepairRun(UUID repairRunId)
focal_class.full_signature: private int getSegmentAmountForRepairRun(UUID repairRunId)
focal_class.identifier: getSegmentAmountForRepairRun
focal_class.modifiers: private
focal_class.parameters: (UUID repairRunId)
focal_class.return: int
focal_class.signature: int getSegmentAmountForRepairRun(UUID repairRunId)
focal_class.class_method_signature: RepairRunResource.startRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response startRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: startRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response startRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.pauseRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response pauseRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: pauseRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response pauseRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.resumeRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response resumeRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: resumeRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response resumeRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.abortRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private Response abortRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: abortRun
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: Response
focal_class.signature: Response abortRun(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.updateRunIntensity(UriInfo uriInfo, RepairRun run, double intensity)
focal_class.full_signature: private Response updateRunIntensity(UriInfo uriInfo, RepairRun run, double intensity)
focal_class.identifier: updateRunIntensity
focal_class.modifiers: private
focal_class.parameters: (UriInfo uriInfo, RepairRun run, double intensity)
focal_class.return: Response
focal_class.signature: Response updateRunIntensity(UriInfo uriInfo, RepairRun run, double intensity)
focal_class.class_method_signature: RepairRunResource.getRepairRun(
        @PathParam("id") UUID repairRunId)
focal_class.full_signature: @GET @Path("/{id}") public Response getRepairRun(
        @PathParam("id") UUID repairRunId)
focal_class.identifier: getRepairRun
focal_class.modifiers: @GET @Path("/{id}") public
focal_class.parameters: (
        @PathParam("id") UUID repairRunId)
focal_class.return: Response
focal_class.signature: Response getRepairRun(
        @PathParam("id") UUID repairRunId)
focal_class.class_method_signature: RepairRunResource.getRepairRunSegments(@PathParam("id") UUID repairRunId)
focal_class.full_signature: @GET @Path("/{id}/segments") public Response getRepairRunSegments(@PathParam("id") UUID repairRunId)
focal_class.identifier: getRepairRunSegments
focal_class.modifiers: @GET @Path("/{id}/segments") public
focal_class.parameters: (@PathParam("id") UUID repairRunId)
focal_class.return: Response
focal_class.signature: Response getRepairRunSegments(@PathParam("id") UUID repairRunId)
focal_class.class_method_signature: RepairRunResource.abortRepairRunSegment(@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.full_signature: @POST @Path("/{id}/segments/abort/{segment_id}") public Response abortRepairRunSegment(@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.identifier: abortRepairRunSegment
focal_class.modifiers: @POST @Path("/{id}/segments/abort/{segment_id}") public
focal_class.parameters: (@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.return: Response
focal_class.signature: Response abortRepairRunSegment(@PathParam("id") UUID repairRunId, @PathParam("segment_id") UUID segmentId)
focal_class.class_method_signature: RepairRunResource.getRepairRunsForCluster(
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.full_signature: @GET @Path("/cluster/{cluster_name}") public Response getRepairRunsForCluster(
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.identifier: getRepairRunsForCluster
focal_class.modifiers: @GET @Path("/cluster/{cluster_name}") public
focal_class.parameters: (
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.return: Response
focal_class.signature: Response getRepairRunsForCluster(
        @PathParam("cluster_name") String clusterName,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.class_method_signature: RepairRunResource.getRepairRunStatus(RepairRun repairRun)
focal_class.full_signature: private RepairRunStatus getRepairRunStatus(RepairRun repairRun)
focal_class.identifier: getRepairRunStatus
focal_class.modifiers: private
focal_class.parameters: (RepairRun repairRun)
focal_class.return: RepairRunStatus
focal_class.signature: RepairRunStatus getRepairRunStatus(RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.buildRepairRunUri(UriInfo uriInfo, RepairRun repairRun)
focal_class.full_signature: private static URI buildRepairRunUri(UriInfo uriInfo, RepairRun repairRun)
focal_class.identifier: buildRepairRunUri
focal_class.modifiers: private static
focal_class.parameters: (UriInfo uriInfo, RepairRun repairRun)
focal_class.return: URI
focal_class.signature: URI buildRepairRunUri(UriInfo uriInfo, RepairRun repairRun)
focal_class.class_method_signature: RepairRunResource.listRepairRuns(
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.full_signature: @GET public Response listRepairRuns(
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.identifier: listRepairRuns
focal_class.modifiers: @GET public
focal_class.parameters: (
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.return: Response
focal_class.signature: Response listRepairRuns(
        @QueryParam("state") Optional<String> state,
        @QueryParam("cluster_name") Optional<String> cluster,
        @QueryParam("keyspace_name") Optional<String> keyspace,
        @QueryParam("limit") Optional<Integer> limit)
focal_class.class_method_signature: RepairRunResource.getRunStatuses(Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.full_signature: private List<RepairRunStatus> getRunStatuses(Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.identifier: getRunStatuses
focal_class.modifiers: private
focal_class.parameters: (Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.return: List<RepairRunStatus>
focal_class.signature: List<RepairRunStatus> getRunStatuses(Collection<RepairRun> runs, Set<String> desiredStates)
focal_class.class_method_signature: RepairRunResource.splitStateParam(Optional<String> state)
focal_class.full_signature: static Set splitStateParam(Optional<String> state)
focal_class.identifier: splitStateParam
focal_class.modifiers: static
focal_class.parameters: (Optional<String> state)
focal_class.return: Set
focal_class.signature: Set splitStateParam(Optional<String> state)
focal_class.class_method_signature: RepairRunResource.deleteRepairRun(
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.full_signature: @DELETE @Path("/{id}") public Response deleteRepairRun(
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.identifier: deleteRepairRun
focal_class.modifiers: @DELETE @Path("/{id}") public
focal_class.parameters: (
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.return: Response
focal_class.signature: Response deleteRepairRun(
        @PathParam("id") UUID runId,
        @QueryParam("owner") Optional<String> owner)
focal_class.class_method_signature: RepairRunResource.purgeRepairRuns()
focal_class.full_signature: @POST @Path("/purge") public Response purgeRepairRuns()
focal_class.identifier: purgeRepairRuns
focal_class.modifiers: @POST @Path("/purge") public
focal_class.parameters: ()
focal_class.return: Response
focal_class.signature: Response purgeRepairRuns()
focal_class.class_method_signature: RepairRunResource.checkRepairParallelismString(String repairParallelism)
focal_class.full_signature: private static void checkRepairParallelismString(String repairParallelism)
focal_class.identifier: checkRepairParallelismString
focal_class.modifiers: private static
focal_class.parameters: (String repairParallelism)
focal_class.return: void
focal_class.signature: void checkRepairParallelismString(String repairParallelism)
focal_class.class_method_signature: RepairRunResource.createMissingArgumentResponse(String argumentName)
focal_class.full_signature: private static Response createMissingArgumentResponse(String argumentName)
focal_class.identifier: createMissingArgumentResponse
focal_class.modifiers: private static
focal_class.parameters: (String argumentName)
focal_class.return: Response
focal_class.signature: Response createMissingArgumentResponse(String argumentName)
focal_class.class_method_signature: RepairRunResource.parseRunState(String input)
focal_class.full_signature: private static RunState parseRunState(String input)
focal_class.identifier: parseRunState
focal_class.modifiers: private static
focal_class.parameters: (String input)
focal_class.return: RunState
focal_class.signature: RunState parseRunState(String input)
focal_class.class_method_signature: RepairRunResource.parseIntensity(String input)
focal_class.full_signature: private static double parseIntensity(String input)
focal_class.identifier: parseIntensity
focal_class.modifiers: private static
focal_class.parameters: (String input)
focal_class.return: double
focal_class.signature: double parseIntensity(String input)
focal_method.body: @PUT
    @Path("/{id}/state/{state}")
    public Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
        throws ReaperException {
  
      LOG.info("modify repair run state called with: id = {}, state = {}", repairRunId, stateStr);
      try {
        if (!stateStr.isPresent()) {
          return createMissingArgumentResponse("state");
        }
  
        Optional<RepairRun> repairRun = context.storage.getRepairRun(repairRunId);
        if (!repairRun.isPresent()) {
          return Response.status(Status.NOT_FOUND).entity("repair run " + repairRunId + " doesn't exist").build();
        }
  
        final RepairRun.RunState newState = parseRunState(stateStr.get());
        final RunState oldState = repairRun.get().getRunState();
        if (oldState == newState) {
          String msg = "given \"state\" " + stateStr + " is same as the current run state";
          return Response.noContent().entity(msg).location(buildRepairRunUri(uriInfo, repairRun.get())).build();
        }
        if ((isStarting(oldState, newState) || isResuming(oldState, newState) || isRetrying(oldState, newState))
            && isUnitAlreadyRepairing(repairRun.get())) {
  
          String errMsg = "repair unit already has run " + repairRun.get().getRepairUnitId() + " in RUNNING state";
          LOG.error(errMsg);
          return Response.status(Status.CONFLICT).entity(errMsg).build();
        }
  
        if (isStarting(oldState, newState)) {
          return startRun(uriInfo, repairRun.get());
        } else if (isPausing(oldState, newState)) {
          return pauseRun(uriInfo, repairRun.get());
        } else if (isResuming(oldState, newState) || isRetrying(oldState, newState)) {
          return resumeRun(uriInfo, repairRun.get());
        } else if (isAborting(oldState, newState)) {
          return abortRun(uriInfo, repairRun.get());
        } else {
          String errMsg = String.format("Transition %s->%s not supported.", oldState.toString(), newState.toString());
          LOG.error(errMsg);
          return Response.status(Status.CONFLICT).entity(errMsg).build();
        }
      } catch (ValidationException ex) {
        return Response.status(Status.BAD_REQUEST).entity(ex.getMessage()).build();
      }
    }
focal_method.class_method_signature: RepairRunResource.modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_method.full_signature: @PUT @Path("/{id}/state/{state}") public Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_method.identifier: modifyRunState
focal_method.invocations: info isPresent createMissingArgumentResponse getRepairRun isPresent build entity status parseRunState get getRunState get build location entity noContent buildRepairRunUri get isStarting isResuming isRetrying isUnitAlreadyRepairing get getRepairUnitId get error build entity status isStarting startRun get isPausing pauseRun get isResuming isRetrying resumeRun get isAborting abortRun get format toString toString error build entity status build entity status getMessage
focal_method.modifiers: @PUT @Path("/{id}/state/{state}") public
focal_method.parameters: (
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)
focal_method.return: Response
focal_method.signature: Response modifyRunState(
        @Context UriInfo uriInfo,
        @PathParam("id") UUID repairRunId,
        @PathParam("state") Optional<String> stateStr)