Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
42 changes: 39 additions & 3 deletions src/main/java/com/getconvoy/models/DatastoreProjectConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,8 @@
DatastoreProjectConfig.JSON_PROPERTY_SEARCH_POLICY,
DatastoreProjectConfig.JSON_PROPERTY_SIGNATURE,
DatastoreProjectConfig.JSON_PROPERTY_SSL,
DatastoreProjectConfig.JSON_PROPERTY_STRATEGY
DatastoreProjectConfig.JSON_PROPERTY_STRATEGY,
DatastoreProjectConfig.JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK
})
@jakarta.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", comments = "Generator version: 7.23.0")
public class DatastoreProjectConfig {
Expand Down Expand Up @@ -106,6 +107,10 @@ public class DatastoreProjectConfig {
public static final String JSON_PROPERTY_STRATEGY = "strategy";
private JsonNullable<DatastoreStrategyConfiguration> strategy = JsonNullable.<DatastoreStrategyConfiguration>undefined();

public static final String JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK = "sync_dynamic_event_ack";
@jakarta.annotation.Nullable
private Boolean syncDynamicEventAck;

public DatastoreProjectConfig() {
}

Expand Down Expand Up @@ -469,6 +474,30 @@ public void setStrategy(@jakarta.annotation.Nullable DatastoreStrategyConfigurat
}


public DatastoreProjectConfig syncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
return this;
}

/**
* SyncDynamicEventAck waits for endpoint/subscription resolve before returning 2xx from POST /events/dynamic. Default false keeps 201-on-queue.
* @return syncDynamicEventAck
*/
@jakarta.annotation.Nullable
@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public Boolean getSyncDynamicEventAck() {
return syncDynamicEventAck;
}


@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setSyncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
}


/**
* Return true if this datastore.ProjectConfig object is equal to o.
*/
Expand All @@ -493,7 +522,8 @@ public boolean equals(Object o) {
Objects.equals(this.searchPolicy, datastoreProjectConfig.searchPolicy) &&
equalsNullable(this.signature, datastoreProjectConfig.signature) &&
equalsNullable(this.ssl, datastoreProjectConfig.ssl) &&
equalsNullable(this.strategy, datastoreProjectConfig.strategy);
equalsNullable(this.strategy, datastoreProjectConfig.strategy) &&
Objects.equals(this.syncDynamicEventAck, datastoreProjectConfig.syncDynamicEventAck);
}

private static <T> boolean equalsNullable(JsonNullable<T> a, JsonNullable<T> b) {
Expand All @@ -502,7 +532,7 @@ private static <T> boolean equalsNullable(JsonNullable<T> a, JsonNullable<T> b)

@Override
public int hashCode() {
return Objects.hash(addEventIdTraceHeaders, hashCodeNullable(circuitBreaker), disableEndpoint, maxPayloadReadSize, hashCodeNullable(metaEvent), multipleEndpointSubscriptions, hashCodeNullable(ratelimit), replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, hashCodeNullable(signature), hashCodeNullable(ssl), hashCodeNullable(strategy));
return Objects.hash(addEventIdTraceHeaders, hashCodeNullable(circuitBreaker), disableEndpoint, maxPayloadReadSize, hashCodeNullable(metaEvent), multipleEndpointSubscriptions, hashCodeNullable(ratelimit), replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, hashCodeNullable(signature), hashCodeNullable(ssl), hashCodeNullable(strategy), syncDynamicEventAck);
}

private static <T> int hashCodeNullable(JsonNullable<T> a) {
Expand All @@ -529,6 +559,7 @@ public String toString() {
sb.append(" signature: ").append(toIndentedString(signature)).append("\n");
sb.append(" ssl: ").append(toIndentedString(ssl)).append("\n");
sb.append(" strategy: ").append(toIndentedString(strategy)).append("\n");
sb.append(" syncDynamicEventAck: ").append(toIndentedString(syncDynamicEventAck)).append("\n");
sb.append("}");
return sb.toString();
}
Expand Down Expand Up @@ -638,6 +669,11 @@ public String toUrlQueryString(String prefix) {
joiner.add(getStrategy().toUrlQueryString(prefix + "strategy" + suffix));
}

// add `sync_dynamic_event_ack` to the URL query string
if (getSyncDynamicEventAck() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%ssync_dynamic_event_ack%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getSyncDynamicEventAck()))));
}

return joiner.toString();
}
}
Expand Down
42 changes: 39 additions & 3 deletions src/main/java/com/getconvoy/models/ModelsProjectConfig.java
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,8 @@
ModelsProjectConfig.JSON_PROPERTY_SEARCH_POLICY,
ModelsProjectConfig.JSON_PROPERTY_SIGNATURE,
ModelsProjectConfig.JSON_PROPERTY_SSL,
ModelsProjectConfig.JSON_PROPERTY_STRATEGY
ModelsProjectConfig.JSON_PROPERTY_STRATEGY,
ModelsProjectConfig.JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK
})
@jakarta.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", comments = "Generator version: 7.23.0")
public class ModelsProjectConfig {
Expand Down Expand Up @@ -108,6 +109,10 @@ public class ModelsProjectConfig {
@jakarta.annotation.Nullable
private ModelsStrategyConfiguration strategy;

public static final String JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK = "sync_dynamic_event_ack";
@jakarta.annotation.Nullable
private Boolean syncDynamicEventAck;

public ModelsProjectConfig() {
}

Expand Down Expand Up @@ -423,6 +428,30 @@ public void setStrategy(@jakarta.annotation.Nullable ModelsStrategyConfiguration
}


public ModelsProjectConfig syncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
return this;
}

/**
* SyncDynamicEventAck waits for dynamic endpoint/subscription resolve before acknowledging POST /events/dynamic. When false, the handler returns 201 after enqueue.
* @return syncDynamicEventAck
*/
@jakarta.annotation.Nullable
@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public Boolean getSyncDynamicEventAck() {
return syncDynamicEventAck;
}


@JsonProperty(value = JSON_PROPERTY_SYNC_DYNAMIC_EVENT_ACK, required = false)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setSyncDynamicEventAck(@jakarta.annotation.Nullable Boolean syncDynamicEventAck) {
this.syncDynamicEventAck = syncDynamicEventAck;
}


/**
* Return true if this models.ProjectConfig object is equal to o.
*/
Expand All @@ -447,12 +476,13 @@ public boolean equals(Object o) {
Objects.equals(this.searchPolicy, modelsProjectConfig.searchPolicy) &&
Objects.equals(this.signature, modelsProjectConfig.signature) &&
Objects.equals(this.ssl, modelsProjectConfig.ssl) &&
Objects.equals(this.strategy, modelsProjectConfig.strategy);
Objects.equals(this.strategy, modelsProjectConfig.strategy) &&
Objects.equals(this.syncDynamicEventAck, modelsProjectConfig.syncDynamicEventAck);
}

@Override
public int hashCode() {
return Objects.hash(addEventIdTraceHeaders, circuitBreaker, disableEndpoint, maxPayloadReadSize, metaEvent, multipleEndpointSubscriptions, ratelimit, replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, signature, ssl, strategy);
return Objects.hash(addEventIdTraceHeaders, circuitBreaker, disableEndpoint, maxPayloadReadSize, metaEvent, multipleEndpointSubscriptions, ratelimit, replayAttacksPreventionEnabled, requestIdHeader, searchPolicy, signature, ssl, strategy, syncDynamicEventAck);
}

@Override
Expand All @@ -472,6 +502,7 @@ public String toString() {
sb.append(" signature: ").append(toIndentedString(signature)).append("\n");
sb.append(" ssl: ").append(toIndentedString(ssl)).append("\n");
sb.append(" strategy: ").append(toIndentedString(strategy)).append("\n");
sb.append(" syncDynamicEventAck: ").append(toIndentedString(syncDynamicEventAck)).append("\n");
sb.append("}");
return sb.toString();
}
Expand Down Expand Up @@ -581,6 +612,11 @@ public String toUrlQueryString(String prefix) {
joiner.add(getStrategy().toUrlQueryString(prefix + "strategy" + suffix));
}

// add `sync_dynamic_event_ack` to the URL query string
if (getSyncDynamicEventAck() != null) {
joiner.add(String.format(java.util.Locale.ROOT, "%ssync_dynamic_event_ack%s=%s", prefix, suffix, ApiClient.urlEncode(ApiClient.valueToString(getSyncDynamicEventAck()))));
}

return joiner.toString();
}
}
Expand Down
Loading