Skip to content

Commit 26cf79f

Browse files
committed
Tidy Up
1 parent 8ee29e5 commit 26cf79f

File tree

3 files changed

+0
-11
lines changed

3 files changed

+0
-11
lines changed

modules/streams/src/main/java/org/elasticsearch/rest/streams/StreamsPlugin.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,6 @@ public List<ActionHandler> getActions() {
6262

6363
@Override
6464
public List<NamedWriteableRegistry.Entry> getNamedWriteables() {
65-
// TODO: Update to project custom
6665
return List.of(new NamedWriteableRegistry.Entry(Metadata.ProjectCustom.class, StreamsMetadata.TYPE, StreamsMetadata::new));
6766
}
6867
}

modules/streams/src/main/java/org/elasticsearch/rest/streams/logs/LogsStreamsActivationToggleAction.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121

2222
public class LogsStreamsActivationToggleAction {
2323

24-
// TODO: Lookup naming scheme for actions
2524
public static ActionType<AcknowledgedResponse> INSTANCE = new ActionType<>("cluster:admin/streams/logs/toggle");
2625

2726
public static class Request extends AcknowledgedRequest<Request> {

modules/streams/src/main/java/org/elasticsearch/rest/streams/logs/TransportLogsStreamsToggleActivation.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,6 @@ protected void masterOperation(
8080
boolean shouldEnable = request.shouldEnable();
8181
if (shouldEnable != currentlyEnabled) {
8282
StreamsMetadataUpdateTask updateTask = new StreamsMetadataUpdateTask(request, listener, projectId, shouldEnable);
83-
// TODO: Append state to task name (See TransportStartSLMAction)
8483
String taskName = String.format(Locale.ROOT, "enable-streams-logs-[%s]", shouldEnable ? "enable" : "disable");
8584
taskQueue.submitTask(taskName, updateTask, updateTask.timeout());
8685
} else {
@@ -89,14 +88,6 @@ protected void masterOperation(
8988
}
9089
}
9190

92-
private void cleanupActions() {
93-
logger.debug("Cleaning up after disabling logs streams");
94-
}
95-
96-
private void setupActions() {
97-
logger.debug("Setting up logs streams");
98-
}
99-
10091
@Override
10192
protected ClusterBlockException checkBlock(LogsStreamsActivationToggleAction.Request request, ClusterState state) {
10293
return state.blocks().globalBlockedException(ClusterBlockLevel.METADATA_WRITE);

0 commit comments

Comments
 (0)