Skip to content

Commit 7bafe0f

Browse files
committed
feat: Update IDL
1 parent a623276 commit 7bafe0f

54 files changed

Lines changed: 675 additions & 21 deletions

File tree

Some content is hidden

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

build.gradle

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -181,8 +181,35 @@ clean {
181181
delete protobuf.generatedFilesBaseDir
182182
}
183183

184+
task replaceGeneratedSources {
185+
dependsOn 'generateProto'
186+
doLast {
187+
def file = file("$buildDir/generated-sources/proto/main/java/com/uber/cadence/api/v1/ActiveClusterSelectionPolicy.java")
188+
189+
if (!file.exists()) {
190+
return
191+
}
192+
193+
def content = file.text
194+
195+
def updated = content.replaceFirst(
196+
/public\s+.*class\s+ActiveClusterSelectionPolicy/,
197+
'@SuppressWarnings("deprecation")\n$0'
198+
)
199+
200+
if (content == updated) {
201+
println("❌ Pattern did NOT match")
202+
} else {
203+
file.text = updated
204+
println("✅ Replacement applied")
205+
}
206+
207+
}
208+
}
209+
184210
compileJava {
185211
dependsOn 'googleJavaFormat'
212+
dependsOn 'replaceGeneratedSources'
186213
options.encoding = 'UTF-8'
187214
options.compilerArgs << '-Xlint:none' << '-Xlint:deprecation' << '-Werror'
188215
options.errorprone.excludedPaths = '.*/generated-sources/.*'
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.uber.cadence;
2+
3+
import java.util.*;
4+
import lombok.Data;
5+
import lombok.experimental.Accessors;
6+
7+
@Data
8+
@Accessors(chain = true)
9+
public class ActiveClusterInfo {
10+
private String activeClusterName;
11+
private long failoverVersion;
12+
}
Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
package com.uber.cadence;
2+
3+
import java.util.*;
4+
import lombok.Data;
5+
import lombok.experimental.Accessors;
6+
7+
@Data
8+
@Accessors(chain = true)
9+
public class ActiveClusterSelectionPolicy {
10+
private ClusterAttribute clusterAttribute;
11+
private ActiveClusterSelectionStrategy strategy;
12+
private String stickyRegion;
13+
private String externalEntityType;
14+
private String externalEntityKey;
15+
}
Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
package com.uber.cadence;
2+
3+
public enum ActiveClusterSelectionStrategy {
4+
REGION_STICKY,
5+
EXTERNAL_ENTITY,
6+
}
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.uber.cadence;
2+
3+
import java.util.*;
4+
import lombok.Data;
5+
import lombok.experimental.Accessors;
6+
7+
@Data
8+
@Accessors(chain = true)
9+
public class ActiveClusters {
10+
private Map<String, ActiveClusterInfo> activeClustersByRegion = new HashMap<>();;
11+
private Map<String, ClusterAttributeScope> activeClustersByClusterAttribute = new HashMap<>();;
12+
}
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.uber.cadence;
2+
3+
import java.util.*;
4+
import lombok.Data;
5+
import lombok.experimental.Accessors;
6+
7+
@Data
8+
@Accessors(chain = true)
9+
public class ClusterAttribute {
10+
private String scope;
11+
private String name;
12+
}
Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
package com.uber.cadence;
2+
3+
import java.util.*;
4+
import lombok.Data;
5+
import lombok.experimental.Accessors;
6+
7+
@Data
8+
@Accessors(chain = true)
9+
public class ClusterAttributeScope {
10+
private Map<String, ActiveClusterInfo> clusterAttributes = new HashMap<>();;
11+
}
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package com.uber.cadence;
2+
3+
import java.util.*;
4+
import lombok.Data;
5+
import lombok.experimental.Accessors;
6+
7+
@Data
8+
@Accessors(chain = true)
9+
public class ClusterFailover {
10+
private ActiveClusterInfo fromCluster;
11+
private ActiveClusterInfo toCluster;
12+
private ClusterAttribute clusterAttribute;
13+
}

src/gen/java/com/uber/cadence/ContinueAsNewWorkflowExecutionDecisionAttributes.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,4 +23,6 @@ public class ContinueAsNewWorkflowExecutionDecisionAttributes {
2323
private Memo memo;
2424
private SearchAttributes searchAttributes;
2525
private int jitterStartSeconds;
26+
private CronOverlapPolicy cronOverlapPolicy;
27+
private ActiveClusterSelectionPolicy activeClusterSelectionPolicy;
2628
}
Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
package com.uber.cadence;
2+
3+
public enum CronOverlapPolicy {
4+
SKIPPED,
5+
BUFFERONE,
6+
}

0 commit comments

Comments
 (0)