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) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
Get an object from the storeReturns an ObjectResult with a ByteArray of the data.
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
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
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
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
Compression option for the bucket Default: false (no compression)
getCompression() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder
Compression option for the bucket Default: false (no compression)
getConnection() - function in eu.vstoyanov.natsy.NatsKlient
Direct access to the underlying NATS connection for advanced use cases
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
getCoroutineContext() - function in eu.vstoyanov.natsy.NatsScope
 
getCreated() - function in eu.vstoyanov.natsy.jetstream.model.KeyValueEntry
The timestamp when this entry was created
getCredentials() - function in eu.vstoyanov.natsy.KlientConfig
 
getCredentials() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
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
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
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)
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)
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
getDigest() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The SHA-256 digest of the object
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.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
 
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 directly to the file, avoiding loading the entire object into memory.
getFilterSubject() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfig
Filter messages by subject
getFilterSubject() - function in eu.vstoyanov.natsy.jetstream.ConsumerConfigBuilder
Filter messages by subject
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
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
 
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
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
getInfo() - function in eu.vstoyanov.natsy.jetstream.StreamContext
Get current stream information
getInfo() - function in eu.vstoyanov.natsy.jetstream.model.ObjectResult
The object information
getInputStream() - function in eu.vstoyanov.natsy.jetstream.model.ObjectResult
The input stream for reading the object data
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
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
Maximum expiration duration for pull requests
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)
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)
getMaxWaitMillis() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Maximum wait time in milliseconds for pull consumers
getMaxWaitMillis() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Maximum wait time in milliseconds for pull consumers
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
getMirror() - function in eu.vstoyanov.natsy.jetstream.StreamConfig
Mirror configuration to mirror another stream
getModified() - function in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
The timestamp when the object was last modified
getName() - function in eu.vstoyanov.natsy.KlientConfig
 
getName() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getName() - function in eu.vstoyanov.natsy.jetstream.StreamContext
Name of the stream
getName() - function in eu.vstoyanov.natsy.jetstream.model.ObjectMetadata
The name of the object
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.DeliverPolicy
 
getName() - function in kotlin.DiscardPolicy
 
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)
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.DeliverPolicy
 
getOrdinal() - function in kotlin.DiscardPolicy
 
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
 
getPaused() - function in eu.vstoyanov.natsy.jetstream.model.PauseResponse
Whether the consumer is paused - always true for a successful pause
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.jetstream.JetStreamMessage
The decoded message payload
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
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
 
getReconnectWait() - function in eu.vstoyanov.natsy.KlientConfig
 
getReconnectWait() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
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
 
getRequestCleanupInterval() - function in eu.vstoyanov.natsy.KlientConfig
 
getRequestCleanupInterval() - function in eu.vstoyanov.natsy.KlientConfigBuilder
 
getRequestTimeout() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Request timeout for JetStream API calls
getRequestTimeout() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Request timeout for JetStream API calls
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)
getScope() - function in eu.vstoyanov.natsy.NatsKlient
Persistent scope for long-lived operations (subscriptions, consumers, etc.
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
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
getStatistics() - function in eu.vstoyanov.natsy.NatsScope
 
getStorageType() - function in eu.vstoyanov.natsy.jetstream.KeyValueConfig
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)

getStorageType() - 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)

getStorageType() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfig
Storage type (FILE or MEMORY)
getStorageType() - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder
Storage type (FILE or MEMORY)
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
getStreamName() - function in eu.vstoyanov.natsy.jetstream.ConsumerContext
Name of the stream this consumer belongs to
getStreamPrefix() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfig
Optional prefix for stream names
getStreamPrefix() - function in eu.vstoyanov.natsy.jetstream.JetStreamConfigBuilder
Optional prefix for stream names
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.jetstream.JetStreamMessage
The NATS subject the message was published to
getSubject() - function in eu.vstoyanov.natsy.model.Message
 
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 to Supports 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
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
 
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)
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 (null for DELETE/PURGE operations)
A  B  C  D  E  F  G  H  I  J  K  L  M  N  O  P  R  S  T  U  V  W