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

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(eu.vstoyanov.natsy.NatsOperations,java.lang.String,T,io.nats.client.impl.Headers) - function in eu.vstoyanov.natsy.NatsOperationsKt

Publish a typed message, serializing it with the codec for TAny @Serializable type works with no registration; see eu.vstoyanov.natsy.codec.CodecRegistry for what else does and how to override it.

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 expectationsSuspends until the server acknowledges the message.

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

Publish raw bytes for performance-critical pathsHands the message to the connection's outgoing queue and returns without waiting for the server.

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

Publish raw bytes for performance-critical pathsHands the message to the connection's outgoing queue and returns without waiting for the server.

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 JetStreamSuspends until the server acknowledges the message.

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

 

publishTyped(java.lang.String,T,kotlin.reflect.KType,io.nats.client.impl.Headers) - function in eu.vstoyanov.natsy.NatsKlient

publish with the type to carry message as given as a value.

publishTyped(java.lang.String,T,kotlin.reflect.KType,io.nats.client.impl.Headers) - function in eu.vstoyanov.natsy.NatsOperations

publish with the type to carry message as given as a value.

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.

PURGE - enum entry in eu.vstoyanov.natsy.jetstream.model.KeyValueOperation

The key and its history were 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

PUT - enum entry in eu.vstoyanov.natsy.jetstream.model.KeyValueOperation

A value was written

putFile(java.io.File,java.lang.String,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