test_class.declarator: DB_URL = "jdbc:h2:mem:test_mem;MODE=PostgreSQL;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false"
test_class.modifier: private static final
test_class.original_string: private static final String DB_URL = "jdbc:h2:mem:test_mem;MODE=PostgreSQL;DB_CLOSE_DELAY=-1;DATABASE_TO_UPPER=false";
test_class.type: String
test_class.var_name: DB_URL
test_class.file: src/server/src/test/java/io/cassandrareaper/storage/PostgresStorageTest.java
test_class.identifier: PostgresStorageTest
test_case.body: @Test
    public void testSaveHeartbeat() {
      DBI dbi = new DBI(DB_URL);
      UUID reaperInstanceId = UUID.randomUUID();
      PostgresStorage storage = new PostgresStorage(reaperInstanceId, dbi);
      Assertions.assertThat(storage.isStorageConnected()).isTrue();
  
      Handle handle = dbi.open();
      handle.execute("DELETE from running_reapers");
  
      storage.saveHeartbeat();
      int numReapers = storage.countRunningReapers();
      Assertions.assertThat(numReapers).isEqualTo(1);
    }
test_case.class_method_signature: PostgresStorageTest.testSaveHeartbeat()
test_case.full_signature: @Test public void testSaveHeartbeat()
test_case.identifier: testSaveHeartbeat
test_case.invocations: randomUUID isTrue assertThat isStorageConnected open execute saveHeartbeat countRunningReapers isEqualTo assertThat
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSaveHeartbeat()
focal_class.declarator: LOG = LoggerFactory.getLogger(PostgresStorage.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger LOG = LoggerFactory.getLogger(PostgresStorage.class);
focal_class.type: Logger
focal_class.var_name: LOG
focal_class.declarator: DEFAULT_LEADER_TIMEOUT_MIN = 10
focal_class.modifier: private static final
focal_class.original_string: private static final int DEFAULT_LEADER_TIMEOUT_MIN = 10;
focal_class.type: int
focal_class.var_name: DEFAULT_LEADER_TIMEOUT_MIN
focal_class.declarator: DEFAULT_REAPER_TIMEOUT_MIN = 3
focal_class.modifier: private static final
focal_class.original_string: private static final int DEFAULT_REAPER_TIMEOUT_MIN = 3;
focal_class.type: int
focal_class.var_name: DEFAULT_REAPER_TIMEOUT_MIN
focal_class.declarator: DEFAULT_METRICS_TIMEOUT_MIN = 14400
focal_class.modifier: private static final
focal_class.original_string: private static final int DEFAULT_METRICS_TIMEOUT_MIN = 14400;
focal_class.type: int
focal_class.var_name: DEFAULT_METRICS_TIMEOUT_MIN
focal_class.declarator: DEFAULT_NODE_OPERATIONS_TIMEOUT_MIN = 5
focal_class.modifier: private static final
focal_class.original_string: private static final int DEFAULT_NODE_OPERATIONS_TIMEOUT_MIN = 5;
focal_class.type: int
focal_class.var_name: DEFAULT_NODE_OPERATIONS_TIMEOUT_MIN
focal_class.declarator: jdbi
focal_class.modifier: protected final
focal_class.original_string: protected final DBI jdbi;
focal_class.type: DBI
focal_class.var_name: jdbi
focal_class.declarator: leaderTimeout
focal_class.modifier: private final
focal_class.original_string: private final Duration leaderTimeout;
focal_class.type: Duration
focal_class.var_name: leaderTimeout
focal_class.declarator: reaperTimeout
focal_class.modifier: private final
focal_class.original_string: private final Duration reaperTimeout;
focal_class.type: Duration
focal_class.var_name: reaperTimeout
focal_class.declarator: metricsTimeout
focal_class.modifier: private final
focal_class.original_string: private final Duration metricsTimeout;
focal_class.type: Duration
focal_class.var_name: metricsTimeout
focal_class.declarator: nodeOperationsTimeout
focal_class.modifier: private final
focal_class.original_string: private final Duration nodeOperationsTimeout;
focal_class.type: Duration
focal_class.var_name: nodeOperationsTimeout
focal_class.declarator: reaperInstanceId
focal_class.modifier: private final
focal_class.original_string: private final UUID reaperInstanceId;
focal_class.type: UUID
focal_class.var_name: reaperInstanceId
focal_class.file: src/server/src/main/java/io/cassandrareaper/storage/PostgresStorage.java
focal_class.identifier: PostgresStorage
focal_class.interfaces: implements IStorage, IDistributedStorage
focal_class.class_method_signature: PostgresStorage.PostgresStorage(UUID reaperInstanceId, DBI jdbi)
focal_class.full_signature: public  PostgresStorage(UUID reaperInstanceId, DBI jdbi)
focal_class.identifier: PostgresStorage
focal_class.modifiers: public
focal_class.parameters: (UUID reaperInstanceId, DBI jdbi)
focal_class.signature:  PostgresStorage(UUID reaperInstanceId, DBI jdbi)
focal_class.class_method_signature: PostgresStorage.PostgresStorage(UUID reaperInstanceId,
                           DBI jdbi,
                           int leaderTimeoutInMinutes,
                           int reaperTimeoutInMinutes,
                           int metricsTimeoutInMinutes,
                           int nodeOperationsTimeoutInMinutes)
focal_class.full_signature: @VisibleForTesting public  PostgresStorage(UUID reaperInstanceId,
                           DBI jdbi,
                           int leaderTimeoutInMinutes,
                           int reaperTimeoutInMinutes,
                           int metricsTimeoutInMinutes,
                           int nodeOperationsTimeoutInMinutes)
focal_class.identifier: PostgresStorage
focal_class.modifiers: @VisibleForTesting public
focal_class.parameters: (UUID reaperInstanceId,
                           DBI jdbi,
                           int leaderTimeoutInMinutes,
                           int reaperTimeoutInMinutes,
                           int metricsTimeoutInMinutes,
                           int nodeOperationsTimeoutInMinutes)
focal_class.signature:  PostgresStorage(UUID reaperInstanceId,
                           DBI jdbi,
                           int leaderTimeoutInMinutes,
                           int reaperTimeoutInMinutes,
                           int metricsTimeoutInMinutes,
                           int nodeOperationsTimeoutInMinutes)
focal_class.class_method_signature: PostgresStorage.getPostgresStorage(Handle handle)
focal_class.full_signature: protected static IStoragePostgreSql getPostgresStorage(Handle handle)
focal_class.identifier: getPostgresStorage
focal_class.modifiers: protected static
focal_class.parameters: (Handle handle)
focal_class.return: IStoragePostgreSql
focal_class.signature: IStoragePostgreSql getPostgresStorage(Handle handle)
focal_class.class_method_signature: PostgresStorage.getCluster(String clusterName)
focal_class.full_signature: @Override public Cluster getCluster(String clusterName)
focal_class.identifier: getCluster
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName)
focal_class.return: Cluster
focal_class.signature: Cluster getCluster(String clusterName)
focal_class.class_method_signature: PostgresStorage.deleteCluster(String clusterName)
focal_class.full_signature: @Override public Cluster deleteCluster(String clusterName)
focal_class.identifier: deleteCluster
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName)
focal_class.return: Cluster
focal_class.signature: Cluster deleteCluster(String clusterName)
focal_class.class_method_signature: PostgresStorage.isStorageConnected()
focal_class.full_signature: @Override public boolean isStorageConnected()
focal_class.identifier: isStorageConnected
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isStorageConnected()
focal_class.class_method_signature: PostgresStorage.getClusters()
focal_class.full_signature: @Override public Collection<Cluster> getClusters()
focal_class.identifier: getClusters
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<Cluster>
focal_class.signature: Collection<Cluster> getClusters()
focal_class.class_method_signature: PostgresStorage.addCluster(Cluster cluster)
focal_class.full_signature: @Override public boolean addCluster(Cluster cluster)
focal_class.identifier: addCluster
focal_class.modifiers: @Override public
focal_class.parameters: (Cluster cluster)
focal_class.return: boolean
focal_class.signature: boolean addCluster(Cluster cluster)
focal_class.class_method_signature: PostgresStorage.updateCluster(Cluster cluster)
focal_class.full_signature: @Override public boolean updateCluster(Cluster cluster)
focal_class.identifier: updateCluster
focal_class.modifiers: @Override public
focal_class.parameters: (Cluster cluster)
focal_class.return: boolean
focal_class.signature: boolean updateCluster(Cluster cluster)
focal_class.class_method_signature: PostgresStorage.addAndUpdateClusterAssertions(Cluster cluster)
focal_class.full_signature: private boolean addAndUpdateClusterAssertions(Cluster cluster)
focal_class.identifier: addAndUpdateClusterAssertions
focal_class.modifiers: private
focal_class.parameters: (Cluster cluster)
focal_class.return: boolean
focal_class.signature: boolean addAndUpdateClusterAssertions(Cluster cluster)
focal_class.class_method_signature: PostgresStorage.getRepairRun(UUID id)
focal_class.full_signature: @Override public Optional<RepairRun> getRepairRun(UUID id)
focal_class.identifier: getRepairRun
focal_class.modifiers: @Override public
focal_class.parameters: (UUID id)
focal_class.return: Optional<RepairRun>
focal_class.signature: Optional<RepairRun> getRepairRun(UUID id)
focal_class.class_method_signature: PostgresStorage.getRepairRunsForCluster(String clusterName, Optional<Integer> limit)
focal_class.full_signature: @Override public Collection<RepairRun> getRepairRunsForCluster(String clusterName, Optional<Integer> limit)
focal_class.identifier: getRepairRunsForCluster
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, Optional<Integer> limit)
focal_class.return: Collection<RepairRun>
focal_class.signature: Collection<RepairRun> getRepairRunsForCluster(String clusterName, Optional<Integer> limit)
focal_class.class_method_signature: PostgresStorage.getRepairRunsForUnit(UUID repairUnitId)
focal_class.full_signature: @Override public Collection<RepairRun> getRepairRunsForUnit(UUID repairUnitId)
focal_class.identifier: getRepairRunsForUnit
focal_class.modifiers: @Override public
focal_class.parameters: (UUID repairUnitId)
focal_class.return: Collection<RepairRun>
focal_class.signature: Collection<RepairRun> getRepairRunsForUnit(UUID repairUnitId)
focal_class.class_method_signature: PostgresStorage.getRepairRunsWithState(RepairRun.RunState runState)
focal_class.full_signature: @Override public Collection<RepairRun> getRepairRunsWithState(RepairRun.RunState runState)
focal_class.identifier: getRepairRunsWithState
focal_class.modifiers: @Override public
focal_class.parameters: (RepairRun.RunState runState)
focal_class.return: Collection<RepairRun>
focal_class.signature: Collection<RepairRun> getRepairRunsWithState(RepairRun.RunState runState)
focal_class.class_method_signature: PostgresStorage.deleteRepairRun(UUID id)
focal_class.full_signature: @Override public Optional<RepairRun> deleteRepairRun(UUID id)
focal_class.identifier: deleteRepairRun
focal_class.modifiers: @Override public
focal_class.parameters: (UUID id)
focal_class.return: Optional<RepairRun>
focal_class.signature: Optional<RepairRun> deleteRepairRun(UUID id)
focal_class.class_method_signature: PostgresStorage.addRepairRun(RepairRun.Builder newRepairRun, Collection<RepairSegment.Builder> newSegments)
focal_class.full_signature: @Override public RepairRun addRepairRun(RepairRun.Builder newRepairRun, Collection<RepairSegment.Builder> newSegments)
focal_class.identifier: addRepairRun
focal_class.modifiers: @Override public
focal_class.parameters: (RepairRun.Builder newRepairRun, Collection<RepairSegment.Builder> newSegments)
focal_class.return: RepairRun
focal_class.signature: RepairRun addRepairRun(RepairRun.Builder newRepairRun, Collection<RepairSegment.Builder> newSegments)
focal_class.class_method_signature: PostgresStorage.updateRepairRun(RepairRun repairRun)
focal_class.full_signature: @Override public boolean updateRepairRun(RepairRun repairRun)
focal_class.identifier: updateRepairRun
focal_class.modifiers: @Override public
focal_class.parameters: (RepairRun repairRun)
focal_class.return: boolean
focal_class.signature: boolean updateRepairRun(RepairRun repairRun)
focal_class.class_method_signature: PostgresStorage.updateRepairRun(RepairRun repairRun, Optional<Boolean> updateRepairState)
focal_class.full_signature: @Override public boolean updateRepairRun(RepairRun repairRun, Optional<Boolean> updateRepairState)
focal_class.identifier: updateRepairRun
focal_class.modifiers: @Override public
focal_class.parameters: (RepairRun repairRun, Optional<Boolean> updateRepairState)
focal_class.return: boolean
focal_class.signature: boolean updateRepairRun(RepairRun repairRun, Optional<Boolean> updateRepairState)
focal_class.class_method_signature: PostgresStorage.addRepairUnit(RepairUnit.Builder newRepairUnit)
focal_class.full_signature: @Override public RepairUnit addRepairUnit(RepairUnit.Builder newRepairUnit)
focal_class.identifier: addRepairUnit
focal_class.modifiers: @Override public
focal_class.parameters: (RepairUnit.Builder newRepairUnit)
focal_class.return: RepairUnit
focal_class.signature: RepairUnit addRepairUnit(RepairUnit.Builder newRepairUnit)
focal_class.class_method_signature: PostgresStorage.getRepairUnit(UUID id)
focal_class.full_signature: @Override public RepairUnit getRepairUnit(UUID id)
focal_class.identifier: getRepairUnit
focal_class.modifiers: @Override public
focal_class.parameters: (UUID id)
focal_class.return: RepairUnit
focal_class.signature: RepairUnit getRepairUnit(UUID id)
focal_class.class_method_signature: PostgresStorage.getRepairUnit(RepairUnit.Builder params)
focal_class.full_signature: @Override public Optional<RepairUnit> getRepairUnit(RepairUnit.Builder params)
focal_class.identifier: getRepairUnit
focal_class.modifiers: @Override public
focal_class.parameters: (RepairUnit.Builder params)
focal_class.return: Optional<RepairUnit>
focal_class.signature: Optional<RepairUnit> getRepairUnit(RepairUnit.Builder params)
focal_class.class_method_signature: PostgresStorage.addRepairSegments(Collection<RepairSegment.Builder> newSegments, UUID runId)
focal_class.full_signature: private void addRepairSegments(Collection<RepairSegment.Builder> newSegments, UUID runId)
focal_class.identifier: addRepairSegments
focal_class.modifiers: private
focal_class.parameters: (Collection<RepairSegment.Builder> newSegments, UUID runId)
focal_class.return: void
focal_class.signature: void addRepairSegments(Collection<RepairSegment.Builder> newSegments, UUID runId)
focal_class.class_method_signature: PostgresStorage.updateRepairSegment(RepairSegment repairSegment)
focal_class.full_signature: @Override public boolean updateRepairSegment(RepairSegment repairSegment)
focal_class.identifier: updateRepairSegment
focal_class.modifiers: @Override public
focal_class.parameters: (RepairSegment repairSegment)
focal_class.return: boolean
focal_class.signature: boolean updateRepairSegment(RepairSegment repairSegment)
focal_class.class_method_signature: PostgresStorage.getRepairSegment(UUID runId, UUID segmentId)
focal_class.full_signature: @Override public Optional<RepairSegment> getRepairSegment(UUID runId, UUID segmentId)
focal_class.identifier: getRepairSegment
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, UUID segmentId)
focal_class.return: Optional<RepairSegment>
focal_class.signature: Optional<RepairSegment> getRepairSegment(UUID runId, UUID segmentId)
focal_class.class_method_signature: PostgresStorage.getRepairSegmentsForRun(UUID runId)
focal_class.full_signature: @Override public Collection<RepairSegment> getRepairSegmentsForRun(UUID runId)
focal_class.identifier: getRepairSegmentsForRun
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId)
focal_class.return: Collection<RepairSegment>
focal_class.signature: Collection<RepairSegment> getRepairSegmentsForRun(UUID runId)
focal_class.class_method_signature: PostgresStorage.getNextFreeSegment(UUID runId)
focal_class.full_signature: private Optional<RepairSegment> getNextFreeSegment(UUID runId)
focal_class.identifier: getNextFreeSegment
focal_class.modifiers: private
focal_class.parameters: (UUID runId)
focal_class.return: Optional<RepairSegment>
focal_class.signature: Optional<RepairSegment> getNextFreeSegment(UUID runId)
focal_class.class_method_signature: PostgresStorage.getNextFreeSegmentInRange(UUID runId, Optional<RingRange> range)
focal_class.full_signature: @Override public Optional<RepairSegment> getNextFreeSegmentInRange(UUID runId, Optional<RingRange> range)
focal_class.identifier: getNextFreeSegmentInRange
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, Optional<RingRange> range)
focal_class.return: Optional<RepairSegment>
focal_class.signature: Optional<RepairSegment> getNextFreeSegmentInRange(UUID runId, Optional<RingRange> range)
focal_class.class_method_signature: PostgresStorage.getSegmentsWithState(UUID runId, RepairSegment.State segmentState)
focal_class.full_signature: @Override public Collection<RepairSegment> getSegmentsWithState(UUID runId, RepairSegment.State segmentState)
focal_class.identifier: getSegmentsWithState
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, RepairSegment.State segmentState)
focal_class.return: Collection<RepairSegment>
focal_class.signature: Collection<RepairSegment> getSegmentsWithState(UUID runId, RepairSegment.State segmentState)
focal_class.class_method_signature: PostgresStorage.getOngoingRepairsInCluster(String clusterName)
focal_class.full_signature: @Override public Collection<RepairParameters> getOngoingRepairsInCluster(String clusterName)
focal_class.identifier: getOngoingRepairsInCluster
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName)
focal_class.return: Collection<RepairParameters>
focal_class.signature: Collection<RepairParameters> getOngoingRepairsInCluster(String clusterName)
focal_class.class_method_signature: PostgresStorage.getRepairRunIdsForCluster(String clusterName, Optional<Integer> limit)
focal_class.full_signature: @Override public SortedSet<UUID> getRepairRunIdsForCluster(String clusterName, Optional<Integer> limit)
focal_class.identifier: getRepairRunIdsForCluster
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, Optional<Integer> limit)
focal_class.return: SortedSet<UUID>
focal_class.signature: SortedSet<UUID> getRepairRunIdsForCluster(String clusterName, Optional<Integer> limit)
focal_class.class_method_signature: PostgresStorage.getSegmentAmountForRepairRun(UUID runId)
focal_class.full_signature: @Override public int getSegmentAmountForRepairRun(UUID runId)
focal_class.identifier: getSegmentAmountForRepairRun
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId)
focal_class.return: int
focal_class.signature: int getSegmentAmountForRepairRun(UUID runId)
focal_class.class_method_signature: PostgresStorage.getSegmentAmountForRepairRunWithState(UUID runId, RepairSegment.State state)
focal_class.full_signature: @Override public int getSegmentAmountForRepairRunWithState(UUID runId, RepairSegment.State state)
focal_class.identifier: getSegmentAmountForRepairRunWithState
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, RepairSegment.State state)
focal_class.return: int
focal_class.signature: int getSegmentAmountForRepairRunWithState(UUID runId, RepairSegment.State state)
focal_class.class_method_signature: PostgresStorage.addRepairSchedule(RepairSchedule.Builder repairSchedule)
focal_class.full_signature: @Override public RepairSchedule addRepairSchedule(RepairSchedule.Builder repairSchedule)
focal_class.identifier: addRepairSchedule
focal_class.modifiers: @Override public
focal_class.parameters: (RepairSchedule.Builder repairSchedule)
focal_class.return: RepairSchedule
focal_class.signature: RepairSchedule addRepairSchedule(RepairSchedule.Builder repairSchedule)
focal_class.class_method_signature: PostgresStorage.getRepairSchedule(UUID repairScheduleId)
focal_class.full_signature: @Override public Optional<RepairSchedule> getRepairSchedule(UUID repairScheduleId)
focal_class.identifier: getRepairSchedule
focal_class.modifiers: @Override public
focal_class.parameters: (UUID repairScheduleId)
focal_class.return: Optional<RepairSchedule>
focal_class.signature: Optional<RepairSchedule> getRepairSchedule(UUID repairScheduleId)
focal_class.class_method_signature: PostgresStorage.getRepairSchedulesForCluster(String clusterName)
focal_class.full_signature: @Override public Collection<RepairSchedule> getRepairSchedulesForCluster(String clusterName)
focal_class.identifier: getRepairSchedulesForCluster
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName)
focal_class.return: Collection<RepairSchedule>
focal_class.signature: Collection<RepairSchedule> getRepairSchedulesForCluster(String clusterName)
focal_class.class_method_signature: PostgresStorage.getRepairSchedulesForKeyspace(String keyspaceName)
focal_class.full_signature: @Override public Collection<RepairSchedule> getRepairSchedulesForKeyspace(String keyspaceName)
focal_class.identifier: getRepairSchedulesForKeyspace
focal_class.modifiers: @Override public
focal_class.parameters: (String keyspaceName)
focal_class.return: Collection<RepairSchedule>
focal_class.signature: Collection<RepairSchedule> getRepairSchedulesForKeyspace(String keyspaceName)
focal_class.class_method_signature: PostgresStorage.getRepairSchedulesForClusterAndKeyspace(String clusterName, String keyspaceName)
focal_class.full_signature: @Override public Collection<RepairSchedule> getRepairSchedulesForClusterAndKeyspace(String clusterName, String keyspaceName)
focal_class.identifier: getRepairSchedulesForClusterAndKeyspace
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, String keyspaceName)
focal_class.return: Collection<RepairSchedule>
focal_class.signature: Collection<RepairSchedule> getRepairSchedulesForClusterAndKeyspace(String clusterName, String keyspaceName)
focal_class.class_method_signature: PostgresStorage.getAllRepairSchedules()
focal_class.full_signature: @Override public Collection<RepairSchedule> getAllRepairSchedules()
focal_class.identifier: getAllRepairSchedules
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<RepairSchedule>
focal_class.signature: Collection<RepairSchedule> getAllRepairSchedules()
focal_class.class_method_signature: PostgresStorage.updateRepairSchedule(RepairSchedule newRepairSchedule)
focal_class.full_signature: @Override public boolean updateRepairSchedule(RepairSchedule newRepairSchedule)
focal_class.identifier: updateRepairSchedule
focal_class.modifiers: @Override public
focal_class.parameters: (RepairSchedule newRepairSchedule)
focal_class.return: boolean
focal_class.signature: boolean updateRepairSchedule(RepairSchedule newRepairSchedule)
focal_class.class_method_signature: PostgresStorage.deleteRepairSchedule(UUID id)
focal_class.full_signature: @Override public Optional<RepairSchedule> deleteRepairSchedule(UUID id)
focal_class.identifier: deleteRepairSchedule
focal_class.modifiers: @Override public
focal_class.parameters: (UUID id)
focal_class.return: Optional<RepairSchedule>
focal_class.signature: Optional<RepairSchedule> deleteRepairSchedule(UUID id)
focal_class.class_method_signature: PostgresStorage.getClusterRunStatuses(String clusterName, int limit)
focal_class.full_signature: @Override public Collection<RepairRunStatus> getClusterRunStatuses(String clusterName, int limit)
focal_class.identifier: getClusterRunStatuses
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, int limit)
focal_class.return: Collection<RepairRunStatus>
focal_class.signature: Collection<RepairRunStatus> getClusterRunStatuses(String clusterName, int limit)
focal_class.class_method_signature: PostgresStorage.getClusterScheduleStatuses(String clusterName)
focal_class.full_signature: @Override public Collection<RepairScheduleStatus> getClusterScheduleStatuses(String clusterName)
focal_class.identifier: getClusterScheduleStatuses
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName)
focal_class.return: Collection<RepairScheduleStatus>
focal_class.signature: Collection<RepairScheduleStatus> getClusterScheduleStatuses(String clusterName)
focal_class.class_method_signature: PostgresStorage.saveSnapshot(Snapshot snapshot)
focal_class.full_signature: @Override public boolean saveSnapshot(Snapshot snapshot)
focal_class.identifier: saveSnapshot
focal_class.modifiers: @Override public
focal_class.parameters: (Snapshot snapshot)
focal_class.return: boolean
focal_class.signature: boolean saveSnapshot(Snapshot snapshot)
focal_class.class_method_signature: PostgresStorage.deleteSnapshot(Snapshot snapshot)
focal_class.full_signature: @Override public boolean deleteSnapshot(Snapshot snapshot)
focal_class.identifier: deleteSnapshot
focal_class.modifiers: @Override public
focal_class.parameters: (Snapshot snapshot)
focal_class.return: boolean
focal_class.signature: boolean deleteSnapshot(Snapshot snapshot)
focal_class.class_method_signature: PostgresStorage.getSnapshot(String clusterName, String snapshotName)
focal_class.full_signature: @Override public Snapshot getSnapshot(String clusterName, String snapshotName)
focal_class.identifier: getSnapshot
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, String snapshotName)
focal_class.return: Snapshot
focal_class.signature: Snapshot getSnapshot(String clusterName, String snapshotName)
focal_class.class_method_signature: PostgresStorage.getEventSubscriptions()
focal_class.full_signature: @Override public Collection<DiagEventSubscription> getEventSubscriptions()
focal_class.identifier: getEventSubscriptions
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<DiagEventSubscription>
focal_class.signature: Collection<DiagEventSubscription> getEventSubscriptions()
focal_class.class_method_signature: PostgresStorage.getEventSubscriptions(String clusterName)
focal_class.full_signature: @Override public Collection<DiagEventSubscription> getEventSubscriptions(String clusterName)
focal_class.identifier: getEventSubscriptions
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName)
focal_class.return: Collection<DiagEventSubscription>
focal_class.signature: Collection<DiagEventSubscription> getEventSubscriptions(String clusterName)
focal_class.class_method_signature: PostgresStorage.getEventSubscription(UUID id)
focal_class.full_signature: @Override public DiagEventSubscription getEventSubscription(UUID id)
focal_class.identifier: getEventSubscription
focal_class.modifiers: @Override public
focal_class.parameters: (UUID id)
focal_class.return: DiagEventSubscription
focal_class.signature: DiagEventSubscription getEventSubscription(UUID id)
focal_class.class_method_signature: PostgresStorage.addEventSubscription(DiagEventSubscription subscription)
focal_class.full_signature: @Override public DiagEventSubscription addEventSubscription(DiagEventSubscription subscription)
focal_class.identifier: addEventSubscription
focal_class.modifiers: @Override public
focal_class.parameters: (DiagEventSubscription subscription)
focal_class.return: DiagEventSubscription
focal_class.signature: DiagEventSubscription addEventSubscription(DiagEventSubscription subscription)
focal_class.class_method_signature: PostgresStorage.deleteEventSubscription(UUID id)
focal_class.full_signature: @Override public boolean deleteEventSubscription(UUID id)
focal_class.identifier: deleteEventSubscription
focal_class.modifiers: @Override public
focal_class.parameters: (UUID id)
focal_class.return: boolean
focal_class.signature: boolean deleteEventSubscription(UUID id)
focal_class.class_method_signature: PostgresStorage.takeLead(UUID leaderId)
focal_class.full_signature: @Override public boolean takeLead(UUID leaderId)
focal_class.identifier: takeLead
focal_class.modifiers: @Override public
focal_class.parameters: (UUID leaderId)
focal_class.return: boolean
focal_class.signature: boolean takeLead(UUID leaderId)
focal_class.class_method_signature: PostgresStorage.takeLead(UUID leaderId, int ttl)
focal_class.full_signature: @Override public boolean takeLead(UUID leaderId, int ttl)
focal_class.identifier: takeLead
focal_class.modifiers: @Override public
focal_class.parameters: (UUID leaderId, int ttl)
focal_class.return: boolean
focal_class.signature: boolean takeLead(UUID leaderId, int ttl)
focal_class.class_method_signature: PostgresStorage.takeLead(UUID leaderId, Duration ttl)
focal_class.full_signature: private boolean takeLead(UUID leaderId, Duration ttl)
focal_class.identifier: takeLead
focal_class.modifiers: private
focal_class.parameters: (UUID leaderId, Duration ttl)
focal_class.return: boolean
focal_class.signature: boolean takeLead(UUID leaderId, Duration ttl)
focal_class.class_method_signature: PostgresStorage.renewLead(UUID leaderId)
focal_class.full_signature: @Override public boolean renewLead(UUID leaderId)
focal_class.identifier: renewLead
focal_class.modifiers: @Override public
focal_class.parameters: (UUID leaderId)
focal_class.return: boolean
focal_class.signature: boolean renewLead(UUID leaderId)
focal_class.class_method_signature: PostgresStorage.renewLead(UUID leaderId, int ttl)
focal_class.full_signature: @Override public boolean renewLead(UUID leaderId, int ttl)
focal_class.identifier: renewLead
focal_class.modifiers: @Override public
focal_class.parameters: (UUID leaderId, int ttl)
focal_class.return: boolean
focal_class.signature: boolean renewLead(UUID leaderId, int ttl)
focal_class.class_method_signature: PostgresStorage.getLeaders()
focal_class.full_signature: @Override public List<UUID> getLeaders()
focal_class.identifier: getLeaders
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: List<UUID>
focal_class.signature: List<UUID> getLeaders()
focal_class.class_method_signature: PostgresStorage.releaseLead(UUID leaderId)
focal_class.full_signature: @Override public void releaseLead(UUID leaderId)
focal_class.identifier: releaseLead
focal_class.modifiers: @Override public
focal_class.parameters: (UUID leaderId)
focal_class.return: void
focal_class.signature: void releaseLead(UUID leaderId)
focal_class.class_method_signature: PostgresStorage.saveHeartbeat()
focal_class.full_signature: @Override public void saveHeartbeat()
focal_class.identifier: saveHeartbeat
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void saveHeartbeat()
focal_class.class_method_signature: PostgresStorage.countRunningReapers()
focal_class.full_signature: @Override public int countRunningReapers()
focal_class.identifier: countRunningReapers
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int countRunningReapers()
focal_class.class_method_signature: PostgresStorage.storeNodeMetrics(UUID runId, NodeMetrics nodeMetrics)
focal_class.full_signature: @Override public void storeNodeMetrics(UUID runId, NodeMetrics nodeMetrics)
focal_class.identifier: storeNodeMetrics
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, NodeMetrics nodeMetrics)
focal_class.return: void
focal_class.signature: void storeNodeMetrics(UUID runId, NodeMetrics nodeMetrics)
focal_class.class_method_signature: PostgresStorage.getNodeMetrics(UUID runId)
focal_class.full_signature: @Override public Collection<NodeMetrics> getNodeMetrics(UUID runId)
focal_class.identifier: getNodeMetrics
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId)
focal_class.return: Collection<NodeMetrics>
focal_class.signature: Collection<NodeMetrics> getNodeMetrics(UUID runId)
focal_class.class_method_signature: PostgresStorage.getNodeMetrics(UUID runId, String node)
focal_class.full_signature: @Override public Optional<NodeMetrics> getNodeMetrics(UUID runId, String node)
focal_class.identifier: getNodeMetrics
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, String node)
focal_class.return: Optional<NodeMetrics>
focal_class.signature: Optional<NodeMetrics> getNodeMetrics(UUID runId, String node)
focal_class.class_method_signature: PostgresStorage.deleteNodeMetrics(UUID runId, String node)
focal_class.full_signature: @Override public void deleteNodeMetrics(UUID runId, String node)
focal_class.identifier: deleteNodeMetrics
focal_class.modifiers: @Override public
focal_class.parameters: (UUID runId, String node)
focal_class.return: void
focal_class.signature: void deleteNodeMetrics(UUID runId, String node)
focal_class.class_method_signature: PostgresStorage.purgeNodeMetrics()
focal_class.full_signature: @Override public void purgeNodeMetrics()
focal_class.identifier: purgeNodeMetrics
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void purgeNodeMetrics()
focal_class.class_method_signature: PostgresStorage.getNextFreeSegmentForRanges(
        UUID runId,
        Optional<RingRange> parallelRange,
        List<RingRange> ranges)
focal_class.full_signature: @Override public Optional<RepairSegment> getNextFreeSegmentForRanges(
        UUID runId,
        Optional<RingRange> parallelRange,
        List<RingRange> ranges)
focal_class.identifier: getNextFreeSegmentForRanges
focal_class.modifiers: @Override public
focal_class.parameters: (
        UUID runId,
        Optional<RingRange> parallelRange,
        List<RingRange> ranges)
focal_class.return: Optional<RepairSegment>
focal_class.signature: Optional<RepairSegment> getNextFreeSegmentForRanges(
        UUID runId,
        Optional<RingRange> parallelRange,
        List<RingRange> ranges)
focal_class.class_method_signature: PostgresStorage.storeMetric(GenericMetric metric)
focal_class.full_signature: @Override public void storeMetric(GenericMetric metric)
focal_class.identifier: storeMetric
focal_class.modifiers: @Override public
focal_class.parameters: (GenericMetric metric)
focal_class.return: void
focal_class.signature: void storeMetric(GenericMetric metric)
focal_class.class_method_signature: PostgresStorage.getMetrics(
        String clusterName,
        Optional<String> host,
        String metricDomain,
        String metricType,
        long since)
focal_class.full_signature: @Override public List<GenericMetric> getMetrics(
        String clusterName,
        Optional<String> host,
        String metricDomain,
        String metricType,
        long since)
focal_class.identifier: getMetrics
focal_class.modifiers: @Override public
focal_class.parameters: (
        String clusterName,
        Optional<String> host,
        String metricDomain,
        String metricType,
        long since)
focal_class.return: List<GenericMetric>
focal_class.signature: List<GenericMetric> getMetrics(
        String clusterName,
        Optional<String> host,
        String metricDomain,
        String metricType,
        long since)
focal_class.class_method_signature: PostgresStorage.purgeMetrics()
focal_class.full_signature: @Override public void purgeMetrics()
focal_class.identifier: purgeMetrics
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void purgeMetrics()
focal_class.class_method_signature: PostgresStorage.storeOperations(String clusterName, OpType operationType, String host, String operationsJson)
focal_class.full_signature: @Override public void storeOperations(String clusterName, OpType operationType, String host, String operationsJson)
focal_class.identifier: storeOperations
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, OpType operationType, String host, String operationsJson)
focal_class.return: void
focal_class.signature: void storeOperations(String clusterName, OpType operationType, String host, String operationsJson)
focal_class.class_method_signature: PostgresStorage.listOperations(String clusterName, OpType operationType, String host)
focal_class.full_signature: @Override public String listOperations(String clusterName, OpType operationType, String host)
focal_class.identifier: listOperations
focal_class.modifiers: @Override public
focal_class.parameters: (String clusterName, OpType operationType, String host)
focal_class.return: String
focal_class.signature: String listOperations(String clusterName, OpType operationType, String host)
focal_class.class_method_signature: PostgresStorage.purgeNodeOperations()
focal_class.full_signature: @Override public void purgeNodeOperations()
focal_class.identifier: purgeNodeOperations
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void purgeNodeOperations()
focal_class.class_method_signature: PostgresStorage.beat()
focal_class.full_signature: private void beat()
focal_class.identifier: beat
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void beat()
focal_class.class_method_signature: PostgresStorage.deleteOldReapers()
focal_class.full_signature: private void deleteOldReapers()
focal_class.identifier: deleteOldReapers
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void deleteOldReapers()
focal_class.class_method_signature: PostgresStorage.insertGenericMetricSourceNode(GenericMetric metric)
focal_class.full_signature: private void insertGenericMetricSourceNode(GenericMetric metric)
focal_class.identifier: insertGenericMetricSourceNode
focal_class.modifiers: private
focal_class.parameters: (GenericMetric metric)
focal_class.return: void
focal_class.signature: void insertGenericMetricSourceNode(GenericMetric metric)
focal_class.class_method_signature: PostgresStorage.getExpirationTime(Duration timeout)
focal_class.full_signature: private static Instant getExpirationTime(Duration timeout)
focal_class.identifier: getExpirationTime
focal_class.modifiers: private static
focal_class.parameters: (Duration timeout)
focal_class.return: Instant
focal_class.signature: Instant getExpirationTime(Duration timeout)
focal_class.class_method_signature: PostgresStorage.segmentIsWithinRange(RepairSegment segment, RingRange range)
focal_class.full_signature: private static boolean segmentIsWithinRange(RepairSegment segment, RingRange range)
focal_class.identifier: segmentIsWithinRange
focal_class.modifiers: private static
focal_class.parameters: (RepairSegment segment, RingRange range)
focal_class.return: boolean
focal_class.signature: boolean segmentIsWithinRange(RepairSegment segment, RingRange range)
focal_class.class_method_signature: PostgresStorage.withinRange(RepairSegment segment, Optional<RingRange> range)
focal_class.full_signature: private static boolean withinRange(RepairSegment segment, Optional<RingRange> range)
focal_class.identifier: withinRange
focal_class.modifiers: private static
focal_class.parameters: (RepairSegment segment, Optional<RingRange> range)
focal_class.return: boolean
focal_class.signature: boolean withinRange(RepairSegment segment, Optional<RingRange> range)
focal_method.body: @Override
    public void saveHeartbeat() {
      beat();
      deleteOldReapers();
    }
focal_method.class_method_signature: PostgresStorage.saveHeartbeat()
focal_method.full_signature: @Override public void saveHeartbeat()
focal_method.identifier: saveHeartbeat
focal_method.invocations: beat deleteOldReapers
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void saveHeartbeat()