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

G

get(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
Get a typed value for a key
get(java.lang.String,java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
Get a specific revision of a typed value
get(java.lang.String,java.io.OutputStream) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
Stream an object into sinkThe object is written chunk by chunk as it arrives, so nothing larger than one chunk is held: this is the read a Ktor respondOutputStream route wants.
getAckFloor() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How many messages have been acknowledged contiguously from the start
getAckPending() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How many delivered messages are still waiting to be acknowledged
getAckPolicy() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Acknowledgment policy for message processing
getAckPolicy() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Acknowledgment policy for message processing
getAckWait() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
How long to wait for acknowledgment before redelivering
getAckWait() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
How long to wait for acknowledgment before redelivering
getAllowDirect() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Serve reads straight from the stream, without a consumer
getAllowDirect() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Serve reads straight from the stream, without a consumerWhat makes getMessage-shaped lookups and a mirror's local reads a single round trip rather than a consumer created and torn down per call.
getApiErrorCode() - function in eu.vstoyanov.natsy.exception.NatsyServerException
the JetStream API code, e.g.
getApiErrorCode() - function in eu.vstoyanov.natsy.exception.NatsyServerException
the JetStream API code, e.g.
getApiPrefix() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Non-default JetStream API subject prefix - see JetStreamConfigBuilder.apiPrefix
getApiPrefix() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Non-default JetStream API subject prefix, as JetStreamOptions.prefixThis is the subject every JetStream API call is addressed to, which is how a client reaches JetStream in another account.
getBackoff() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Per-attempt redelivery delays, overriding ackWait - see ConsumerConfigBuilder.backoff
getBackoff() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
How long to wait before each redelivery, instead of a fixed ackWaitThe standard poison-message mitigation: listOf(1.seconds, 5.seconds, 30.seconds) retries quickly for a blip and slowly for an outage, and with maxDeliver set it bounds how long a message can keep failing before it is dead-lettered.
getBucket() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The name of the bucket containing this entry
getBucket() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The name of the bucket containing the object
getBucket() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreLink
The bucket the link points at
getBucketName() - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
Get the name of the bucket
getBucketName() - function in eu.vstoyanov.natsy.jetstream.ObjectStore
Get the name of the bucket
getBytes(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
Read a whole object into memoryThe object is materialised: a ByteArray cannot hold more than 2 GiB, and one of any size is one the heap has to carry.
getCause() - function in kotlin.Throwable
 
getChunks() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The number of chunks the object is split into
getChunkSize() - function in eu.vstoyanov.natsy.jetstream.model.ObjectMetadata
Chunk size for streaming (default: 128KB)
getCluster() - function in eu.vstoyanov.natsy.jetstream.PlacementConfig
Cluster name where the object store should be placed
getCluster() - function in eu.vstoyanov.natsy.jetstream.PlacementConfigBuilder
Cluster name where the object store should be placed
getCluster() - function in eu.vstoyanov.natsy.jetstream.model.Placement
Cluster name where the stream should be placed
getCluster() - function in eu.vstoyanov.natsy.jetstream.model.PlacementBuilder
Cluster name where the stream should be placed
getCompression() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Whether the bucket's messages are stored S2-compressed Default: false (no compression)
getCompression() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Whether the bucket's messages are stored S2-compressed Default: false (no compression)Only read when the bucket is created: natsy leaves an existing bucket's configuration alone.
getCompressionOption() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Whether stored messages are compressed (file storage only)
getCompressionOption() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Whether stored messages are compressedFile storage only; a memory stream ignores it.
getConnection() - function in eu.vstoyanov.natsy.NatsKlient
Direct access to the underlying NATS connection for advanced use casesOne jnats behaviour differs from its default here: natsy builds the connection with advancedRequestBehavior(), which is what lets it tell "nobody is subscribed" apart from "nobody answered in time".
getConnectionListener() - function in eu.vstoyanov.natsy.KlientConfig
 
getConnectionListener() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getConnectionTimeout() - function in eu.vstoyanov.natsy.KlientConfig
 
getConnectionTimeout() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getConsumer(java.lang.String,java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Get an existing consumer by name
getConsumer() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
The consumer name (null for ephemeral consumers without explicit names)
getConsumer(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.StreamContext
Get an existing consumer on this stream by name
getConsumerName() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
Name of the consumer
getConsumerSequence() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
Sequence number for this consumer
getContentType() - function in eu.vstoyanov.natsy.codec.BinaryCodec
Content type identifier for this codec
getContentType() - function in eu.vstoyanov.natsy.codec.JsonCodec
Content type identifier for this codec
getContentType() - function in eu.vstoyanov.natsy.codec.MessageCodec
Content type identifier for this codec
getContentType() - function in eu.vstoyanov.natsy.codec.StringCodec
Content type identifier for this codec
getCreated() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The timestamp when this entry was created
getCredentialsPath() - function in eu.vstoyanov.natsy.KlientConfig
 
getCredentialsPath() - function in eu.vstoyanov.natsy.KlientConfigBuilder
Path to a NATS credentials file - the .creds holding a user JWT and its NKey seedA path, not the credential material itself: jnats reads the file on every connect and reconnect, so a rotated file is picked up without rebuilding the klient.
getData() - function in eu.vstoyanov.natsy.model.Message
 
getDefaultAckWait() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Default acknowledgment wait time for consumers
getDefaultAckWait() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default acknowledgment wait time for consumers
getDefaultMaxDeliver() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Default maximum delivery attempts (-1 for unlimited)
getDefaultMaxDeliver() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default maximum delivery attempts (-1 for unlimited)
getDefaultReplayPolicy() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Default replay policy for consumers
getDefaultReplayPolicy() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default replay policy for consumers
getDefaultReplicas() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Default number of replicas for streams
getDefaultReplicas() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default number of replicas for streams
getDefaultRetentionPolicy() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Default retention policy for streams
getDefaultRetentionPolicy() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default retention policy for streams
getDefaults() - function in eu.vstoyanov.natsy.codec.JsonCodec.Companion
The Json every JSON codec natsy builds starts from, and the one to start a hand-built codec from.
getDefaultStorageType() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Default storage type for streams
getDefaultStorageType() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Default storage type for streams
getDeleted() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
Whether the object is deleted
getDelivered() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
Number of times this message has been delivered
getDelivered() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How many messages this consumer has been delivered.
getDeliveredStreamSequence() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How far into the stream delivery has reached.
getDeliverGroup() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Deliver group for queue semantics (push consumers only)
getDeliverGroup() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver group for queue semantics (push consumers only)A deliver group balances among subscribers of one consumer's deliver subject, so it needs a consumer every collector can share - however the group was asked for.
getDeliverPolicy() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Deliver policy determines where to start consuming messages
getDeliverPolicy() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver policy determines where to start consuming messages
getDeliverSubject() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Deliver subject for push consumers
getDeliverSubject() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver subject for push consumers
getDelta() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The number of entries pending after this one (0 means this is the latest)
getDenyDelete() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Refuse per-message deletes on this stream
getDenyDelete() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Refuse per-message deletes on this stream
getDenyPurge() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Refuse purges on this stream
getDenyPurge() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Refuse purges on this stream
getDescription() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Description of the consumer
getDescription() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Description of the consumer
getDescription() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Optional description of the bucket
getDescription() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Optional description of the bucket
getDescription() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
Description of the bucket
getDescription() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Description of the bucket
getDescription() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Description of the stream
getDescription() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Description of the stream
getDescription() - function in eu.vstoyanov.natsy.jetstream.model.ObjectMetadata
Optional description of the object
getDescription() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
Optional description of the object
getDestination() - function in eu.vstoyanov.natsy.jetstream.model.Republish
Subject template the copy is published to
getDestination() - function in eu.vstoyanov.natsy.jetstream.model.RepublishBuilder
Subject template the copy is published toSupports the $1, $2 … tokens matched by wildcards in source, so source = "orders.*" with destination = "mirror.$1" sends orders.created on to mirror.created.
getDigest() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The SHA-256 digest of the object
getDiscardMessagesWhenOutgoingQueueFull() - function in eu.vstoyanov.natsy.KlientConfig
 
getDiscardMessagesWhenOutgoingQueueFull() - function in eu.vstoyanov.natsy.KlientConfigBuilder
Whether a publish that finds the outgoing queue full drops the message instead of waitingThe queue being full means the connection cannot write as fast as the application publishes.
getDiscardPolicy() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Discard policy when limits are reached
getDiscardPolicy() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Discard policy when limits are reached
getDomain() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
JetStream domain name for multi-tenancy
getDomain() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
JetStream domain name for multi-tenancy
getDuplicateWindow() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Window within which to track duplicate messages
getDuplicateWindow() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Window within which to track duplicate messages
getDurable() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Durable name for the consumer If null, the consumer will be ephemeral
getDurable() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Durable name for the consumer If null, the consumer will be ephemeral
getEntries() - function in eu.vstoyanov.natsy.ConnectionStatus
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.CompressionOption
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.ReplayPolicy
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.RetentionPolicy
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.StorageType
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.model.AckPolicy
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.model.DeliverPolicy
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.model.DiscardPolicy
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueOperation
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.model.KvWatchOption
 
getEntries() - function in eu.vstoyanov.natsy.jetstream.model.ObjectWatchOption
 
getEntry() - function in eu.vstoyanov.natsy.jetstream.model.KvWatchEvent.Entry
 
getEphemeral() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
Whether the consumer disappears once it goes inactive
getErrorCode() - function in eu.vstoyanov.natsy.exception.NatsyServerException
the transport-level code jnats reports - 400, 404, 503
getErrorCode() - function in eu.vstoyanov.natsy.exception.NatsyServerException
the transport-level code jnats reports - 400, 404, 503
getErrorListener() - function in eu.vstoyanov.natsy.KlientConfig
 
getErrorListener() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getExpectedLastMsgId() - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected last message ID for ordering validation
getExpectedLastSequence() - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected last sequence number in the stream
getExpectedLastSubjectSequence() - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected last sequence number for this specific subject
getExpectedStream() - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Expected stream name - validates publish went to correct stream
getExternalApiPrefix() - function in eu.vstoyanov.natsy.jetstream.model.StreamSource
External API prefix for external sources
getExternalApiPrefix() - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
External API prefix for external sources
getExternalDeliverPrefix() - function in eu.vstoyanov.natsy.jetstream.model.StreamSource
External deliver prefix for external sources
getExternalDeliverPrefix() - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
External deliver prefix for external sources
getFile(java.lang.String,java.io.File) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
Get an object and write it to a fileStreams the object data to disk rather than loading it into memory, and puts it at file only once the store has verified it.
getFilterSubject() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Filter messages by subject; mutually exclusive with filterSubjects
getFilterSubject() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Filter messages by subjectOne subject; use filterSubjects for several.
getFilterSubject() - function in eu.vstoyanov.natsy.jetstream.model.StreamSource
Optional subject filter for the source stream
getFilterSubject() - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
Optional subject filter for the source stream
getFilterSubjects() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Filter messages by several subjects; mutually exclusive with filterSubject
getFilterSubjects() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Filter messages by several subjectsThe plural form of filterSubject; a consumer over orders.created and orders.cancelled without the orders.updated in between.
getFlowControl() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Enable flow control for push consumersFlow control prevents the server from overwhelming slow consumers.
getFlowControl() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Enable flow control for push consumersFlow control prevents the server from overwhelming slow consumers.
getHasMore() - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
Indicates if there are more messages available to fetch
getHeaders() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
Optional NATS headers attached to the message
getHeaders() - function in eu.vstoyanov.natsy.jetstream.model.ObjectMetadata
Optional headers to attach to the object
getHeaders() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
Optional headers attached to the object
getHeaders() - function in eu.vstoyanov.natsy.model.Message
 
getHeaders() - function in eu.vstoyanov.natsy.model.TypedMessage
the headers the message arrived with, or null if it carried none
getHeadersOnly() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Deliver only headers, not payloads
getHeadersOnly() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Deliver only headers, not payloads
getHeadersOnly() - function in eu.vstoyanov.natsy.jetstream.model.Republish
Republish the headers without the body
getHeadersOnly() - function in eu.vstoyanov.natsy.jetstream.model.RepublishBuilder
Republish the headers without the body
getIdleHeartbeat() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Idle heartbeat interval for push consumersThe server will send heartbeat messages if no data messages are sent within this interval.
getIdleHeartbeat() - 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.
getInactiveThreshold() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Inactivity threshold before consumer is considered inactive
getInactiveThreshold() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Inactivity threshold before consumer is considered inactive
getInfo() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
Get current consumer information, exactly as jnats models itThe escape hatch for anything stats does not carry.
getInfo() - function in eu.vstoyanov.natsy.jetstream.StreamContext
Get current stream information
getInfo() - function in eu.vstoyanov.natsy.jetstream.model.ObjectWatchEvent.Entry
 
getIoDispatcher() - function in eu.vstoyanov.natsy.KlientConfig
 
getIoDispatcher() - function in eu.vstoyanov.natsy.KlientConfigBuilder
The dispatcher every blocking NATS call runs onjnats is a blocking client: management calls, key-value and object-store operations, flushes and fetches all park a thread, so natsy moves them off the caller's.
getJetStream() - function in eu.vstoyanov.natsy.NatsKlient
JetStream, key-value and object-store operationsCreated on first access and reused.
getKey() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The key for this entry
getKeyValue(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Get an existing Key-Value store bucket
getLink() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
What this entry points at, or null when it holds its own bytes.
getLocalizedMessage() - function in kotlin.Throwable
 
getManagement() - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Access to the underlying JetStream management client for administrative operations.
getMaxAckPending() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Maximum number of outstanding unacknowledged messages
getMaxAckPending() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Maximum number of outstanding unacknowledged messages
getMaxAge() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Maximum age of messages to retain (Duration.
getMaxAge() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum age of messages to retain (Duration.
getMaxBatch() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Largest batch a single pull request may ask this consumer for (null = uncapped)
getMaxBatch() - 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.
getMaxBucketSize() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Maximum number of bytes for the entire bucket Default: -1 (unlimited)
getMaxBucketSize() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Maximum number of bytes for the entire bucket Default: -1 (unlimited)
getMaxBucketSize() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
Maximum size of the bucket in bytes (default: -1 = unlimited)
getMaxBucketSize() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Maximum size of the bucket in bytes (default: -1 = unlimited)
getMaxBytes() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Maximum total bytes to retain (-1 for unlimited)
getMaxBytes() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum total bytes to retain (-1 for unlimited)
getMaxConsumers() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Maximum number of consumers allowed on this stream (-1 for unlimited)
getMaxConsumers() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum number of consumers allowed on this stream (-1 for unlimited)
getMaxDeliver() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Maximum number of delivery attempts (-1 for unlimited)
getMaxDeliver() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Maximum number of delivery attempts (-1 for unlimited)
getMaxExpires() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Maximum expiration duration for pull requests
getMaxExpires() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Longest a pull request against this consumer may waitZERO - the default - leaves the limit to the server.
getMaxHistoryPerKey() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
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
getMaxHistoryPerKey() - 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
getMaxMessages() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Maximum number of messages to retain (-1 for unlimited)
getMaxMessages() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum number of messages to retain (-1 for unlimited)
getMaxMessagesInOutgoingQueue() - function in eu.vstoyanov.natsy.KlientConfig
 
getMaxMessagesInOutgoingQueue() - function in eu.vstoyanov.natsy.KlientConfigBuilder
How many messages may wait in the connection's outgoing queuenull leaves jnats' default (5000).
getMaxMessagesPerSubject() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Maximum messages per subject (-1 for unlimited)
getMaxMessagesPerSubject() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum messages per subject (-1 for unlimited)
getMaxMsgSize() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Maximum size of a single message (-1 for unlimited)
getMaxMsgSize() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Maximum size of a single message (-1 for unlimited)
getMaxPullWaiting() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Maximum number of pull requests that may wait on the consumer at once (null = server default)
getMaxPullWaiting() - 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.
getMaxReconnects() - function in eu.vstoyanov.natsy.KlientConfig
 
getMaxReconnects() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getMaxValueSize() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Maximum size in bytes for a single value Default: -1 (server default, typically 1MB)
getMaxValueSize() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Maximum size in bytes for a single value Default: -1 (server default, typically 1MB)
getMemoryStorage() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Enable memory storage for the consumer state
getMemoryStorage() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Enable memory storage for the consumer state
getMessage(java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.StreamContext
Get a specific message by sequence number
getMessage() - function in kotlin.Throwable
 
getMessageId() - function in eu.vstoyanov.natsy.jetstream.PublishExpectations
Message ID for the current message (deduplication)
getMessages() - function in eu.vstoyanov.natsy.SubscriptionHandle
 
getMessages() - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
The list of messages in this batch
getMetadata() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Free-form key-value pairs stored on the consumer
getMetadata() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Free-form key-value pairs stored on the consumerFor whoever has to work out later which deployment created it.
getMirror() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Mirror configuration to mirror another stream
getModified() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
When the store recorded this revision, or null when the value did not come from the server.
getName() - function in eu.vstoyanov.natsy.KlientConfig
 
getName() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getName() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Name for the consumer, without making it durable - see ConsumerConfigBuilder.name
getName() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Name for the consumer, without making it durableA named consumer is still ephemeral - the server reaps it once inactiveThreshold passes - but it is addressable and re-attachable in the meantime, where an unnamed one gets a server-generated name nobody can predict.
getName() - function in eu.vstoyanov.natsy.jetstream.StreamContext
Name of the stream
getName() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
The consumer's name as the server holds it
getName() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The name of the object
getName() - function in eu.vstoyanov.natsy.jetstream.model.StreamSource
Name of the source stream
getName() - function in eu.vstoyanov.natsy.jetstream.model.StreamSourceBuilder
Name of the source stream
getName() - function in kotlin.AckPolicy
 
getName() - function in kotlin.CompressionOption
 
getName() - function in kotlin.ConnectionStatus
 
getName() - function in kotlin.DeliverPolicy
 
getName() - function in kotlin.DiscardPolicy
 
getName() - function in kotlin.KeyValueOperation
 
getName() - function in kotlin.KvWatchOption
 
getName() - function in kotlin.ObjectWatchOption
 
getName() - function in kotlin.ReplayPolicy
 
getName() - function in kotlin.RetentionPolicy
 
getName() - function in kotlin.StorageType
 
getNoAck() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Disable acknowledgments (used for fire-and-forget scenarios)
getNoAck() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Disable acknowledgments (used for fire-and-forget scenarios)
getObjectName() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreLink
The object it points at, or null when the link is to the bucket itself
getObjectStore(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Get an existing Object Store bucket
getOperation() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The operation type (PUT, DELETE, PURGE)
getOrdinal() - function in kotlin.AckPolicy
 
getOrdinal() - function in kotlin.CompressionOption
 
getOrdinal() - function in kotlin.ConnectionStatus
 
getOrdinal() - function in kotlin.DeliverPolicy
 
getOrdinal() - function in kotlin.DiscardPolicy
 
getOrdinal() - function in kotlin.KeyValueOperation
 
getOrdinal() - function in kotlin.KvWatchOption
 
getOrdinal() - function in kotlin.ObjectWatchOption
 
getOrdinal() - function in kotlin.ReplayPolicy
 
getOrdinal() - function in kotlin.RetentionPolicy
 
getOrdinal() - function in kotlin.StorageType
 
getPassword() - function in eu.vstoyanov.natsy.KlientConfig
 
getPassword() - function in eu.vstoyanov.natsy.KlientConfigBuilder
Password for username, held the way token is
getPaused() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
Whether delivery is currently paused
getPaused() - function in eu.vstoyanov.natsy.jetstream.model.PauseResponse
Whether the consumer is paused - always true for a successful pause
getPauseRemaining() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How long the pause still has to run, or null when the consumer is not paused or is paused until an explicit resume()
getPauseUntil() - function in eu.vstoyanov.natsy.jetstream.model.PauseResponse
When the consumer will be automatically resumed, or null when it stays paused until explicitly resumed
getPayload() - function in eu.vstoyanov.natsy.exception.NatsyDecodeException
the bytes that failed, kept for diagnostics.
getPayload() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
The decoded message payload
getPayload() - function in eu.vstoyanov.natsy.model.TypedMessage
the decoded message
getPending() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How many messages the stream still holds for this consumer
getPendingCount() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
Number of messages pending for this consumer (0 if unknown)
getPingInterval() - function in eu.vstoyanov.natsy.KlientConfig
 
getPingInterval() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getPlacement() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Placement constraints for the bucket Only relevant in cluster mode
getPlacement() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
Placement configuration for clustering
getPlacement() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Placement configuration for clustering
getPushBound() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
Whether a push subscription is currently attached
getRateLimit() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Rate limit in bits per second (-1 for unlimited)
getRateLimit() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Rate limit in bits per second (-1 for unlimited)
getReconnectBufferSize() - function in eu.vstoyanov.natsy.KlientConfig
 
getReconnectBufferSize() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getReconnectOnConnect() - function in eu.vstoyanov.natsy.KlientConfig
 
getReconnectOnConnect() - function in eu.vstoyanov.natsy.KlientConfigBuilder
Whether NatsKlient.connect waits for a server that is not up yetWith the default false, connecting is a single pass over servers: it either succeeds or throws, which is what a fail-fast startup wants.
getReconnectWait() - function in eu.vstoyanov.natsy.KlientConfig
 
getReconnectWait() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getRedelivered() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How many messages have been delivered more than once
getReplayPolicy() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Replay policy for message delivery
getReplayPolicy() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Replay policy for message delivery
getReplicas() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Number of replicas for the consumer (-1 for stream default)
getReplicas() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Number of replicas for the consumer (-1 for stream default)
getReplicas() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Number of replicas for the bucket (cluster mode) Default: 1 (single replica)For high availability, set to 3 or more (odd numbers recommended)
getReplicas() - 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)
getReplicas() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
Number of replicas (default: 1)
getReplicas() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Number of replicas (default: 1)
getReplicas() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Number of replicas for the stream (1-5)
getReplicas() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Number of replicas for the stream (1-5)
getReplyTo() - function in eu.vstoyanov.natsy.model.Message
 
getReplyTo() - function in eu.vstoyanov.natsy.model.TypedMessage
the subject a reply is expected on, or null for a message that is not a request
getRepublish() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Republish a copy of every matching message on a subject of its own
getRequestCleanupInterval() - function in eu.vstoyanov.natsy.KlientConfig
 
getRequestCleanupInterval() - function in eu.vstoyanov.natsy.KlientConfigBuilder
How often the connection reaps unanswered request inboxesA JetStream publish future has no per-call deadline of its own: jnats hands it a null timeout (NatsJetStream.java:171) and falls back to this interval (NatsConnection.java:1484-1486).
getRequestTimeout() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
How long a JetStream API call waits for the server, including a publish waiting for its ack
getRequestTimeout() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
How long a JetStream API call waits for the server, including a publish waiting for its ackA publish is awaited against this deadline, but the future jnats actually uses is cleaned up on eu.vstoyanov.natsy.KlientConfigBuilder.requestCleanupInterval.
getRetentionPolicy() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Retention policy for the stream
getRetentionPolicy() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Retention policy for the stream
getRevision() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The revision number of this entry
getSampleFrequency() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Sample frequency for metrics (0-100, 0 = disabled)
getSampleFrequency() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Sample frequency for metrics (0-100, 0 = disabled)
getServers() - function in eu.vstoyanov.natsy.KlientConfig
 
getServers() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getSize() - function in eu.vstoyanov.natsy.jetstream.JetStreamBatch
The number of messages in this batch
getSize() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The size of the object in bytes
getSource() - function in eu.vstoyanov.natsy.exception.NatsyDecodeException
where the bytes came from, in a form a log line can use directly - "subject orders.created", "a reply to 'orders.ask'", "key user:1 in bucket prefs".
getSource() - function in eu.vstoyanov.natsy.jetstream.model.Republish
Subject filter selecting which published messages are republished
getSource() - function in eu.vstoyanov.natsy.jetstream.model.RepublishBuilder
Subject filter selecting which published messages are republishednull - the default - republishes everything the stream captures.
getSources() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
List of sources to aggregate from multiple streams
getStackTrace() - function in kotlin.Throwable
 
getStartSequence() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Start sequence for BY_START_SEQUENCE deliver policy
getStartSequence() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Start sequence for BY_START_SEQUENCE deliver policy
getStartTime() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Start time for BY_START_TIME deliver policy
getStartTime() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Start time for BY_START_TIME deliver policy
getStatistics() - function in eu.vstoyanov.natsy.NatsKlient
Access to connection statistics
getStatus() - function in eu.vstoyanov.natsy.NatsKlient
What the connection is currently doingUnlike connection this never throws: before connect it reports ConnectionStatus.DISCONNECTED.
getStorageType() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Storage type for the bucket Default: StorageType.FILE for persistence
getStorageType() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Storage type for the bucket Default: StorageType.FILE for persistence
getStorageType() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
Storage type for the bucket Default: StorageType.FILE for persistence
getStorageType() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Storage type for the bucket Default: StorageType.FILE for persistence
getStorageType() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Storage type for the stream
getStorageType() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
Storage type for the stream
getStream(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
Get an existing stream by name
getStream() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
The JetStream stream name
getStream() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
The stream the consumer reads from
getStreamName() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
Name of the stream this consumer belongs to
getStreamSequence() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
Sequence number in the stream
getSubject() - function in eu.vstoyanov.natsy.codec.DecodeErrorStrategy.DeadLetter
 
getSubject() - function in eu.vstoyanov.natsy.exception.NatsyNoRespondersException
the request subject that had no responder, or null when natsy does not know it.
getSubject() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
The NATS subject the message was published to
getSubject() - function in eu.vstoyanov.natsy.model.Message
 
getSubject() - function in eu.vstoyanov.natsy.model.TypedMessage
the subject this message was published to, which for a wildcard or queue subscription is not the subject that was subscribed to
getSubjects() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
getSubjects() - function in eu.vstoyanov.natsy.jetstream.StreamConfigBuilder
List of subjects this stream listens toSupports wildcards (e.g., "orders.*", "payments.>").
getSuppressed() - function in kotlin.Throwable
 
getTags() - function in eu.vstoyanov.natsy.jetstream.PlacementConfig
Tags for placement (e.g.
getTags() - function in eu.vstoyanov.natsy.jetstream.PlacementConfigBuilder
Tags for placement (e.g.
getTags() - function in eu.vstoyanov.natsy.jetstream.model.Placement
List of tags for placement constraints
getTags() - function in eu.vstoyanov.natsy.jetstream.model.PlacementBuilder
List of tags for placement constraints
getTargetType() - function in eu.vstoyanov.natsy.exception.NatsyDecodeException
the type the decode was aiming for, when known
getTimestamp() - function in eu.vstoyanov.natsy.jetstream.JetStreamMessage
When the message was originally published
getTlsContext() - function in eu.vstoyanov.natsy.KlientConfig
 
getTlsContext() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getToken() - function in eu.vstoyanov.natsy.KlientConfig
 
getToken() - function in eu.vstoyanov.natsy.KlientConfigBuilder
Authentication token, held the way password isCharArray rather than String so the secret can be zeroed after connecting; jnats takes char[] here too and has deprecated its String overload (io/nats/client/Options.java:1952).
getTtl() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
Time-to-live for entries in the bucket Default: Duration.
getTtl() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Time-to-live for entries in the bucket Default: Duration.
getTtl() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
TTL for objects in the bucket (default: no expiration)
getTtl() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
TTL for objects in the bucket (default: no expiration)
getType() - function in eu.vstoyanov.natsy.exception.NatsyEncodeException
the type that failed to encode
getType() - function in eu.vstoyanov.natsy.exception.NatsyMissingCodecException
the type that cannot be carried
getUsername() - function in eu.vstoyanov.natsy.KlientConfig
 
getUsername() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getValue() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The typed value.
getWaitingPulls() - function in eu.vstoyanov.natsy.jetstream.model.ConsumerStats
How many pull requests are parked waiting for messages
A  B  C  D  E  F  G  H  I  J  K  L  M  N  O  P  R  S  T  U  V  W