Skip to content

Commit

Permalink
chore(camel-k): Fix IntegrationSpec in Pipe/KameletBinding model
Browse files Browse the repository at this point in the history
  • Loading branch information
christophd committed Aug 30, 2023
1 parent 0f743bc commit 11b2818
Show file tree
Hide file tree
Showing 4 changed files with 11 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -32,10 +32,10 @@
import org.citrusframework.yaks.camelk.CamelKSettings;
import org.citrusframework.yaks.camelk.jbang.CamelJBangSettings;
import org.citrusframework.yaks.camelk.jbang.ProcessAndOutput;
import org.citrusframework.yaks.camelk.model.IntegrationSpec;
import org.citrusframework.yaks.camelk.model.Pipe;
import org.citrusframework.yaks.camelk.model.PipeList;
import org.citrusframework.yaks.camelk.model.PipeSpec;
import org.citrusframework.yaks.camelk.model.Integration;
import org.citrusframework.yaks.camelk.model.v1alpha1.KameletBinding;
import org.citrusframework.yaks.camelk.model.v1alpha1.KameletBindingList;
import org.citrusframework.yaks.kubernetes.KubernetesSupport;
Expand All @@ -57,7 +57,7 @@ public class CreatePipeAction extends AbstractKameletAction {
private static final Logger LOG = LoggerFactory.getLogger(CreatePipeAction.class);

private final String pipeName;
private final Integration integration;
private final IntegrationSpec integration;
private final PipeSpec.Endpoint source;
private final PipeSpec.Endpoint sink;
private final Resource resource;
Expand Down Expand Up @@ -218,7 +218,7 @@ private void createLocalPipe(Pipe pipe, String name, TestContext context) {
public static final class Builder extends AbstractKameletAction.Builder<CreatePipeAction, Builder> {

private String pipeName;
private Integration integration;
private IntegrationSpec integration;
private PipeSpec.Endpoint source;
private PipeSpec.Endpoint sink;
private Resource resource;
Expand All @@ -234,7 +234,7 @@ public Builder pipe(String pipeName) {
return this;
}

public Builder integration(Integration integration) {
public Builder integration(IntegrationSpec integration) {
this.integration = integration;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ public Pipe() {
public static class Builder {
protected String name;
private int replicas;
private Integration integration;
private IntegrationSpec integration;
private PipeSpec.Endpoint source;
private PipeSpec.Endpoint sink;
private final List<PipeSpec.Endpoint> steps = new ArrayList<>();
Expand All @@ -61,7 +61,7 @@ public Builder name(String name) {
return this;
}

public Builder integration(Integration integration) {
public Builder integration(IntegrationSpec integration) {
this.integration = integration;
return this;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
public class PipeSpec implements KubernetesResource {

@JsonProperty("integration")
private Integration integration;
private IntegrationSpec integration;

@JsonProperty("source")
private Endpoint source;
Expand Down Expand Up @@ -79,11 +79,11 @@ public void setSteps(Endpoint[] steps) {
this.steps = steps;
}

public void setIntegration(Integration integration) {
public void setIntegration(IntegrationSpec integration) {
this.integration = integration;
}

public Integration getIntegration() {
public IntegrationSpec getIntegration() {
return integration;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@
import io.fabric8.kubernetes.model.annotation.Version;
import org.citrusframework.yaks.camelk.CamelKSettings;
import org.citrusframework.yaks.camelk.CamelKSupport;
import org.citrusframework.yaks.camelk.model.Integration;
import org.citrusframework.yaks.camelk.model.IntegrationSpec;
import org.citrusframework.yaks.camelk.model.Pipe;
import org.citrusframework.yaks.camelk.model.PipeSpec;

Expand All @@ -47,7 +47,7 @@ public Builder name(String name) {
return this;
}

public Builder integration(Integration integration) {
public Builder integration(IntegrationSpec integration) {
delegate.integration(integration);
return this;
}
Expand Down

0 comments on commit 11b2818

Please sign in to comment.