R-index

A B C D E F G H I J K L M N O P R S T U V W

R

raw(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder

Reach a jnats consumer setting this DSL does not modelConsumerConfiguration.Builder carries more than natsy has an opinion about; maxBytes, priorityGroups, priorityPolicy and pauseUntil are all reachable here rather than being unreachable until natsy grows a property for each.

raw(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Reach a jnats stream setting this DSL does not modelStreamConfiguration.Builder carries more than natsy has an opinion about; subjectTransform, consumerLimits, allowRollup, mirrorDirect, firstSequence and metadata are all reachable here rather than being unreachable until natsy grows a property for each.

RECONNECTING - enum entry in eu.vstoyanov.natsy.ConnectionStatus

The connection dropped and jnats is working through the server list to restore it

register(eu.vstoyanov.natsy.codec.MessageCodec) - function in eu.vstoyanov.natsy.codec.CodecRegistry.Builder

Carry T with codec instead of JSON.

registerJson(kotlinx.serialization.KSerializer) - function in eu.vstoyanov.natsy.codec.CodecRegistry.Builder

Carry T as JSON using serializer rather than the one derived from the type.

remainingDeliveries(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage

Calculate remaining delivery attempts

ReplayPolicy - class in eu.vstoyanov.natsy.jetstream

Consumer replay policy

republish(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder

Configure republishing

republish {
    source = "orders.*"
    destination = "mirror.$1"
}

Republish - class in eu.vstoyanov.natsy.jetstream.model

Republish configuration: a copy of every matching message, on a subject of its ownThe copy is a plain core-NATS message rather than a stream message, so a subscriber gets it without a consumer - which is how a stream feeds a cache or an audit listener that must not acknowledge anything.

RepublishBuilder - class in eu.vstoyanov.natsy.jetstream.model

Builder for Republish configuration

request(eu.vstoyanov.natsy.NatsOperations,java.lang.String,Req,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsOperationsKt

Request-reply pattern with typed messages

requestMany(eu.vstoyanov.natsy.NatsOperations,java.lang.String,Req,java.lang.Integer,kotlin.time.Duration,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsOperationsKt

Request-many pattern (scatter-gather)Sends a request to multiple responders and collects all responses until timeout or expectedResponses count is reached.

requestManyTyped(java.lang.String,Req,kotlin.reflect.KType,kotlin.reflect.KType,java.lang.Integer,kotlin.time.Duration,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsKlient

requestMany with both types given as values.

requestTyped(java.lang.String,Req,kotlin.reflect.KType,kotlin.reflect.KType,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsKlient

request with both types given as values.

requestTyped(java.lang.String,Req,kotlin.reflect.KType,kotlin.reflect.KType,kotlin.time.Duration) - function in eu.vstoyanov.natsy.NatsOperations

request with both types given as values.

respond(eu.vstoyanov.natsy.NatsOperations,java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy,kotlin.coroutines.SuspendFunction1) - function in eu.vstoyanov.natsy.NatsOperationsKt

Answer typed requests on subjectThe other half of request: decode the request, compute a response, publish it to the subject the caller is listening on.

respondTyped(java.lang.String,kotlin.reflect.KType,kotlin.reflect.KType,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy,kotlin.coroutines.SuspendFunction1) - function in eu.vstoyanov.natsy.NatsKlient

respond with both types given as values.

resume() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext

Resume the consumerResumes message delivery to a paused consumer.

RetentionPolicy - class in eu.vstoyanov.natsy.jetstream

Stream retention policy

A B C D E F G H I J K L M N O P R S T U V W