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

P

pause(java.time.Instant) - function in eu.vstoyanov.natsy.jetstream.ConsumerContext

Pause the consumerTemporarily pauses message delivery to the consumer.

pause(kotlin.time.Duration) - function in eu.vstoyanov.natsy.jetstream.ConsumerContext

Pause the consumer for a durationConvenience over pause with an absolute deadline.

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

Response from pause operation

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

Get the count of pending messages (messages waiting to be delivered)

placement(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.KeyValueConfigBuilder

Configure placement constraintsExample:

placement {
    cluster = "east-cluster"
    tags = listOf("ssd", "high-memory")
}

placement(kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.ObjectStoreConfigBuilder

Configure placement for clustering

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

Configure placement for the stream

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

Placement configuration for stream clusteringControls where a stream is placed within a NATS cluster.

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

Builder for Placement configuration

PlacementConfig - class in eu.vstoyanov.natsy.jetstream

Placement configuration for object store clustering

PlacementConfigBuilder - class in eu.vstoyanov.natsy.jetstream

Builder for placement configuration for object store clustering

printStackTrace() - function in kotlin.Throwable

 

printStackTrace(java.io.PrintStream) - function in kotlin.Throwable

 

printStackTrace(java.io.PrintWriter) - function in kotlin.Throwable

 

publish(java.lang.String,T,io.nats.client.impl.Headers) - function in eu.vstoyanov.natsy.NatsScope

Publish with reified type parameter for better ergonomicsThis operation is non-blocking and thread-safe.

publish(java.lang.String,T,kotlin.reflect.KClass,io.nats.client.impl.Headers) - function in eu.vstoyanov.natsy.NatsScope

Publish a typed message with automatic serializationThis operation is non-blocking and thread-safe.

publish(java.lang.String,T,io.nats.client.impl.Headers,eu.vstoyanov.natsy.jetstream.PublishExpectations) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext

Publish a typed message to JetStream with optional expectationsUses Dispatchers.IO because JetStream publish operations block waiting for PublishAck from the server.

publishBytes(java.lang.String,kotlin.ByteArray,io.nats.client.impl.Headers) - function in eu.vstoyanov.natsy.NatsScope

Publish raw bytes for performance-critical pathsThis operation is non-blocking and thread-safe.

publishBytes(java.lang.String,kotlin.ByteArray,io.nats.client.impl.Headers,eu.vstoyanov.natsy.jetstream.PublishExpectations) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext

Publish raw bytes to JetStreamUses Dispatchers.IO because JetStream publish operations block waiting for PublishAck from the server.

PublishExpectations - class in eu.vstoyanov.natsy.jetstream

Expectations for JetStream publishing to ensure message ordering and deduplication

PublishExpectations.Companion - class in eu.vstoyanov.natsy.jetstream.PublishExpectations

 

pull(java.lang.String,java.lang.String,java.lang.Integer,kotlin.time.Duration,java.lang.Boolean,kotlin.jvm.functions.Function1,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext

Create a pull consumer that fetches messages in batchesCreates a durable pull consumer and returns a Flow of message batches.

purge(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore

Purge all history for a key (hard delete)

purge(java.lang.String,java.lang.Long) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore

Purge a key only if the expected revision matches

purge(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.StreamContext

Purge messages from the streamWithout a subject every message in the stream is removed.

put(java.lang.String,T) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore

Put a typed value for a key

put(java.lang.String,kotlin.ByteArray,eu.vstoyanov.natsy.jetstream.model.ObjectMetadata) - function in eu.vstoyanov.natsy.jetstream.ObjectStore

Put an object with byte array data

putFile(java.lang.String,java.io.File,eu.vstoyanov.natsy.jetstream.model.ObjectMetadata) - function in eu.vstoyanov.natsy.jetstream.ObjectStore

Put an object from a fileStreams the file content to the object store in chunks, avoiding loading the entire file into memory.

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