crossplane
/
function-sdk-java
mirror of https://github.com/crossplane/function-sdk-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cleanup naming ved using autoregister functionality 

Signed-off-by: Knut-Erik Johnsen <abstract@knut-erik.org>
This commit is contained in:
Knut-Erik Johnsen 2024-06-24 23:21:51 +02:00
parent 99e3aae5d1
commit 064fa05647
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
crossplane-function-springboot-starter/src/main/java/io/crossplane/compositefunctions/starter/registration/CrossplaneCompositeResourceService.java
View File

@ -25,15 +25,16 @@ public class CrossplaneCompositeResourceService {
public static <T extends CustomResource<?, Void>> void registerOrUpdateCompositeResource(T functionDefinition,
boolean addReadyFunction,
public static <T extends CustomResource<?, Void>> void registerOrUpdateCompositeResource(String functionName,
List<String> additionalFunctions,
T functionDefinition,
KubernetesClient kubernetesClient) {
CompositeResourceDefinition compositeResourceDefinition = createCompositeResourceDefinition(functionDefinition);
registerOrUpdateCompositeResourceDefinition(compositeResourceDefinition, kubernetesClient);
Composition composition = createCompositionDefinition(functionDefinition, addReadyFunction);
Composition composition = createCompositionDefinition(functionName, additionalFunctions, functionDefinition);
registerOrUpdateCompositeResourceDefinition(composition, kubernetesClient);
@ -106,11 +107,13 @@ public class CrossplaneCompositeResourceService {
}
}
private static <T extends CustomResource<?, Void>> Composition createCompositionDefinition(T functionDefinition, boolean addReadyFunction) {
private static <T extends CustomResource<?, Void>> Composition createCompositionDefinition(
String functionName, List<String> additionalFunctions,
T functionDefinition) {
Composition composition = new Composition();
composition.setMetadata(CrossplaneMetadataBuilder.createMetadata("kalypso-" + functionDefinition.getKind().toLowerCase() + "-composition"));
composition.setMetadata(CrossplaneMetadataBuilder.createMetadata(functionDefinition.getKind().toLowerCase() + "-composition"));
CompositionSpec compositionSpec = new CompositionSpec();
CompositeTypeRef compositeTypeRef = new CompositeTypeRef();
@ -122,11 +125,10 @@ public class CrossplaneCompositeResourceService {
List<Pipeline> pipelineList = new ArrayList<>();
pipelineList.add(createPipeline("kalypso-" + functionDefinition.getKind().toLowerCase() + "-function"));
pipelineList.add(createPipeline(functionName));
additionalFunctions.forEach(s -> pipelineList.add(createPipeline(s)));
if (addReadyFunction) {
pipelineList.add(createPipeline("kalypso-ready-function"));
}
compositionSpec.setPipeline(pipelineList);
composition.setSpec(compositionSpec);
return composition;