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

S

session(kotlin.coroutines.SuspendFunction1) - function in eu.vstoyanov.natsy.NatsKlient
Execute operations against a NatsScope whose lifetime is exactly blockThe scope owns a child Job of the calling coroutine, so everything launched into it — subscriptions above all — is cancelled and awaited when block returns, before the scope's jnats dispatchers are closed.
setAckPolicy(eu.vstoyanov.natsy.jetstream.model.AckPolicy) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Acknowledgment policy for message processing
setAckWait(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
How long to wait for acknowledgment before redelivering
setCluster(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PlacementConfigBuilder
Cluster name where the object store should be placed
setCluster(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.PlacementBuilder
Cluster name where the stream should be placed
setCompression(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Compression option for the bucket Default: false (no compression)
setConnectionListener(io.nats.client.ConnectionListener) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setConnectionTimeout(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setCredentials(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setDefaultAckWait(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default acknowledgment wait time for consumers
setDefaultMaxDeliver(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default maximum delivery attempts (-1 for unlimited)
setDefaultReplayPolicy(eu.vstoyanov.natsy.jetstream.ReplayPolicy) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default replay policy for consumers
setDefaultReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default number of replicas for streams
setDefaultRetentionPolicy(eu.vstoyanov.natsy.jetstream.RetentionPolicy) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default retention policy for streams
setDefaultStorageType(eu.vstoyanov.natsy.jetstream.StorageType) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default storage type for streams
setDeliverGroup(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver group for queue semantics (push consumers only)
setDeliverPolicy(eu.vstoyanov.natsy.jetstream.model.DeliverPolicy) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver policy determines where to start consuming messages
setDeliverSubject(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver subject for push consumers
setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Description of the consumer
setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Optional description of the bucket
setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Description of the bucket
setDescription(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Description of the stream
setDiscardPolicy(eu.vstoyanov.natsy.jetstream.model.DiscardPolicy) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Discard policy when limits are reached
setDomain(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
JetStream domain name for multi-tenancy
setDuplicateWindow(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Window within which to track duplicate messages
setDurable(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Durable name for the consumer If null, the consumer will be ephemeral
setErrorListener(io.nats.client.ErrorListener) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setExpectedLastMsgId(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected last message ID for ordering validation
setExpectedLastSequence(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected last sequence number in the stream
setExpectedLastSubjectSequence(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected last sequence number for this specific subject
setExpectedStream(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected stream name - validates publish went to correct stream
setExternalApiPrefix(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
External API prefix for external sources
setExternalDeliverPrefix(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
External deliver prefix for external sources
setFilterSubject(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Filter messages by subject
setFilterSubject(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
Optional subject filter for the source stream
setFlowControl(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Enable flow control for push consumersFlow control prevents the server from overwhelming slow consumers.
setHeadersOnly(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver only headers, not payloads
setIdleHeartbeat(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Idle heartbeat interval for push consumersThe server will send heartbeat messages if no data messages are sent within this interval.
setInactiveThreshold(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Inactivity threshold before consumer is considered inactive
setMaxAckPending(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Maximum number of outstanding unacknowledged messages
setMaxAge(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum age of messages to retain (Duration.
setMaxBatch(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Largest batch a single pull request may ask this consumer fornull - the default - leaves the limit to the server, which does not cap batches.
setMaxBucketSize(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Maximum number of bytes for the entire bucket Default: -1 (unlimited)
setMaxBucketSize(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Maximum size of the bucket in bytes (default: -1 = unlimited)
setMaxBytes(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum total bytes to retain (-1 for unlimited)
setMaxConsumers(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum number of consumers allowed on this stream (-1 for unlimited)
setMaxDeliver(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Maximum number of delivery attempts (-1 for unlimited)
setMaxExpires(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Maximum expiration duration for pull requests
setMaxHistoryPerKey(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Maximum number of history entries per key (includes current value) Default: 1 (only keep current value) Set to higher value to track history of changes
setMaxMessages(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum number of messages to retain (-1 for unlimited)
setMaxMessagesPerSubject(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum messages per subject (-1 for unlimited)
setMaxMsgSize(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum size of a single message (-1 for unlimited)
setMaxPullWaiting(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Maximum number of pull requests that may wait on the consumer at oncenull - the default - leaves the limit to the server, which allows 512.
setMaxReconnects(java.lang.Integer) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setMaxValueSize(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Maximum size in bytes for a single value Default: -1 (server default, typically 1MB)
setMaxWaitMillis(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Maximum wait time in milliseconds for pull consumers
setMemoryStorage(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Enable memory storage for the consumer state
setMessageId(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Message ID for the current message (deduplication)
setName(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setName(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
Name of the source stream
setNoAck(java.lang.Boolean) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Disable acknowledgments (used for fire-and-forget scenarios)
setPassword(kotlin.CharArray) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setPingInterval(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setRateLimit(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Rate limit in bits per second (-1 for unlimited)
setReconnectBufferSize(java.lang.Integer) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setReconnectWait(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setReplayPolicy(eu.vstoyanov.natsy.jetstream.ReplayPolicy) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Replay policy for message delivery
setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Number of replicas for the consumer (-1 for stream default)
setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Number of replicas for the bucket (cluster mode) Default: 1 (single replica)For high availability, set to 3 or more (odd numbers recommended)
setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Number of replicas (default: 1)
setReplicas(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Number of replicas for the stream (1-5)
setRequestCleanupInterval(kotlin.time.Duration) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setRequestTimeout(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Request timeout for JetStream API calls
setRetentionPolicy(eu.vstoyanov.natsy.jetstream.RetentionPolicy) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Retention policy for the stream
setSampleFrequency(java.lang.Integer) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Sample frequency for metrics (0-100, 0 = disabled)
setServers(java.util.List) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setStackTrace(kotlin.Array) - function in kotlin.Throwable
 
setStartSequence(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Start sequence for BY_START_SEQUENCE deliver policy
setStartTime(java.time.ZonedDateTime) - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Start time for BY_START_TIME deliver policy
setStorageType(io.nats.client.api.StorageType) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Storage type for the bucket Default: FILE for persistenceOptions:

  • io.nats.client.api.StorageType.File: Persistent storage

  • io.nats.client.api.StorageType.Memory: In-memory only (faster but not durable)

setStorageType(io.nats.client.api.StorageType) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Storage type (FILE or MEMORY)
setStorageType(eu.vstoyanov.natsy.jetstream.StorageType) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Storage type for the stream
setStreamPrefix(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Optional prefix for stream names
setSubjects(java.util.List) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
setTags(java.util.List) - function in eu.vstoyanov.natsy.jetstream.PlacementConfigBuilder
Tags for placement (e.g.
setTags(java.util.List) - function in eu.vstoyanov.natsy.jetstream.model.PlacementBuilder
List of tags for placement constraints
setTlsContext(javax.net.ssl.SSLContext) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setToken(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
setTtl(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Time-to-live for entries in the bucket Default: Duration.
setTtl(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
TTL for objects in the bucket (default: no expiration)
setUsername(java.lang.String) - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
source(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Add a source stream for aggregation
started(kotlin.time.Duration) - function in eu.vstoyanov.natsy.SubscriptionHandle
Suspends until this subscription is live on the server: until messages has been collected, registering the SUB, and until the server has acknowledged it.
status() - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
Get the status of the bucket
status() - function in eu.vstoyanov.natsy.jetstream.ObjectStore
Get the status of the bucket
StorageType - class in eu.vstoyanov.natsy.jetstream
Stream storage type
stream(java.lang.String,kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Create or update a JetStream streamIf the stream doesn't exist, a new one is created from the configuration block.
StreamConfig - class in eu.vstoyanov.natsy.jetstream
DSL for configuring JetStream streamsExample usage:
val streamCtx = js.stream("MY_STREAM") {
    subjects = listOf("orders.*", "payments.*")
    retentionPolicy = RetentionPolicy.LIMITS
    maxMessages = 1000000
    maxBytes = 1024 * 1024 * 1024 // 1GB
    storageType = StorageType.FILE
    replicas = 3
}
StreamConfigBuilder - class in eu.vstoyanov.natsy.jetstream
Builder for JetStream stream configuration
StreamContext - class in eu.vstoyanov.natsy.jetstream
Context for JetStream stream operationsProvides access to stream management and operations including:

  • Stream information and updates

  • Message purging and deletion

  • Consumer listing

Example usage:
val streamCtx = js.stream("MY_STREAM") {
    subjects = listOf("orders.*")
    maxMessages = 1000
}.getOrThrow()

// Update the stream
streamCtx.update {
    maxMessages = 2000
}

// Purge every message
streamCtx.purge()

// Purge a single subject, or a subtree with "orders.>"
streamCtx.purge("orders.cancelled")

// List consumers
streamCtx.consumers().collect { consumer ->
    println(consumer.name)
}
streams() - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
List all streams in the JetStream accountReturns a Flow that emits StreamContext for each stream.
StreamSource - class in eu.vstoyanov.natsy.jetstream.model
Stream source configuration for stream aggregationUsed to aggregate messages from other streams or external sources.
StreamSourceBuilder - class in eu.vstoyanov.natsy.jetstream.model
Builder for StreamSource configuration
StringCodec - class in eu.vstoyanov.natsy.codec
Simple string codec for text messages
subscribe(java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsScope
Subscribe with reified type parameter for better ergonomicsMessages are delivered through a channel of capacity slots and decoded downstream of it.
subscribe(java.lang.String,kotlin.reflect.KClass,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.NatsScope
Subscribe to a subject with typed messagesMessages are delivered through a channel of capacity slots and decoded downstream of it.
subscribe(java.lang.String,java.lang.String,java.lang.String,java.lang.String,kotlin.jvm.functions.Function1,java.lang.Integer,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Subscribe to a JetStream stream with a push consumerCreates an ephemeral push consumer and returns a Flow of typed messages.
subscribeBytes(java.lang.String,java.lang.String,java.lang.Integer,kotlinx.coroutines.channels.BufferOverflow) - function in eu.vstoyanov.natsy.NatsScope
Subscribe to raw messages for performanceThe jnats dispatcher hands messages to a channel of capacity slots without ever suspending.
SubscriptionHandle - class in eu.vstoyanov.natsy
One subscription, and the rendezvous that tells you it exists.
A  B  C  D  E  F  G  H  I  J  K  L  M  N  O  P  R  S  T  U  V  W