TimeseriesMigrationService

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total904 of 9040%50 of 500%61612462463636
migratePayloads(TimeseriesContainer, String, InfluxTimeseries, InfluxTimeseriesDataType)2090%140%88484811
lambda$createMigrationTasksForContainers$4(Long)900%60%44212111
runMigrations()670%40%33252511
TimeseriesMigrationService(TimeseriesContainerService, MigrationTaskRepository, InfluxDBConnector, InfluxTimeseriesService, TimeseriesDataPointRepository, PayloadReader, PayloadWriter, CompressionRunner, int, int, int)640%n/a11181811
migrateTask(MigrationTaskEntity)620%40%33191911
getMigrationState()610%60%44181811
getContainerIdsThatDoNotHaveMigrationTaskYet(List)340%n/a11121211
getTimestampOfPayload(String, InfluxTimeseries, InfluxSingleValuedUnaryFunction)270%20%224411
addCompressionTask()230%20%229911
addWriterPoisonPills()210%20%227711
setStateToFinishedAndRemoveErrors(MigrationTaskEntity)200%n/a115511
addCompressionPoisonPills()190%n/a117711
persistError(MigrationTaskEntity, String)180%n/a115511
getExistingContainerIds()170%n/a119911
getMigrationTasks(boolean)150%20%223311
createMigrationTaskForEachContainer()150%n/a115511
setStateToRunning(MigrationTaskEntity)150%n/a114411
compressAllDataPoints()120%n/a115511
doesDatabaseExist(String)120%20%224411
getPayloadReadQueueSize()110%n/a112211
storeTasksInDatabase(List)100%n/a113311
getTimeseries(MigrationTaskEntity)80%n/a112211
getUnfinishedMigrationTasks()80%n/a111111
lambda$getContainerIdsThatDoNotHaveMigrationTaskYet$6(List, Long)80%20%221111
lambda$getMigrationState$1(MigrationTaskEntity)80%20%221111
lambda$getMigrationTasks$0(MigrationTaskEntity)80%20%221111
createMigrationTasksForContainers(List)70%n/a114411
getFirstTimestampOfPayload(String, InfluxTimeseries)60%n/a111111
getLastTimestampOfPayload(String, InfluxTimeseries)60%n/a111111
lambda$getContainerIdsThatDoNotHaveMigrationTaskYet$5(MigrationTaskEntity)40%n/a111111
lambda$getExistingContainerIds$2(TimeseriesContainer)40%n/a111111
getPayloadReadQueue()30%n/a111111
getCompressionTasksQueue()30%n/a111111
getReadWriteLock()30%n/a111111
getPayloadWriteQueue()30%n/a111111
lambda$getExistingContainerIds$3(TimeseriesContainer)30%n/a111111