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

M

MEMORY - enum entry in eu.vstoyanov.natsy.jetstream.StorageType

Memory-based storage

Message - class in eu.vstoyanov.natsy.model

Message wrapper for raw subscriptions

MessageCodec - class in eu.vstoyanov.natsy.codec

Turns values of one type into bytes on the wire and back.

messageId(java.lang.String) - function in eu.vstoyanov.natsy.jetstream.PublishExpectations.Companion

Set message ID for the current message (deduplication)

META_ONLY - enum entry in eu.vstoyanov.natsy.jetstream.model.KvWatchOption

Ask the server for headers only, so no entry carries a value

Sets headersOnly on the watch consumer (io/nats/client/impl/NatsKeyValueWatchSubscription.java:46), so KeyValueEntry.value is null on every entry, PUT included, while KeyValueEntry.operation and KeyValueEntry.revision still arrive.

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

Configure mirror to replicate another stream

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