Skip to content

Commit

Permalink
Regen code
Browse files Browse the repository at this point in the history
  • Loading branch information
vietj committed Sep 23, 2023
1 parent f1c3907 commit f20a8be
Show file tree
Hide file tree
Showing 159 changed files with 6,645 additions and 7,813 deletions.

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -22,34 +22,40 @@ import io.vertx.amqp.AmqpReceiverOptions
*
* Configures the AMQP Receiver.
*
* @param autoAcknowledgement Sets the auto-acknowledgement. When enabled (default), the messages are automatically acknowledged. If set to <code>false</code>, the messages must be acknowledged explicitly using [io.vertx.amqp.AmqpMessage], [io.vertx.amqp.AmqpMessage] and [io.vertx.amqp.AmqpMessage].
* @param linkName
* @param dynamic Sets whether the Source terminus to be used should specify it is 'dynamic', requesting the peer creates a node and names it with a generated address. <p> The address provided by the peer can then be inspected using the [io.vertx.amqp.AmqpReceiver] method on the [io.vertx.amqp.AmqpReceiver] received once opened.
* @param qos Sets the local QOS config.
* @param capabilities Sets the list of capabilities to be set on the receiver source terminus.
* @param capabilitys Adds a capability to be set on the receiver source terminus.
* @param durable Sets the durability. <p> Passing <code>true</code> sets the expiry policy of the source to <code>NEVER</code> and the durability of the source to <code>UNSETTLED_STATE</code>.
* @param dynamic Sets whether the Source terminus to be used should specify it is 'dynamic', requesting the peer creates a node and names it with a generated address. <p> The address provided by the peer can then be inspected using the [io.vertx.amqp.AmqpReceiver] method on the [io.vertx.amqp.AmqpReceiver] received once opened.
* @param linkName
* @param maxBufferedMessages Sets the max buffered messages. This message can be used to configure the initial credit of a receiver.
* @param noLocal Sets whether this receiver should not receive messages that were sent using the same underlying connection. Used to determine whether to define an "apache.org:no-local-filter:list" filter on the source terminus, requesting that the server filters which messages are delivered to the receiver so that they do not include messages sent on the same underlying connection (if supported by the server in question).
* @param qos Sets the local QOS config.
* @param autoAcknowledgement Sets the auto-acknowledgement. When enabled (default), the messages are automatically acknowledged. If set to <code>false</code>, the messages must be acknowledged explicitly using [io.vertx.amqp.AmqpMessage], [io.vertx.amqp.AmqpMessage] and [io.vertx.amqp.AmqpMessage].
* @param selector Sets a message selector string. Used to define an "apache.org:selector-filter:string" filter on the source terminus, using SQL-based syntax to request the server filters which messages are delivered to the receiver (if supported by the server in question). Precise functionality supported and syntax needed can vary depending on the server.
* @param noLocal Sets whether this receiver should not receive messages that were sent using the same underlying connection. Used to determine whether to define an "apache.org:no-local-filter:list" filter on the source terminus, requesting that the server filters which messages are delivered to the receiver so that they do not include messages sent on the same underlying connection (if supported by the server in question).
*
* <p/>
* NOTE: This function has been automatically generated from the [io.vertx.amqp.AmqpReceiverOptions original] using Vert.x codegen.
*/
fun amqpReceiverOptionsOf(
autoAcknowledgement: Boolean? = null,
linkName: String? = null,
dynamic: Boolean? = null,
qos: String? = null,
capabilities: Iterable<String>? = null,
capabilitys: Iterable<String>? = null,
durable: Boolean? = null,
dynamic: Boolean? = null,
linkName: String? = null,
maxBufferedMessages: Int? = null,
noLocal: Boolean? = null,
qos: String? = null,
selector: String? = null): AmqpReceiverOptions = io.vertx.amqp.AmqpReceiverOptions().apply {
autoAcknowledgement: Boolean? = null,
selector: String? = null,
noLocal: Boolean? = null): AmqpReceiverOptions = io.vertx.amqp.AmqpReceiverOptions().apply {

if (autoAcknowledgement != null) {
this.setAutoAcknowledgement(autoAcknowledgement)
if (linkName != null) {
this.setLinkName(linkName)
}
if (dynamic != null) {
this.setDynamic(dynamic)
}
if (qos != null) {
this.setQos(qos)
}
if (capabilities != null) {
this.setCapabilities(capabilities.toList())
Expand All @@ -62,23 +68,17 @@ fun amqpReceiverOptionsOf(
if (durable != null) {
this.setDurable(durable)
}
if (dynamic != null) {
this.setDynamic(dynamic)
}
if (linkName != null) {
this.setLinkName(linkName)
}
if (maxBufferedMessages != null) {
this.setMaxBufferedMessages(maxBufferedMessages)
}
if (noLocal != null) {
this.setNoLocal(noLocal)
}
if (qos != null) {
this.setQos(qos)
if (autoAcknowledgement != null) {
this.setAutoAcknowledgement(autoAcknowledgement)
}
if (selector != null) {
this.setSelector(selector)
}
if (noLocal != null) {
this.setNoLocal(noLocal)
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -22,22 +22,28 @@ import io.vertx.amqp.AmqpSenderOptions
*
* Configures the AMQP Sender.
*
* @param linkName
* @param dynamic Sets whether the Target terminus to be used should specify it is 'dynamic', requesting the peer creates a node and names it with a generated address. <p> The address provided by the peer can then be inspected using the [io.vertx.amqp.AmqpSender] method on the [io.vertx.amqp.AmqpSender] received once opened.
* @param autoDrained Sets whether the link is automatically marked drained after the send queue drain handler callback returns if the receiving peer requested that credit be drained. <p> <code>true</code> by default.
* @param capabilities Sets the list of capabilities to be set on the sender target terminus.
* @param capabilitys Adds a capability to be set on the sender target terminus.
* @param dynamic Sets whether the Target terminus to be used should specify it is 'dynamic', requesting the peer creates a node and names it with a generated address. <p> The address provided by the peer can then be inspected using the [io.vertx.amqp.AmqpSender] method on the [io.vertx.amqp.AmqpSender] received once opened.
* @param linkName
*
* <p/>
* NOTE: This function has been automatically generated from the [io.vertx.amqp.AmqpSenderOptions original] using Vert.x codegen.
*/
fun amqpSenderOptionsOf(
linkName: String? = null,
dynamic: Boolean? = null,
autoDrained: Boolean? = null,
capabilities: Iterable<String>? = null,
capabilitys: Iterable<String>? = null,
dynamic: Boolean? = null,
linkName: String? = null): AmqpSenderOptions = io.vertx.amqp.AmqpSenderOptions().apply {
capabilitys: Iterable<String>? = null): AmqpSenderOptions = io.vertx.amqp.AmqpSenderOptions().apply {

if (linkName != null) {
this.setLinkName(linkName)
}
if (dynamic != null) {
this.setDynamic(dynamic)
}
if (autoDrained != null) {
this.setAutoDrained(autoDrained)
}
Expand All @@ -49,11 +55,5 @@ fun amqpSenderOptionsOf(
this.addCapability(item)
}
}
if (dynamic != null) {
this.setDynamic(dynamic)
}
if (linkName != null) {
this.setLinkName(linkName)
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -25,19 +25,19 @@ import io.vertx.core.tracing.TracingPolicy
*
* @param contactPoints Adds a contact point to use for the initial connection to the cluster
* @param keyspace Set the keyspace to use when creating the Cassandra session. Defaults to <code>null</code>.
* @param username Set the username for plaintext authentication. Defaults to <code>null</code>.
* @param password Set the password for plaintext authentication. Defaults to <code>null</code>.
* @param tracingPolicy Set the tracing policy for the client behavior when Vert.x has tracing enabled.
* @param username Set the username for plaintext authentication. Defaults to <code>null</code>.
*
* <p/>
* NOTE: This function has been automatically generated from the [io.vertx.cassandra.CassandraClientOptions original] using Vert.x codegen.
*/
fun cassandraClientOptionsOf(
contactPoints: Map<String, Int>? = null,
keyspace: String? = null,
username: String? = null,
password: String? = null,
tracingPolicy: TracingPolicy? = null,
username: String? = null): CassandraClientOptions = io.vertx.cassandra.CassandraClientOptions().apply {
tracingPolicy: TracingPolicy? = null): CassandraClientOptions = io.vertx.cassandra.CassandraClientOptions().apply {

if (contactPoints != null) {
for (item in contactPoints) {
Expand All @@ -47,14 +47,14 @@ fun cassandraClientOptionsOf(
if (keyspace != null) {
this.setKeyspace(keyspace)
}
if (username != null) {
this.setUsername(username)
}
if (password != null) {
this.setPassword(password)
}
if (tracingPolicy != null) {
this.setTracingPolicy(tracingPolicy)
}
if (username != null) {
this.setUsername(username)
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -20,68 +20,68 @@ import io.vertx.circuitbreaker.CircuitBreakerOptions
/**
* A function providing a DSL for building [io.vertx.circuitbreaker.CircuitBreakerOptions] objects.
*
* Circuit breaker configuration options. All time are given in milliseconds.
* Circuit breaker configuration options. All time values are in milliseconds.
*
* @param failuresRollingWindow Sets the rolling window used for metrics.
* @param fallbackOnFailure Sets whether or not the fallback is executed on failure, even when the circuit is closed.
* @param maxFailures Sets the maximum number of failures before opening the circuit.
* @param maxRetries Configures the number of times the circuit breaker tries to redo the operation before failing.
* @param metricsRollingBuckets Sets the configured number of buckets the rolling window is divided into. The following must be true - metrics.rollingStats.timeInMilliseconds % metrics.rollingStats.numBuckets == 0 - otherwise it will throw an exception. In other words, 10000/10 is okay, so is 10000/20 but 10000/7 is not.
* @param metricsRollingWindow Sets the rolling window used for metrics.
* @param notificationAddress Sets the event bus address on which the circuit breaker publish its state change.
* @param notificationLocalOnly Whether circuit breaker state should be delivered only to local consumers.
* @param notificationPeriod Configures the period in milliseconds where the circuit breaker send a notification on the event bus with its current state.
* @param resetTimeout Sets the time in ms before it attempts to re-close the circuit (by going to the half-open state). If the circuit is closed when the timeout is reached, nothing happens. <code>-1</code> disables this feature.
* @param timeout Sets the timeout in milliseconds. If an action is not completed before this timeout, the action is considered as a failure.
* @param maxFailures Sets the maximum number of failures before opening the circuit breaker.
* @param timeout Sets the timeout in milliseconds. If an action does not complete before this timeout, the action is considered as a failure.
* @param fallbackOnFailure Sets whether the fallback is executed on failure, even when the circuit breaker is closed.
* @param resetTimeout Sets the time in milliseconds before an open circuit breaker moves to half-open (in an attempt to re-close). If the circuit breaker is closed when the timeout is reached, nothing happens. <code>-1</code> disables this feature.
* @param notificationLocalOnly Sets whether circuit breaker state events should be delivered only to local consumers.
* @param notificationAddress Sets the event bus address on which the circuit breaker publishes its state changes.
* @param notificationPeriod Sets the period in milliseconds in which the circuit breaker sends notifications on the event bus with its current state.
* @param metricsRollingWindow Sets the rolling window length used for metrics.
* @param failuresRollingWindow Sets the rolling window length used for failures.
* @param metricsRollingBuckets Sets the number of buckets the metrics rolling window is divided into. <p> The following must be true: <code>metricsRollingWindow % metricsRollingBuckets == 0</code>, otherwise an exception will be thrown. For example, 10000/10 is okay, so is 10000/20, but 10000/7 is not.
* @param maxRetries Sets the number of times the circuit breaker retries an operation before failing.
*
* <p/>
* NOTE: This function has been automatically generated from the [io.vertx.circuitbreaker.CircuitBreakerOptions original] using Vert.x codegen.
*/
fun circuitBreakerOptionsOf(
failuresRollingWindow: Long? = null,
fallbackOnFailure: Boolean? = null,
maxFailures: Int? = null,
maxRetries: Int? = null,
metricsRollingBuckets: Int? = null,
metricsRollingWindow: Long? = null,
notificationAddress: String? = null,
timeout: Long? = null,
fallbackOnFailure: Boolean? = null,
resetTimeout: Long? = null,
notificationLocalOnly: Boolean? = null,
notificationAddress: String? = null,
notificationPeriod: Long? = null,
resetTimeout: Long? = null,
timeout: Long? = null): CircuitBreakerOptions = io.vertx.circuitbreaker.CircuitBreakerOptions().apply {
metricsRollingWindow: Long? = null,
failuresRollingWindow: Long? = null,
metricsRollingBuckets: Int? = null,
maxRetries: Int? = null): CircuitBreakerOptions = io.vertx.circuitbreaker.CircuitBreakerOptions().apply {

if (failuresRollingWindow != null) {
this.setFailuresRollingWindow(failuresRollingWindow)
}
if (fallbackOnFailure != null) {
this.setFallbackOnFailure(fallbackOnFailure)
}
if (maxFailures != null) {
this.setMaxFailures(maxFailures)
}
if (maxRetries != null) {
this.setMaxRetries(maxRetries)
}
if (metricsRollingBuckets != null) {
this.setMetricsRollingBuckets(metricsRollingBuckets)
if (timeout != null) {
this.setTimeout(timeout)
}
if (metricsRollingWindow != null) {
this.setMetricsRollingWindow(metricsRollingWindow)
if (fallbackOnFailure != null) {
this.setFallbackOnFailure(fallbackOnFailure)
}
if (notificationAddress != null) {
this.setNotificationAddress(notificationAddress)
if (resetTimeout != null) {
this.setResetTimeout(resetTimeout)
}
if (notificationLocalOnly != null) {
this.setNotificationLocalOnly(notificationLocalOnly)
}
if (notificationAddress != null) {
this.setNotificationAddress(notificationAddress)
}
if (notificationPeriod != null) {
this.setNotificationPeriod(notificationPeriod)
}
if (resetTimeout != null) {
this.setResetTimeout(resetTimeout)
if (metricsRollingWindow != null) {
this.setMetricsRollingWindow(metricsRollingWindow)
}
if (timeout != null) {
this.setTimeout(timeout)
if (failuresRollingWindow != null) {
this.setFailuresRollingWindow(failuresRollingWindow)
}
if (metricsRollingBuckets != null) {
this.setMetricsRollingBuckets(metricsRollingBuckets)
}
if (maxRetries != null) {
this.setMaxRetries(maxRetries)
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -22,21 +22,21 @@ import io.vertx.config.ConfigChange
*
* A structure representing a configuration change.
*
* @param newConfiguration Sets the new configuration.
* @param previousConfiguration Sets the previous configuration.
* @param newConfiguration Sets the new configuration.
*
* <p/>
* NOTE: This function has been automatically generated from the [io.vertx.config.ConfigChange original] using Vert.x codegen.
*/
fun configChangeOf(
newConfiguration: io.vertx.core.json.JsonObject? = null,
previousConfiguration: io.vertx.core.json.JsonObject? = null): ConfigChange = io.vertx.config.ConfigChange().apply {
previousConfiguration: io.vertx.core.json.JsonObject? = null,
newConfiguration: io.vertx.core.json.JsonObject? = null): ConfigChange = io.vertx.config.ConfigChange().apply {

if (newConfiguration != null) {
this.setNewConfiguration(newConfiguration)
}
if (previousConfiguration != null) {
this.setPreviousConfiguration(previousConfiguration)
}
if (newConfiguration != null) {
this.setNewConfiguration(newConfiguration)
}
}

Original file line number Diff line number Diff line change
Expand Up @@ -25,20 +25,23 @@ import io.vertx.config.ConfigStoreOptions
* retrieved configuration chunk, and you can also configures the store if it needs configuration to
* retrieve the configuration chunk.
*
* @param type Sets the configuration type
* @param config Sets the configuration of the store
* @param format Sets the format of the configuration that is retrieved from the store.
* @param optional Sets whether or not the store is optional. When the configuration is retrieve, if an optional store returns a failure, the failure is ignored and an empty json object is used instead (for this store).
* @param type Sets the configuration type
*
* <p/>
* NOTE: This function has been automatically generated from the [io.vertx.config.ConfigStoreOptions original] using Vert.x codegen.
*/
fun configStoreOptionsOf(
type: String? = null,
config: io.vertx.core.json.JsonObject? = null,
format: String? = null,
optional: Boolean? = null,
type: String? = null): ConfigStoreOptions = io.vertx.config.ConfigStoreOptions().apply {
optional: Boolean? = null): ConfigStoreOptions = io.vertx.config.ConfigStoreOptions().apply {

if (type != null) {
this.setType(type)
}
if (config != null) {
this.setConfig(config)
}
Expand All @@ -48,8 +51,5 @@ fun configStoreOptionsOf(
if (optional != null) {
this.setOptional(optional)
}
if (type != null) {
this.setType(type)
}
}

Loading

0 comments on commit f20a8be

Please sign in to comment.