Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ protected void validateForReservedState(DeleteRepositoryRequest request, Cluster
ProjectStateRegistry.get(state).reservedStateMetadata(projectResolver.getProjectId()).values(),
reservedStateHandlerName().get(),
modifiedKeys(request),
request.toString()
request::toString
);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ protected void validateForReservedState(Request request, ClusterState state) {
ProjectStateRegistry.get(state).reservedStateMetadata(projectResolver.getProjectId()).values(),
reservedStateHandlerName().get(),
modifiedKeys(request),
request.toString()
request::toString
);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ protected void validateForReservedState(PutComponentTemplateAction.Request reque
ProjectStateRegistry.get(state).reservedStateMetadata(projectResolver.getProjectId()).values(),
reservedStateHandlerName().get(),
modifiedKeys(request),
request.toString()
request::toString
);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -145,7 +145,7 @@ protected void validateForReservedState(Request request, ClusterState state) {
ProjectStateRegistry.get(state).reservedStateMetadata(projectResolver.getProjectId()).values(),
reservedStateHandlerName().get(),
modifiedKeys(request),
request.toString()
request::toString
);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ protected void validateForReservedState(PutPipelineRequest request, ClusterState
ProjectStateRegistry.get(state).reservedStateMetadata(projectResolver.getProjectId()).values(),
reservedStateHandlerName().get(),
modifiedKeys(request),
request.toString()
request::toString
);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ protected void doExecute(Task task, Request request, ActionListener<Response> li
clusterService.state().metadata().reservedStateMetadata().values(),
reservedStateHandlerName().get(),
modifiedKeys(request),
request.toString()
request::toString
);
doExecuteProtected(task, request, listener);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -143,7 +143,7 @@ protected void validateForReservedState(Request request, ClusterState state) {
state.metadata().reservedStateMetadata().values(),
handlerName.get(),
modifiedKeys(request),
request.toString()
request::toString
);
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.function.Supplier;

import static org.elasticsearch.core.Strings.format;

Expand Down Expand Up @@ -53,13 +54,13 @@ default Set<String> modifiedKeys(T request) {
* @param reservedStateMetadata the metadata to check
* @param handlerName the name of the reserved state handler related to this implementation
* @param modified the set of modified keys by the related request
* @param request a string representation of the request for error reporting purposes
* @param requestSupplier a supplier for a string representation of the request for error reporting purposes
*/
default void validateForReservedState(
Collection<ReservedStateMetadata> reservedStateMetadata,
String handlerName,
Set<String> modified,
String request
Supplier<String> requestSupplier
) {
List<String> errors = new ArrayList<>();

Expand All @@ -72,7 +73,7 @@ default void validateForReservedState(

if (errors.isEmpty() == false) {
throw new IllegalArgumentException(
format("Failed to process request [%s] with errors: [%s]", request, String.join(", ", errors))
format("Failed to process request [%s] with errors: [%s]", requestSupplier.get(), String.join(", ", errors))
);
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -963,7 +963,7 @@ public void testTemplatesWithReservedPrefix() throws Exception {
withReservedState.reservedStateMetadata(projectId).values(),
ReservedComposableIndexTemplateAction.NAME,
modifiedKeys,
pr.name()
pr::name
)
).getMessage()
);
Expand All @@ -979,7 +979,7 @@ public void testTemplatesWithReservedPrefix() throws Exception {
withReservedState.reservedStateMetadata(projectId).values(),
ReservedComposableIndexTemplateAction.NAME,
modifiedKeysOK,
prOK.name()
prOK::name
);
}

Expand Down