A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
N
- nak(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
- Negatively acknowledge the message (request redelivery)Tells JetStream that processing failed and the message should be redelivered.
- nakAll(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
- Negatively acknowledge every message in the batch, requesting redeliveryUse this when the whole batch cannot be processed - a database is unavailable, a downstream service is down.
- NatsDsl - class in eu.vstoyanov.natsy
- DSL marker for NATS configuration
- NatsKlient - class in eu.vstoyanov.natsy
- Main entry point for NATS messaging with Kotlin-first APIThis class manages the NATS connection lifecycle and provides access to messaging operations through the NatsScope.
- NatsKlient.Companion - class in eu.vstoyanov.natsy.NatsKlient
- NatsScope - class in eu.vstoyanov.natsy
- Scoped class for NATS messaging operationsAll operations in this scope are tied to the connection lifecycle and will be properly cleaned up when the scope exits.
- NatsyCodecException - class in eu.vstoyanov.natsy.exception
- A payload could not be turned into bytes, or bytes could not be turned into a value.
- NatsyConflictException - class in eu.vstoyanov.natsy.exception
- An optimistic-concurrency expectation was not met.
- NatsyConnectionException - class in eu.vstoyanov.natsy.exception
- The connection could not carry the operation.
- NatsyDecodeException - class in eu.vstoyanov.natsy.exception
- Bytes could not be decoded into the expected type.
- NatsyEncodeException - class in eu.vstoyanov.natsy.exception
- A value could not be encoded for publishing.
- NatsyException - class in eu.vstoyanov.natsy.exception
- Anything that went wrong talking to NATS.
- NatsyIntegrityException - class in eu.vstoyanov.natsy.exception
- What came back is not what was stored.
- NatsyMissingCodecException - class in eu.vstoyanov.natsy.exception
- No codec is registered for the type a call site asked for.
- NatsyNoRespondersException - class in eu.vstoyanov.natsy.exception
- A request was published to a subject nobody is subscribed to.
- NatsyNotFoundException - class in eu.vstoyanov.natsy.exception
- The stream, consumer, bucket, object or message named by the call does not exist.
- NatsyServerException - class in eu.vstoyanov.natsy.exception
- The NATS server rejected the operation.
- NatsyTimeoutException - class in eu.vstoyanov.natsy.exception
- The operation did not complete within the time it was given.
- NEW - enum entry in eu.vstoyanov.natsy.jetstream.model.DeliverPolicy
Deliver only new messages (from now)
- NEW - enum entry in eu.vstoyanov.natsy.jetstream.model.DiscardPolicy
Discard new messages when limits are reached
- NONE - enum entry in eu.vstoyanov.natsy.jetstream.model.AckPolicy
No acknowledgment required (fire-and-forget)