A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
W
- watch(java.lang.String,java.util.Set,java.lang.Long,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Watch for changes to a specific keyThe watch opens by replaying the latest revision of every matching key - not the whole history (
io/nats/client/impl/NatsKeyValueWatchSubscription.java:41) - and then emits a KeyValueEntry on every change. - watch(java.util.List,java.util.Set,java.lang.Long,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Watch several keys, or key patterns, through one subscriptionOne consumer covers them all, so the entries arrive interleaved in server order rather than as several independent flows.
- watch(java.util.Set) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
- Watch for changes to objects in the bucketOpens by replaying the latest revision of every object - the bucket as it stands - and then emits an ObjectStoreInfo on every change.
- watchAll(java.util.Set,java.lang.Long,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Watch for changes to all keys in the bucketThe watch buffer is unbounded so no revision is dropped on its way to the collector.
- watchEvents(java.util.List,java.util.Set,java.lang.Long,eu.vstoyanov.natsy.codec.DecodeErrorStrategy) - function in eu.vstoyanov.natsy.jetstream.KeyValueStore
- Watch, and be told when the opening replay is overThe same subscription watch and watchAll open, with one more element in it: every revision arrives as KvWatchEvent.Entry, and KvWatchEvent.InitialSyncComplete marks the point where the bucket's existing contents end and live changes begin.
- watchEvents(java.util.Set) - function in eu.vstoyanov.natsy.jetstream.ObjectStore
- Watch, with the end of the opening replay markedThe same watch as watch, with one element added: every revision arrives as ObjectWatchEvent.Entry, and ObjectWatchEvent.InitialSyncComplete marks the point where the bucket's existing contents end and live changes begin.
- willAutoResume() - function in eu.vstoyanov.natsy.jetstream.model.PauseResponse
- Check if the consumer is scheduled for automatic resume
- WORK_QUEUE - enum entry in eu.vstoyanov.natsy.jetstream.RetentionPolicy
Retain messages for work queue pattern