Optional earliest time the task can attempt to be delivered.
+ */
+ @JsonSetter(value = "deliverAfter", nulls = Nulls.SKIP)
+ public Builder deliverAfter(Optional deliverAfter) {
+ this.deliverAfter = deliverAfter;
+ return this;
+ }
+
+ public Builder deliverAfter(OffsetDateTime deliverAfter) {
+ this.deliverAfter = Optional.ofNullable(deliverAfter);
+ return this;
+ }
+
+ /**
+ * The latest time by which the task should be delivered.
+ * If this deadline passes without successful delivery of the task, then the task will time
+ * out with DELIVERY_ERROR_CODE_TIMEOUT.
+ * This field is only required for tasks with retry strategies.
+ */
+ @JsonSetter(value = "deliverBefore", nulls = Nulls.SKIP)
+ public Builder deliverBefore(Optional deliverBefore) {
+ this.deliverBefore = deliverBefore;
+ return this;
+ }
+
+ public Builder deliverBefore(OffsetDateTime deliverBefore) {
+ this.deliverBefore = Optional.ofNullable(deliverBefore);
+ return this;
+ }
+
+ public DeliveryConstraints build() {
+ return new DeliveryConstraints(deliverAfter, deliverBefore, additionalProperties);
+ }
+ }
+}
diff --git a/src/main/java/com/anduril/types/DeliveryError.java b/src/main/java/com/anduril/types/DeliveryError.java
new file mode 100644
index 00000000..3fe3d2dd
--- /dev/null
+++ b/src/main/java/com/anduril/types/DeliveryError.java
@@ -0,0 +1,130 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.anduril.types;
+
+import com.anduril.core.ObjectMappers;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = DeliveryError.Builder.class)
+public final class DeliveryError {
+ private final Optional code;
+
+ private final Optional message;
+
+ private final Map additionalProperties;
+
+ private DeliveryError(
+ Optional code, Optional message, Map additionalProperties) {
+ this.code = code;
+ this.message = message;
+ this.additionalProperties = additionalProperties;
+ }
+
+ /**
+ * @return Error code for Delivery error.
+ */
+ @JsonProperty("code")
+ public Optional getCode() {
+ return code;
+ }
+
+ /**
+ * @return Descriptive human-readable string regarding this delivery error.
+ */
+ @JsonProperty("message")
+ public Optional getMessage() {
+ return message;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof DeliveryError && equalTo((DeliveryError) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(DeliveryError other) {
+ return code.equals(other.code) && message.equals(other.message);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(this.code, this.message);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder {
+ private Optional code = Optional.empty();
+
+ private Optional message = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ public Builder from(DeliveryError other) {
+ code(other.getCode());
+ message(other.getMessage());
+ return this;
+ }
+
+ /**
+ * Error code for Delivery error.
+ */
+ @JsonSetter(value = "code", nulls = Nulls.SKIP)
+ public Builder code(Optional code) {
+ this.code = code;
+ return this;
+ }
+
+ public Builder code(DeliveryErrorCode code) {
+ this.code = Optional.ofNullable(code);
+ return this;
+ }
+
+ /**
+ * Descriptive human-readable string regarding this delivery error.
+ */
+ @JsonSetter(value = "message", nulls = Nulls.SKIP)
+ public Builder message(Optional message) {
+ this.message = message;
+ return this;
+ }
+
+ public Builder message(String message) {
+ this.message = Optional.ofNullable(message);
+ return this;
+ }
+
+ public DeliveryError build() {
+ return new DeliveryError(code, message, additionalProperties);
+ }
+ }
+}
diff --git a/src/main/java/com/anduril/types/DeliveryErrorCode.java b/src/main/java/com/anduril/types/DeliveryErrorCode.java
new file mode 100644
index 00000000..29d1a4c3
--- /dev/null
+++ b/src/main/java/com/anduril/types/DeliveryErrorCode.java
@@ -0,0 +1,107 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.anduril.types;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonValue;
+
+public final class DeliveryErrorCode {
+ public static final DeliveryErrorCode DELIVERY_ERROR_CODE_REJECTED =
+ new DeliveryErrorCode(Value.DELIVERY_ERROR_CODE_REJECTED, "DELIVERY_ERROR_CODE_REJECTED");
+
+ public static final DeliveryErrorCode DELIVERY_ERROR_CODE_INVALID =
+ new DeliveryErrorCode(Value.DELIVERY_ERROR_CODE_INVALID, "DELIVERY_ERROR_CODE_INVALID");
+
+ public static final DeliveryErrorCode DELIVERY_ERROR_CODE_UNAVAILABLE =
+ new DeliveryErrorCode(Value.DELIVERY_ERROR_CODE_UNAVAILABLE, "DELIVERY_ERROR_CODE_UNAVAILABLE");
+
+ public static final DeliveryErrorCode DELIVERY_ERROR_CODE_TIMEOUT =
+ new DeliveryErrorCode(Value.DELIVERY_ERROR_CODE_TIMEOUT, "DELIVERY_ERROR_CODE_TIMEOUT");
+
+ private final Value value;
+
+ private final String string;
+
+ DeliveryErrorCode(Value value, String string) {
+ this.value = value;
+ this.string = string;
+ }
+
+ public Value getEnumValue() {
+ return value;
+ }
+
+ @java.lang.Override
+ @JsonValue
+ public String toString() {
+ return this.string;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ return (this == other)
+ || (other instanceof DeliveryErrorCode && this.string.equals(((DeliveryErrorCode) other).string));
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return this.string.hashCode();
+ }
+
+ public T visit(Visitor visitor) {
+ switch (value) {
+ case DELIVERY_ERROR_CODE_REJECTED:
+ return visitor.visitDeliveryErrorCodeRejected();
+ case DELIVERY_ERROR_CODE_INVALID:
+ return visitor.visitDeliveryErrorCodeInvalid();
+ case DELIVERY_ERROR_CODE_UNAVAILABLE:
+ return visitor.visitDeliveryErrorCodeUnavailable();
+ case DELIVERY_ERROR_CODE_TIMEOUT:
+ return visitor.visitDeliveryErrorCodeTimeout();
+ case UNKNOWN:
+ default:
+ return visitor.visitUnknown(string);
+ }
+ }
+
+ @JsonCreator(mode = JsonCreator.Mode.DELEGATING)
+ public static DeliveryErrorCode valueOf(String value) {
+ switch (value) {
+ case "DELIVERY_ERROR_CODE_REJECTED":
+ return DELIVERY_ERROR_CODE_REJECTED;
+ case "DELIVERY_ERROR_CODE_INVALID":
+ return DELIVERY_ERROR_CODE_INVALID;
+ case "DELIVERY_ERROR_CODE_UNAVAILABLE":
+ return DELIVERY_ERROR_CODE_UNAVAILABLE;
+ case "DELIVERY_ERROR_CODE_TIMEOUT":
+ return DELIVERY_ERROR_CODE_TIMEOUT;
+ default:
+ return new DeliveryErrorCode(Value.UNKNOWN, value);
+ }
+ }
+
+ public enum Value {
+ DELIVERY_ERROR_CODE_INVALID,
+
+ DELIVERY_ERROR_CODE_UNAVAILABLE,
+
+ DELIVERY_ERROR_CODE_TIMEOUT,
+
+ DELIVERY_ERROR_CODE_REJECTED,
+
+ UNKNOWN
+ }
+
+ public interface Visitor {
+ T visitDeliveryErrorCodeInvalid();
+
+ T visitDeliveryErrorCodeUnavailable();
+
+ T visitDeliveryErrorCodeTimeout();
+
+ T visitDeliveryErrorCodeRejected();
+
+ T visitUnknown(String unknownType);
+ }
+}
diff --git a/src/main/java/com/anduril/types/DeliveryState.java b/src/main/java/com/anduril/types/DeliveryState.java
new file mode 100644
index 00000000..65883742
--- /dev/null
+++ b/src/main/java/com/anduril/types/DeliveryState.java
@@ -0,0 +1,163 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.anduril.types;
+
+import com.anduril.core.ObjectMappers;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = DeliveryState.Builder.class)
+public final class DeliveryState {
+ private final Optional status;
+
+ private final Optional error;
+
+ private final Optional deliveryConstraints;
+
+ private final Map additionalProperties;
+
+ private DeliveryState(
+ Optional status,
+ Optional error,
+ Optional deliveryConstraints,
+ Map additionalProperties) {
+ this.status = status;
+ this.error = error;
+ this.deliveryConstraints = deliveryConstraints;
+ this.additionalProperties = additionalProperties;
+ }
+
+ /**
+ * @return The current status of the delivery.
+ */
+ @JsonProperty("status")
+ public Optional getStatus() {
+ return status;
+ }
+
+ /**
+ * @return Errors associated with the delivery, if any.
+ */
+ @JsonProperty("error")
+ public Optional getError() {
+ return error;
+ }
+
+ /**
+ * @return Optional scheduling constraints for Lattice delivery of the task.
+ */
+ @JsonProperty("deliveryConstraints")
+ public Optional getDeliveryConstraints() {
+ return deliveryConstraints;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof DeliveryState && equalTo((DeliveryState) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(DeliveryState other) {
+ return status.equals(other.status)
+ && error.equals(other.error)
+ && deliveryConstraints.equals(other.deliveryConstraints);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(this.status, this.error, this.deliveryConstraints);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder {
+ private Optional status = Optional.empty();
+
+ private Optional error = Optional.empty();
+
+ private Optional deliveryConstraints = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ public Builder from(DeliveryState other) {
+ status(other.getStatus());
+ error(other.getError());
+ deliveryConstraints(other.getDeliveryConstraints());
+ return this;
+ }
+
+ /**
+ * The current status of the delivery.
+ */
+ @JsonSetter(value = "status", nulls = Nulls.SKIP)
+ public Builder status(Optional status) {
+ this.status = status;
+ return this;
+ }
+
+ public Builder status(DeliveryStateStatus status) {
+ this.status = Optional.ofNullable(status);
+ return this;
+ }
+
+ /**
+ * Errors associated with the delivery, if any.
+ */
+ @JsonSetter(value = "error", nulls = Nulls.SKIP)
+ public Builder error(Optional error) {
+ this.error = error;
+ return this;
+ }
+
+ public Builder error(DeliveryError error) {
+ this.error = Optional.ofNullable(error);
+ return this;
+ }
+
+ /**
+ * Optional scheduling constraints for Lattice delivery of the task.
+ */
+ @JsonSetter(value = "deliveryConstraints", nulls = Nulls.SKIP)
+ public Builder deliveryConstraints(Optional deliveryConstraints) {
+ this.deliveryConstraints = deliveryConstraints;
+ return this;
+ }
+
+ public Builder deliveryConstraints(DeliveryConstraints deliveryConstraints) {
+ this.deliveryConstraints = Optional.ofNullable(deliveryConstraints);
+ return this;
+ }
+
+ public DeliveryState build() {
+ return new DeliveryState(status, error, deliveryConstraints, additionalProperties);
+ }
+ }
+}
diff --git a/src/main/java/com/anduril/types/DeliveryStateStatus.java b/src/main/java/com/anduril/types/DeliveryStateStatus.java
new file mode 100644
index 00000000..b69cc5e6
--- /dev/null
+++ b/src/main/java/com/anduril/types/DeliveryStateStatus.java
@@ -0,0 +1,118 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.anduril.types;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonValue;
+
+public final class DeliveryStateStatus {
+ public static final DeliveryStateStatus DELIVERY_STATUS_PENDING_CANCEL =
+ new DeliveryStateStatus(Value.DELIVERY_STATUS_PENDING_CANCEL, "DELIVERY_STATUS_PENDING_CANCEL");
+
+ public static final DeliveryStateStatus DELIVERY_STATUS_DELIVERED =
+ new DeliveryStateStatus(Value.DELIVERY_STATUS_DELIVERED, "DELIVERY_STATUS_DELIVERED");
+
+ public static final DeliveryStateStatus DELIVERY_STATUS_INVALID =
+ new DeliveryStateStatus(Value.DELIVERY_STATUS_INVALID, "DELIVERY_STATUS_INVALID");
+
+ public static final DeliveryStateStatus DELIVERY_STATUS_PENDING_EXECUTE =
+ new DeliveryStateStatus(Value.DELIVERY_STATUS_PENDING_EXECUTE, "DELIVERY_STATUS_PENDING_EXECUTE");
+
+ public static final DeliveryStateStatus DELIVERY_STATUS_PENDING_COMPLETE =
+ new DeliveryStateStatus(Value.DELIVERY_STATUS_PENDING_COMPLETE, "DELIVERY_STATUS_PENDING_COMPLETE");
+
+ private final Value value;
+
+ private final String string;
+
+ DeliveryStateStatus(Value value, String string) {
+ this.value = value;
+ this.string = string;
+ }
+
+ public Value getEnumValue() {
+ return value;
+ }
+
+ @java.lang.Override
+ @JsonValue
+ public String toString() {
+ return this.string;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ return (this == other)
+ || (other instanceof DeliveryStateStatus && this.string.equals(((DeliveryStateStatus) other).string));
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return this.string.hashCode();
+ }
+
+ public T visit(Visitor visitor) {
+ switch (value) {
+ case DELIVERY_STATUS_PENDING_CANCEL:
+ return visitor.visitDeliveryStatusPendingCancel();
+ case DELIVERY_STATUS_DELIVERED:
+ return visitor.visitDeliveryStatusDelivered();
+ case DELIVERY_STATUS_INVALID:
+ return visitor.visitDeliveryStatusInvalid();
+ case DELIVERY_STATUS_PENDING_EXECUTE:
+ return visitor.visitDeliveryStatusPendingExecute();
+ case DELIVERY_STATUS_PENDING_COMPLETE:
+ return visitor.visitDeliveryStatusPendingComplete();
+ case UNKNOWN:
+ default:
+ return visitor.visitUnknown(string);
+ }
+ }
+
+ @JsonCreator(mode = JsonCreator.Mode.DELEGATING)
+ public static DeliveryStateStatus valueOf(String value) {
+ switch (value) {
+ case "DELIVERY_STATUS_PENDING_CANCEL":
+ return DELIVERY_STATUS_PENDING_CANCEL;
+ case "DELIVERY_STATUS_DELIVERED":
+ return DELIVERY_STATUS_DELIVERED;
+ case "DELIVERY_STATUS_INVALID":
+ return DELIVERY_STATUS_INVALID;
+ case "DELIVERY_STATUS_PENDING_EXECUTE":
+ return DELIVERY_STATUS_PENDING_EXECUTE;
+ case "DELIVERY_STATUS_PENDING_COMPLETE":
+ return DELIVERY_STATUS_PENDING_COMPLETE;
+ default:
+ return new DeliveryStateStatus(Value.UNKNOWN, value);
+ }
+ }
+
+ public enum Value {
+ DELIVERY_STATUS_INVALID,
+
+ DELIVERY_STATUS_DELIVERED,
+
+ DELIVERY_STATUS_PENDING_EXECUTE,
+
+ DELIVERY_STATUS_PENDING_CANCEL,
+
+ DELIVERY_STATUS_PENDING_COMPLETE,
+
+ UNKNOWN
+ }
+
+ public interface Visitor {
+ T visitDeliveryStatusInvalid();
+
+ T visitDeliveryStatusDelivered();
+
+ T visitDeliveryStatusPendingExecute();
+
+ T visitDeliveryStatusPendingCancel();
+
+ T visitDeliveryStatusPendingComplete();
+
+ T visitUnknown(String unknownType);
+ }
+}
diff --git a/src/main/java/com/anduril/types/FixedRetry.java b/src/main/java/com/anduril/types/FixedRetry.java
new file mode 100644
index 00000000..fcb5eab3
--- /dev/null
+++ b/src/main/java/com/anduril/types/FixedRetry.java
@@ -0,0 +1,101 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.anduril.types;
+
+import com.anduril.core.ObjectMappers;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = FixedRetry.Builder.class)
+public final class FixedRetry {
+ private final Optional retryInterval;
+
+ private final Map additionalProperties;
+
+ private FixedRetry(Optional retryInterval, Map additionalProperties) {
+ this.retryInterval = retryInterval;
+ this.additionalProperties = additionalProperties;
+ }
+
+ /**
+ * @return Specifies the interval between retries. A default interval of 5 seconds is used if this field is not set.
+ */
+ @JsonProperty("retryInterval")
+ public Optional getRetryInterval() {
+ return retryInterval;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof FixedRetry && equalTo((FixedRetry) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(FixedRetry other) {
+ return retryInterval.equals(other.retryInterval);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(this.retryInterval);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder {
+ private Optional retryInterval = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ public Builder from(FixedRetry other) {
+ retryInterval(other.getRetryInterval());
+ return this;
+ }
+
+ /**
+ * Specifies the interval between retries. A default interval of 5 seconds is used if this field is not set.
+ */
+ @JsonSetter(value = "retryInterval", nulls = Nulls.SKIP)
+ public Builder retryInterval(Optional retryInterval) {
+ this.retryInterval = retryInterval;
+ return this;
+ }
+
+ public Builder retryInterval(String retryInterval) {
+ this.retryInterval = Optional.ofNullable(retryInterval);
+ return this;
+ }
+
+ public FixedRetry build() {
+ return new FixedRetry(retryInterval, additionalProperties);
+ }
+ }
+}
diff --git a/src/main/java/com/anduril/types/RetryStrategy.java b/src/main/java/com/anduril/types/RetryStrategy.java
new file mode 100644
index 00000000..3a825fff
--- /dev/null
+++ b/src/main/java/com/anduril/types/RetryStrategy.java
@@ -0,0 +1,95 @@
+/**
+ * This file was auto-generated by Fern from our API Definition.
+ */
+package com.anduril.types;
+
+import com.anduril.core.ObjectMappers;
+import com.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonSetter;
+import com.fasterxml.jackson.annotation.Nulls;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
+
+@JsonInclude(JsonInclude.Include.NON_ABSENT)
+@JsonDeserialize(builder = RetryStrategy.Builder.class)
+public final class RetryStrategy {
+ private final Optional fixedRetryStrategy;
+
+ private final Map additionalProperties;
+
+ private RetryStrategy(Optional fixedRetryStrategy, Map additionalProperties) {
+ this.fixedRetryStrategy = fixedRetryStrategy;
+ this.additionalProperties = additionalProperties;
+ }
+
+ @JsonProperty("fixedRetryStrategy")
+ public Optional getFixedRetryStrategy() {
+ return fixedRetryStrategy;
+ }
+
+ @java.lang.Override
+ public boolean equals(Object other) {
+ if (this == other) return true;
+ return other instanceof RetryStrategy && equalTo((RetryStrategy) other);
+ }
+
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return this.additionalProperties;
+ }
+
+ private boolean equalTo(RetryStrategy other) {
+ return fixedRetryStrategy.equals(other.fixedRetryStrategy);
+ }
+
+ @java.lang.Override
+ public int hashCode() {
+ return Objects.hash(this.fixedRetryStrategy);
+ }
+
+ @java.lang.Override
+ public String toString() {
+ return ObjectMappers.stringify(this);
+ }
+
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ @JsonIgnoreProperties(ignoreUnknown = true)
+ public static final class Builder {
+ private Optional fixedRetryStrategy = Optional.empty();
+
+ @JsonAnySetter
+ private Map additionalProperties = new HashMap<>();
+
+ private Builder() {}
+
+ public Builder from(RetryStrategy other) {
+ fixedRetryStrategy(other.getFixedRetryStrategy());
+ return this;
+ }
+
+ @JsonSetter(value = "fixedRetryStrategy", nulls = Nulls.SKIP)
+ public Builder fixedRetryStrategy(Optional fixedRetryStrategy) {
+ this.fixedRetryStrategy = fixedRetryStrategy;
+ return this;
+ }
+
+ public Builder fixedRetryStrategy(FixedRetry fixedRetryStrategy) {
+ this.fixedRetryStrategy = Optional.ofNullable(fixedRetryStrategy);
+ return this;
+ }
+
+ public RetryStrategy build() {
+ return new RetryStrategy(fixedRetryStrategy, additionalProperties);
+ }
+ }
+}
diff --git a/src/main/java/com/anduril/types/Task.java b/src/main/java/com/anduril/types/Task.java
index 22adadfe..aec3fe13 100644
--- a/src/main/java/com/anduril/types/Task.java
+++ b/src/main/java/com/anduril/types/Task.java
@@ -52,6 +52,10 @@ public final class Task {
private final Optional owner;
+ private final Optional retryStrategy;
+
+ private final Optional deliveryState;
+
private final Map additionalProperties;
private Task(
@@ -70,6 +74,8 @@ private Task(
Optional replication,
Optional> initialEntities,
Optional owner,
+ Optional retryStrategy,
+ Optional deliveryState,
Map additionalProperties) {
this.version = version;
this.displayName = displayName;
@@ -86,6 +92,8 @@ private Task(
this.replication = replication;
this.initialEntities = initialEntities;
this.owner = owner;
+ this.retryStrategy = retryStrategy;
+ this.deliveryState = deliveryState;
this.additionalProperties = additionalProperties;
}
@@ -214,6 +222,22 @@ public Optional getOwner() {
return owner;
}
+ /**
+ * @return Sets an optional try strategy for tasks. Use this option to control how Lattice attempts to retry delivery of tasks to assets with intermittent access or network connectivity to your environment.
+ */
+ @JsonProperty("retryStrategy")
+ public Optional getRetryStrategy() {
+ return retryStrategy;
+ }
+
+ /**
+ * @return The current delivery state of a task.
+ */
+ @JsonProperty("deliveryState")
+ public Optional getDeliveryState() {
+ return deliveryState;
+ }
+
@java.lang.Override
public boolean equals(Object other) {
if (this == other) return true;
@@ -240,7 +264,9 @@ private boolean equalTo(Task other) {
&& createTime.equals(other.createTime)
&& replication.equals(other.replication)
&& initialEntities.equals(other.initialEntities)
- && owner.equals(other.owner);
+ && owner.equals(other.owner)
+ && retryStrategy.equals(other.retryStrategy)
+ && deliveryState.equals(other.deliveryState);
}
@java.lang.Override
@@ -260,7 +286,9 @@ public int hashCode() {
this.createTime,
this.replication,
this.initialEntities,
- this.owner);
+ this.owner,
+ this.retryStrategy,
+ this.deliveryState);
}
@java.lang.Override
@@ -304,6 +332,10 @@ public static final class Builder {
private Optional owner = Optional.empty();
+ private Optional retryStrategy = Optional.empty();
+
+ private Optional deliveryState = Optional.empty();
+
@JsonAnySetter
private Map additionalProperties = new HashMap<>();
@@ -325,6 +357,8 @@ public Builder from(Task other) {
replication(other.getReplication());
initialEntities(other.getInitialEntities());
owner(other.getOwner());
+ retryStrategy(other.getRetryStrategy());
+ deliveryState(other.getDeliveryState());
return this;
}
@@ -543,6 +577,34 @@ public Builder owner(Owner owner) {
return this;
}
+ /**
+ * Sets an optional try strategy for tasks. Use this option to control how Lattice attempts to retry delivery of tasks to assets with intermittent access or network connectivity to your environment.
+ */
+ @JsonSetter(value = "retryStrategy", nulls = Nulls.SKIP)
+ public Builder retryStrategy(Optional retryStrategy) {
+ this.retryStrategy = retryStrategy;
+ return this;
+ }
+
+ public Builder retryStrategy(RetryStrategy retryStrategy) {
+ this.retryStrategy = Optional.ofNullable(retryStrategy);
+ return this;
+ }
+
+ /**
+ * The current delivery state of a task.
+ */
+ @JsonSetter(value = "deliveryState", nulls = Nulls.SKIP)
+ public Builder deliveryState(Optional deliveryState) {
+ this.deliveryState = deliveryState;
+ return this;
+ }
+
+ public Builder deliveryState(DeliveryState deliveryState) {
+ this.deliveryState = Optional.ofNullable(deliveryState);
+ return this;
+ }
+
public Task build() {
return new Task(
version,
@@ -560,6 +622,8 @@ public Task build() {
replication,
initialEntities,
owner,
+ retryStrategy,
+ deliveryState,
additionalProperties);
}
}