Skip to content

Commit 2f9c0f5

Browse files
committed
add clientObjects and change Boolean to boolean
1 parent b20ec58 commit 2f9c0f5

13 files changed

+1190
-1160
lines changed

src/main/java/com/uber/cadence/entities/DescribeDomainResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,5 +22,5 @@ public class DescribeDomainResponse {
2222
private DomainConfiguration configuration;
2323
private DomainReplicationConfiguration replicationConfiguration;
2424
private long failoverVersion;
25-
private Boolean isGlobalDomain;
25+
private boolean isGlobalDomain;
2626
}

src/main/java/com/uber/cadence/entities/DomainConfiguration.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
@Data
2020
public class DomainConfiguration {
2121
private int workflowExecutionRetentionPeriodInDays;
22-
private Boolean emitMetric;
22+
private boolean emitMetric;
2323
private IsolationGroupConfiguration isolationGroups;
2424
private AsyncWorkflowConfiguration asyncWorkflowConfiguration;
2525
private BadBinaries badBinaries;

src/main/java/com/uber/cadence/entities/FailoverInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,5 +23,5 @@ public class FailoverInfo {
2323
private long failoverStartTimestamp;
2424
private long failoverExpireTimestamp;
2525
private int completedShardCount;
26-
private List<int> pendingShards;
26+
private List<Integer> pendingShards;
2727
}

src/main/java/com/uber/cadence/entities/RequestCancelWorkflowExecutionRequest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,4 +22,6 @@ public class RequestCancelWorkflowExecutionRequest {
2222
private WorkflowExecution workflowExecution;
2323
private String requestId;
2424
private String identity;
25+
private String firstExecutionRunID;
26+
private String cause;
2527
}

src/main/java/com/uber/cadence/entities/SignalWithStartWorkflowExecutionRequest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@ public class SignalWithStartWorkflowExecutionRequest {
3333
private WorkflowIdReusePolicy workflowIdReusePolicy;
3434
private String cronSchedule;
3535
private int delayStartSeconds;
36+
private int jitterStartSeconds;
3637
private String identity;
3738
private String signalName;
3839
private byte[] signalInput;

src/main/java/com/uber/cadence/entities/StartWorkflowExecutionRequest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ public class StartWorkflowExecutionRequest {
3131
private SearchAttributes searchAttributes;
3232
private Header header;
3333
private int delayStartSeconds;
34+
private int jitterStartSeconds;
3435
private RetryPolicy retryPolicy;
3536
private String cronSchedule;
3637
private String identity;

src/main/java/com/uber/cadence/entities/TerminateWorkflowExecutionRequest.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,4 +23,5 @@ public class TerminateWorkflowExecutionRequest {
2323
private String reason;
2424
private byte[] details;
2525
private String identity;
26+
private String firstExecutionRunID;
2627
}

src/main/java/com/uber/cadence/entities/UpdateDomainResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,5 +22,5 @@ public class UpdateDomainResponse {
2222
private DomainConfiguration configuration;
2323
private DomainReplicationConfiguration replicationConfiguration;
2424
private long failoverVersion;
25-
private Boolean isGlobalDomain;
25+
private boolean isGlobalDomain;
2626
}

src/main/java/com/uber/cadence/entities/WorkflowExecutionInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,5 +32,5 @@ public class WorkflowExecutionInfo {
3232
private SearchAttributes searchAttributes;
3333
private ResetPoints autoResetPoints;
3434
private String taskList;
35-
private Boolean isCron;
35+
private boolean isCron;
3636
}

src/main/java/com/uber/cadence/internal/compatibility/proto/mappers/RequestMapper.java

Lines changed: 17 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -172,6 +172,12 @@ public static RequestCancelWorkflowExecutionRequest requestCancelWorkflowExecuti
172172
if (t.getIdentity() != null) {
173173
builder.setIdentity(t.getIdentity());
174174
}
175+
if (t.getFirstExecutionRunID() != null) {
176+
builder.setFirstExecutionRunId(t.getFirstExecutionRunID());
177+
}
178+
if (t.getCause() != null) {
179+
builder.setCause(t.getCause());
180+
}
175181
return builder.build();
176182
}
177183

@@ -451,6 +457,9 @@ public static SignalWithStartWorkflowExecutionRequest signalWithStartWorkflowExe
451457
if (t.getDelayStartSeconds() > 0) {
452458
builder.setDelayStart(secondsToDuration(t.getDelayStartSeconds()));
453459
}
460+
if (t.getJitterStartSeconds() > 0) {
461+
builder.setJitterStart(secondsToDuration(t.getJitterStartSeconds()));
462+
}
454463

455464
if (t.getIdentity() != null) {
456465
builder.setIdentity(t.getIdentity());
@@ -521,7 +530,8 @@ public static StartWorkflowExecutionRequest startWorkflowExecutionRequest(
521530
.setMemo(memo(t.getMemo()))
522531
.setSearchAttributes(searchAttributes(t.getSearchAttributes()))
523532
.setHeader(header(t.getHeader()))
524-
.setDelayStart(secondsToDuration(t.getDelayStartSeconds()));
533+
.setDelayStart(secondsToDuration(t.getDelayStartSeconds()))
534+
.setJitterStart(secondsToDuration(t.getJitterStartSeconds()));
525535
if (t.getRetryPolicy() != null) {
526536
request.setRetryPolicy(retryPolicy(t.getRetryPolicy()));
527537
}
@@ -561,6 +571,9 @@ public static TerminateWorkflowExecutionRequest terminateWorkflowExecutionReques
561571
if (t.getIdentity() != null) {
562572
builder.setIdentity(t.getIdentity());
563573
}
574+
if (t.getFirstExecutionRunID() != null) {
575+
builder.setFirstExecutionRunId(t.getFirstExecutionRunID());
576+
}
564577
return builder.build();
565578
}
566579

@@ -780,7 +793,7 @@ public static UpdateDomainRequest updateDomainRequest(
780793
if (configuration != null) {
781794
if (configuration.getWorkflowExecutionRetentionPeriodInDays() > 0) {
782795
request.setWorkflowExecutionRetentionPeriod(
783-
daysToDuration(configuration.getWorkflowExecutionRetentionPeriodInDays()));
796+
daysToDuration(configuration.getWorkflowExecutionRetentionPeriodInDays()));
784797
fields.add(DomainUpdateRetentionPeriodField);
785798
}
786799
// if t.EmitMetric != null {} - DEPRECATED
@@ -806,7 +819,8 @@ public static UpdateDomainRequest updateDomainRequest(
806819
fields.add(DomainUpdateVisibilityArchivalURIField);
807820
}
808821
}
809-
com.uber.cadence.entities.DomainReplicationConfiguration replicationConfiguration = t.getReplicationConfiguration();
822+
com.uber.cadence.entities.DomainReplicationConfiguration replicationConfiguration =
823+
t.getReplicationConfiguration();
810824
if (replicationConfiguration != null) {
811825
if (replicationConfiguration.getActiveClusterName() != null) {
812826
request.setActiveClusterName(replicationConfiguration.getActiveClusterName());

src/main/java/com/uber/cadence/internal/compatibility/proto/mappers/ResponseMapper.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -386,7 +386,7 @@ public static com.uber.cadence.entities.DescribeDomainResponse describeDomainRes
386386
clusterReplicationConfigurationArrayFromProto(t.getDomain().getClustersList()));
387387

388388
response.setFailoverVersion(t.getDomain().getFailoverVersion());
389-
response.setIsGlobalDomain(t.getDomain().getIsGlobalDomain());
389+
response.setGlobalDomain(t.getDomain().getIsGlobalDomain());
390390
return response;
391391
}
392392

@@ -461,7 +461,7 @@ public static com.uber.cadence.entities.UpdateDomainResponse updateDomainRespons
461461
domainReplicationConfiguration.setClusters(
462462
clusterReplicationConfigurationArrayFromProto(t.getDomain().getClustersList()));
463463
updateDomainResponse.setFailoverVersion(t.getDomain().getFailoverVersion());
464-
updateDomainResponse.setIsGlobalDomain(t.getDomain().getIsGlobalDomain());
464+
updateDomainResponse.setGlobalDomain(t.getDomain().getIsGlobalDomain());
465465
return updateDomainResponse;
466466
}
467467

src/main/java/com/uber/cadence/internal/compatibility/proto/mappers/TypeMapper.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -615,7 +615,7 @@ static com.uber.cadence.entities.WorkflowExecutionInfo workflowExecutionInfo(
615615
res.setSearchAttributes(searchAttributes(t.getSearchAttributes()));
616616
res.setAutoResetPoints(resetPoints(t.getAutoResetPoints()));
617617
res.setTaskList(t.getTaskList());
618-
res.setIsCron(t.getIsCron());
618+
res.setCron(t.getIsCron());
619619
return res;
620620
}
621621

@@ -764,7 +764,7 @@ static com.uber.cadence.entities.DescribeDomainResponse describeDomainResponseDo
764764
domainReplicationConfiguration.setClusters(
765765
clusterReplicationConfigurationArrayFromProto(t.getClustersList()));
766766
res.setFailoverVersion(t.getFailoverVersion());
767-
res.setIsGlobalDomain(t.getIsGlobalDomain());
767+
res.setGlobalDomain(t.getIsGlobalDomain());
768768

769769
return res;
770770
}

0 commit comments

Comments
 (0)