Skip to content

Commit 959ce4c

Browse files
authored
add internal new entities and mappers (#995)
1 parent 077bb09 commit 959ce4c

File tree

200 files changed

+7461
-1
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

200 files changed

+7461
-1
lines changed

.gitignore

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,4 +13,5 @@ src/main/idls/*
1313
/bin
1414
.classpath
1515
.project
16-
.settings
16+
.settings
17+
.vscode

build.gradle

+5
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,11 @@ dependencies {
7272
compile group: 'com.google.api.grpc', name: 'proto-google-common-protos', version: '2.10.0'
7373
compile group: 'com.google.protobuf', name: 'protobuf-java-util', version: '3.21.9'
7474
compile group: 'com.google.oauth-client', name: 'google-oauth-client', version: '1.35.0'
75+
compile group: 'org.projectlombok', name: 'lombok', version: '1.18.30'
76+
compileOnly 'org.projectlombok:lombok:1.18.30'
77+
annotationProcessor 'org.projectlombok:lombok:1.18.30'
78+
testCompileOnly 'org.projectlombok:lombok:1.18.30'
79+
testAnnotationProcessor 'org.projectlombok:lombok:1.18.30'
7580

7681
implementation 'io.grpc:grpc-netty-shaded:1.54.2'
7782
implementation 'io.grpc:grpc-protobuf:1.54.2'
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package com.uber.cadence.entities;
2+
3+
import lombok.Data;
4+
5+
@Data
6+
public class ActivityLocalDispatchInfo {
7+
private String activityId;
8+
private Long scheduledTimestamp;
9+
private Long startedTimestamp;
10+
private Long scheduledTimestampOfThisAttempt;
11+
private byte[] taskToken;
12+
13+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ActivityTaskCancelRequestedEventAttributes {
21+
private String activityId;
22+
private Long decisionTaskCompletedEventId;
23+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ActivityTaskCanceledEventAttributes {
21+
private byte[] details;
22+
private Long scheduledEventId;
23+
private Long startedEventId;
24+
private Long latestCancelRequestedEventId;
25+
private String identity;
26+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ActivityTaskCompletedEventAttributes {
21+
private byte[] result;
22+
private Long scheduledEventId;
23+
private Long startedEventId;
24+
private String identity;
25+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ActivityTaskFailedEventAttributes {
21+
private String reason;
22+
private byte[] details;
23+
private Long scheduledEventId;
24+
private Long startedEventId;
25+
private String identity;
26+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
18+
import lombok.Data;
19+
20+
@Data
21+
public class ActivityTaskScheduledEventAttributes {
22+
private ActivityType activityType;
23+
private String activityId;
24+
private String domain;
25+
private TaskList taskList;
26+
private byte[] input;
27+
private Integer scheduleToCloseTimeoutSeconds;
28+
private Integer scheduleToStartTimeoutSeconds;
29+
private Integer startToCloseTimeoutSeconds;
30+
private Integer heartbeatTimeoutSeconds;
31+
private Long decisionTaskCompletedEventId;
32+
private RetryPolicy retryPolicy;
33+
private Header header;
34+
private String requestLocalDispatch;
35+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ActivityTaskStartedEventAttributes {
21+
private Long scheduledEventId;
22+
private String identity;
23+
private String requestId;
24+
private Integer attempt;
25+
private String lastFailureReason;
26+
private byte[] lastFailureDetails;
27+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
18+
import lombok.Data;
19+
20+
@Data
21+
public class ActivityTaskTimedOutEventAttributes {
22+
private byte[] details;
23+
private Long scheduledEventId;
24+
private Long startedEventId;
25+
private TimeoutType timeoutType;
26+
private String lastHeartbeatDetails;
27+
private String lastFailureReason;
28+
private byte[] lastFailureDetails;
29+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ActivityType {
21+
private String name;
22+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
package com.uber.cadence.entities;
2+
3+
/**
4+
* ArchivalStatus represents the status of archival for a domain.
5+
*/
6+
public enum ArchivalStatus {
7+
/**
8+
* Archival is disabled.
9+
*/
10+
DISABLED,
11+
12+
/**
13+
* Archival is enabled.
14+
*/
15+
ENABLED
16+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
package com.uber.cadence.entities;
2+
3+
import lombok.Data;
4+
5+
@Data
6+
public class AsyncWorkflowConfiguration {
7+
private boolean enabled;
8+
private Integer prefetchTaskListSize;
9+
private Integer maxConcurrentTaskExecutionSize;
10+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
package com.uber.cadence.entities;
2+
3+
import java.util.Map;
4+
import lombok.Data;
5+
6+
@Data
7+
public class BadBinaries {
8+
private Map<String, BadBinaryInfo> binaries;
9+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
package com.uber.cadence.entities;
2+
3+
import lombok.Data;
4+
5+
@Data
6+
public class BadBinaryInfo {
7+
private String reason;
8+
private String operator;
9+
private Long createdTimeNano;
10+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
package com.uber.cadence.entities;
2+
3+
public enum CancelExternalWorkflowExecutionFailedCause {
4+
UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION,
5+
WORKFLOW_ALREADY_COMPLETED,
6+
WORKFLOW_ALREADY_CANCELED,
7+
WORKFLOW_ALREADY_TERMINATED,
8+
WORKFLOW_ALREADY_TIMED_OUT,
9+
WORKFLOW_ALREADY_FAILED,
10+
WORKFLOW_ALREADY_CONTINUED_AS_NEW
11+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
package com.uber.cadence.entities;
2+
3+
import lombok.Data;
4+
5+
@Data
6+
public class CancelTimerDecisionAttributes {
7+
private String timerId;
8+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class CancelTimerFailedEventAttributes {
21+
private String timerId;
22+
private String cause;
23+
private Long decisionTaskCompletedEventId;
24+
private String identity;
25+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
package com.uber.cadence.entities;
2+
3+
import lombok.Data;
4+
5+
@Data
6+
public class CancelWorkflowExecutionDecisionAttributes {
7+
private byte[] details;
8+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
package com.uber.cadence.entities;
2+
3+
public enum ChildPolicy {
4+
TERMINATE,
5+
REQUEST_CANCEL,
6+
ABANDON
7+
}
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
/**
2+
* Copyright 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
3+
*
4+
* <p>Modifications copyright (C) 2017 Uber Technologies, Inc.
5+
*
6+
* <p>Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file
7+
* except in compliance with the License. A copy of the License is located at
8+
*
9+
* <p>http://aws.amazon.com/apache2.0
10+
*
11+
* <p>or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
13+
* specific language governing permissions and limitations under the License.
14+
*/
15+
package com.uber.cadence.entities;
16+
17+
import lombok.Data;
18+
19+
@Data
20+
public class ChildWorkflowExecutionCanceledEventAttributes {
21+
private byte[] details;
22+
private String domain;
23+
private WorkflowExecution workflowExecution;
24+
private WorkflowType workflowType;
25+
private Long initiatedEventId;
26+
private Long startedEventId;
27+
}

0 commit comments

Comments
 (0)