feat(common): expose regionDurable over gRPC
TaskDef is a @ProtoMessage and every other field is proto-mapped, so without an id the flag could not travel over gRPC — a client setting it would silently get the default. Annotate it (id 26, the next free one) and commit the protogen output: the field in taskdef.proto and the two AbstractProtoMapper lines.
This commit is contained in:
@@ -157,6 +157,7 @@ public class TaskDef extends Auditable {
|
||||
* before the caller is acked (falling back to asynchronous convergence if the sync quorum is
|
||||
* missed). Defaults to false (locally durable only).
|
||||
*/
|
||||
@ProtoField(id = 26)
|
||||
private boolean regionDurable;
|
||||
|
||||
public TaskDef() {}
|
||||
|
||||
@@ -27,6 +27,7 @@ import jakarta.validation.Validator;
|
||||
import jakarta.validation.ValidatorFactory;
|
||||
|
||||
import static org.junit.Assert.assertEquals;
|
||||
import static org.junit.Assert.assertFalse;
|
||||
import static org.junit.Assert.assertNotEquals;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
|
||||
|
||||
@@ -1039,6 +1039,7 @@ public abstract class AbstractProtoMapper {
|
||||
}
|
||||
to.setTotalTimeoutSeconds( from.getTotalTimeoutSeconds() );
|
||||
to.setTaskStatusListenerEnabled( from.isTaskStatusListenerEnabled() );
|
||||
to.setRegionDurable( from.isRegionDurable() );
|
||||
return to.build();
|
||||
}
|
||||
|
||||
@@ -1072,6 +1073,7 @@ public abstract class AbstractProtoMapper {
|
||||
to.setBaseType( from.getBaseType() );
|
||||
to.setTotalTimeoutSeconds( from.getTotalTimeoutSeconds() );
|
||||
to.setTaskStatusListenerEnabled( from.getTaskStatusListenerEnabled() );
|
||||
to.setRegionDurable( from.getRegionDurable() );
|
||||
return to;
|
||||
}
|
||||
|
||||
|
||||
@@ -42,4 +42,5 @@ message TaskDef {
|
||||
string base_type = 21;
|
||||
int64 total_timeout_seconds = 22;
|
||||
bool task_status_listener_enabled = 23;
|
||||
bool region_durable = 26;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user