Skip to content
Merged
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
20 changes: 3 additions & 17 deletions sdk/src/main/java/software/amazon/lambda/durable/InvokeConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -2,26 +2,19 @@
// SPDX-License-Identifier: Apache-2.0
package software.amazon.lambda.durable;

import java.time.Duration;
import software.amazon.lambda.durable.serde.SerDes;

public class InvokeConfig {
private final Duration timeout;
private final SerDes payloadSerDes;
private final SerDes resultSerDes;
private final String tenantId;

public InvokeConfig(Builder builder) {
this.timeout = builder.timeout;
this.payloadSerDes = builder.payloadSerDes;
this.resultSerDes = builder.resultSerDes;
this.tenantId = builder.tenantId;
}

public Duration timeout() {
return this.timeout;
}

public SerDes payloadSerDes() {
return this.payloadSerDes;
}
Expand All @@ -35,22 +28,20 @@ public String tenantId() {
}

public static Builder builder() {
return new Builder(null, null, null, null);
return new Builder(null, null, null);
}

public Builder toBuilder() {
return new Builder(timeout, payloadSerDes, resultSerDes, tenantId);
return new Builder(payloadSerDes, resultSerDes, tenantId);
}

/** Builder for creating InvokeConfig instances. */
public static class Builder {
private Duration timeout;
private SerDes payloadSerDes;
private SerDes resultSerDes;
private String tenantId;

private Builder(Duration timeout, SerDes payloadSerDes, SerDes resultSerDes, String tenantId) {
this.timeout = timeout;
private Builder(SerDes payloadSerDes, SerDes resultSerDes, String tenantId) {
this.payloadSerDes = payloadSerDes;
this.resultSerDes = resultSerDes;
this.tenantId = tenantId;
Expand All @@ -61,11 +52,6 @@ public Builder tenantId(String tenantId) {
return this;
}

public Builder timeout(Duration timeout) {
this.timeout = timeout;
return this;
}

/**
* Sets a custom serializer for the invoke operation payload.
*
Expand Down