mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/DataFormatAdapter.java (23 lines): - line 477: // TODO job specific migration config is not supported, migration config will be at cluster level - line 608: // TODO need to wire migration config here so it can get persisted - line 629: // TODO need to wire migration config here so it can get persisted - line 774: // TODO Auto-generated method stub - line 781: // TODO Auto-generated method stub - line 788: // TODO Auto-generated method stub - line 794: // TODO Auto-generated method stub - line 800: // TODO Auto-generated method stub - line 807: // TODO Auto-generated method stub - line 814: // TODO Auto-generated method stub - line 820: // TODO Auto-generated method stub - line 826: // TODO Auto-generated method stub - line 832: // TODO Auto-generated method stub - line 838: // TODO Auto-generated method stub - line 844: // TODO Auto-generated method stub - line 850: // TODO Auto-generated method stub - line 856: // TODO Auto-generated method stub - line 862: // TODO Auto-generated method stub - line 868: // TODO Auto-generated method stub - line 874: // TODO Auto-generated method stub - line 880: // TODO Auto-generated method stub - line 886: // TODO Auto-generated method stub - line 892: // TODO Auto-generated method stub mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/JobClusterActor.java (7 lines): - line 657: // TODO getSender().tell(); - line 799: // TODO (p1): support scale rules creation during job cluster creation. - line 816: // TODO: handle case when job cluster exists in store but Job cluster actor is not running - line 825: // TODO: send PoisonPill to self if job cluster was not created ? Return'ing for now, - line 2067: // TODO make part of config - line 2320: //TODO validate the migration config json - line 2436: // TODO relaunch actor ? mantis-runtime-loader/src/main/java/io/mantisrx/runtime/loader/cgroups/ProcFileReader.java (2 lines): - line 75: // TODO: consider moving to read pointer, but for now traceview says - line 180: // TODO: refactor into something like IntegralToString mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/CustomizedAutoAckTaggingStage.java (2 lines): - line 118: // TODO DynamicGauge.set("manits.source.timelag", (now - latestTimeStamp.get())); - line 123: // TODO DynamicCounter.increment("mantis.source.premapping.failed", "mantisJobName", jobName); mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/MantisEventAggregator.java (2 lines): - line 109: "origin", // TODO: Get origin from context. - line 192: "origin", // TODO: Get origin from context. mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/mantisapi/DefaultMantisApiClient.java (2 lines): - line 81: // TODO: handle redirects - line 112: // TODO: handle redirects mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/clutch/experimental/MantisClutchConfigurationSelector.java (2 lines): - line 112: // TODO: Do we want to reset sketches, we need at least one day's values - line 168: // TODO: How do we ensure we're not just always operating in a tight range? mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/writer/config/WriterProperties.java (2 lines): - line 42: // TODO: Change to long. - line 52: // TODO: Change to long. mantis-runtime/src/main/java/io/mantisrx/runtime/sink/ServerSentEventRequestHandler.java (2 lines): - line 132: //TODO Below condition would be always false during if condition. - line 219: //TODO Note: Code logic can be improved here. mantis-control-plane/mantis-control-plane-core/src/main/java/io/mantisrx/server/master/resourcecluster/TaskExecutorRegistration.java (2 lines): - line 76: * TODO make this field non-null once no back-compat required. - line 186: // TODO: remove this value. mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/WorkerExecutionOperationsNetworkStage.java (2 lines): - line 538: // TODO remove this line to set heartbeat payloads when master has upgraded to having jobMaster design - line 543: // TODO remove this line to set heartbeat payloads when master has upgraded to having jobMaster design mantis-common/src/main/java/io/mantisrx/common/metrics/netty/MantisNettyEventsListenerFactory.java (2 lines): - line 82: // TODO Auto-generated method stub - line 89: // TODO Auto-generated method stub mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerAssignments.java (1 line): - line 26: * TODO: Duplicate WorkerAssignments from mantis-server-core lib, move to a common proto lib mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterActor.java (1 line): - line 361: // TODO: implement rate control to confirm we are not overwhelming the TEs with excessive caching requests mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/ResourceUsagePayloadSetter.java (1 line): - line 241: double readBw = (usage.getNetworkReadBytes() - prev_bytes_read) / elapsedInSecs; // TODO check if byteCounts are already rate counts mantis-control-plane/mantis-control-plane-store/mantis-control-plane-store-dynamodb/src/main/java/io/mantisrx/server/master/store/DynamoStore.java (1 line): - line 61: // TODO should we just create the table right here? mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobDefinition.java (1 line): - line 263: // // TODO make immutable mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v1/AdminMasterRoute.java (1 line): - line 137: //TODO: hardcode some V1 admin master info, this should be cleaned up once v0 apis mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/pipeline/HttpEventChannel.java (1 line): - line 102: // TODO: Channel#setAttribute(future), complete (or exceptionally) in HttpEventChannelHandler. mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/MasterMain.java (1 line): - line 148: // TODO who watches actors created at this level? mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/v0/JobRoute.java (1 line): - line 287: // TODO path("updateScalingPolicy", () -> mantis-connectors/mantis-connector-kafka/src/main/java/io/mantisrx/connector/kafka/source/KafkaSource.java (1 line): - line 298: // TODO provide a hook for the user to add handling for messages that could not be processed mantis-rxcontrol/src/main/java/io/mantisrx/control/controllers/ControlLoop.java (1 line): - line 60: // TODO: How do I get a zero if nothing came through? mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/ServeGroupedObservable.java (1 line): - line 61: // TODO this should be pushed into builder, default is 0 buffer mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPreProcessor.java (1 line): - line 57: // TODO - DynamicGauge.set("activeQueries", BasicTagList.of("mantisJobId", context.getJobId(), mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobDiscoveryRouteHandlerAkkaImpl.java (1 line): - line 134: // TODO For future a more explicit key in the payload saying the job is completed. mantis-connectors/mantis-connector-job-source/src/main/java/io/mantisrx/connector/job/source/JobSource.java (1 line): - line 339: * TODO: Currently mutates the list, which isn't problematic here, but it would be prudent to clean this up. mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/MantisEventPublisher.java (1 line): - line 69: // TODO - propagate a Promise of PublishStatus with the Event and update status async after network send to Mantis mantis-common/src/main/java/io/mantisrx/common/network/RoundRobinRouter.java (1 line): - line 81: // TODO should completeAll and errorAll de-register? mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/slotting/ConsistentHashing.java (1 line): - line 90: // TODO should completeAll and errorAll de-register? mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/WorkerMetricHandler.java (1 line): - line 261: private static final int metricsIntervalSeconds = 30; // TODO make it configurable mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/scheduler/JobMessageRouterImpl.java (1 line): - line 33: /* TODO - need a return value to indicate to scheduling service if the worker was marked Launched successfully mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/utils/CaffeineMetrics.java (1 line): - line 34: // TODO make totalLoadTime a Timer mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/SymptomDetector.java (1 line): - line 28: * TODO: This is completely experimental, not currently in use. mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/JobSchedulingInfo.java (1 line): - line 26: * TODO: Duplicate JobSchedulingInfo from mantis-server-core lib, move to a common proto lib mantis-publish/mantis-publish-netty/src/main/java/io/mantisrx/publish/netty/transmitters/RoundRobinEventTransmitter.java (1 line): - line 81: // TODO: propagate feedback - check for Retryable or NonRetryable Exception. mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/MantisJobState.java (1 line): - line 24: * TODO: Duplicate MantisJobState from mantis-runtime lib, move to a common proto lib mantis-runtime-executor/src/main/java/io/mantisrx/server/worker/RuntimeTaskImpl.java (1 line): - line 184: // [TODO:andyz] disable noOp publisher for now. Need to fix the full publisher injection. mantis-rxcontrol/src/main/java/io/mantisrx/control/clutch/ClutchExperimental.java (1 line): - line 94: // TODO: Significant improvements to gain computation can likely be made. mantis-common/src/main/java/io/reactivx/mantis/operators/OperatorGroupBy.java (1 line): - line 343: private final Queue buffer = new ConcurrentLinkedQueue(); // TODO should this be lazily created? mantis-publish/mantis-publish-core/src/main/java/io/mantisrx/publish/internal/discovery/proto/WorkerHost.java (1 line): - line 26: * TODO: Duplicate WorkerHost from mantis-server-core lib, move to a common proto lib mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/server/master/domain/JobClusterConfig.java (1 line): - line 153: // TODO add validity checks for SchedulingInfo, MachineDescription etc mantis-runtime-autoscaler-api/src/main/java/io/mantisrx/server/worker/jobmaster/control/utils/Derivative.java (1 line): - line 27: // TODO: What if this is uninitialized? mantis-runtime/src/main/java/io/mantisrx/runtime/parameter/SourceJobParameters.java (1 line): - line 222: * TODO: Currently mutates the list, which isn't problematic here, but it would be prudent to clean this up. mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/jobcluster/job/JobActor.java (1 line): - line 2186: // TODO: add termination once confirmed the actual corruption scenario. mantis-common/src/main/java/io/reactivx/mantis/operators/GroupedObservableUtils.java (1 line): - line 33: // TODO can we do without this? mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/slotting/RoundRobin.java (1 line): - line 57: // TODO should completeAll and errorAll de-register? mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/api/akka/route/handlers/JobRouteHandler.java (1 line): - line 33: //TODO CompletionStage updateScalingPolicy(final JobClusterManagerProto.Update request); mantis-remote-observable/src/main/java/io/reactivex/mantis/remote/observable/WriteBytesObserver.java (1 line): - line 68: // TODO add callback here to notify when complete even fails mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/IJobClustersManager.java (1 line): - line 37: * [Deprecated] TODO: remove this interface mantis-source-jobs/mantis-source-job-kafka/src/main/java/io/mantisrx/sourcejob/kafka/sink/QueryRequestPostProcessor.java (1 line): - line 54: // TODO - DynamicGauge.set("activeQueries", BasicTagList.of("mantisJobId", context.getJobId(), mantis-control-plane/mantis-control-plane-server/src/main/java/io/mantisrx/master/resourcecluster/ResourceClusterScalerActor.java (1 line): - line 413: // TODO: probably we should use current time mantis-connectors/mantis-connector-iceberg/src/main/java/io/mantisrx/connector/iceberg/sink/committer/config/CommitterProperties.java (1 line): - line 32: // TODO: Change to long.