A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
R
S
T
U
V
W
O
- ObjectMetadata - class in eu.vstoyanov.natsy.jetstream.model
- Everything about an object other than its name and its bytesThe name is not here: it is the parameter the store is asked to write under (eu.vstoyanov.natsy.jetstream.ObjectStore.put, eu.vstoyanov.natsy.jetstream.ObjectStore.putFile).
- objectStore(java.lang.String,kotlin.jvm.functions.Function1) - function in eu.vstoyanov.natsy.jetstream.JetStreamContext
- Create or access an Object Store bucketIf the bucket already exists, it will be returned.
- ObjectStore - class in eu.vstoyanov.natsy.jetstream
- Wrapper around NATS ObjectStore that provides coroutine-friendly operationsLarge objects stream: putFile reads from disk a chunk at a time, getFile writes to disk the same way, and get writes into any OutputStream the caller hands it.
- ObjectStoreConfig - class in eu.vstoyanov.natsy.jetstream
- Configuration for a JetStream Object Store bucketExample:
val objectStore = js.objectStore("file-storage") { description = "Application file storage" storageType = StorageType.FILE replicas = 3 maxBucketSize = 10 * 1024 * 1024 * 1024L // 10GB } - ObjectStoreConfigBuilder - class in eu.vstoyanov.natsy.jetstream
- Builder for Object Store configuration
- ObjectStoreInfo - class in eu.vstoyanov.natsy.jetstream.model
- Information about an object in the object store
- ObjectStoreInfo.Companion - class in eu.vstoyanov.natsy.jetstream.model.ObjectStoreInfo
- ObjectStoreLink - class in eu.vstoyanov.natsy.jetstream.model
- What an entry points at instead of holding bytes of its own.
- ObjectWatchEvent - class in eu.vstoyanov.natsy.jetstream.model
- What an Object Store watch delivers when the initial snapshot is worth telling apart from the changes that follow itA watch begins by replaying what the bucket already holds and only then follows live changes, with nothing in the element type to say where one ends and the other begins.
- ObjectWatchEvent.Entry - class in eu.vstoyanov.natsy.jetstream.model.ObjectWatchEvent
- One revision of one object, exactly as eu.vstoyanov.natsy.jetstream.ObjectStore.watch emits it
- ObjectWatchEvent.InitialSyncComplete - class in eu.vstoyanov.natsy.jetstream.model.ObjectWatchEvent
- Everything the bucket already held has been delivered; what follows is a change
- ObjectWatchOption - class in eu.vstoyanov.natsy.jetstream.model
- How an Object Store watch starts, and what it leaves outAn option changes where the watch begins or which entries reach the collector.
- OLD - enum entry in eu.vstoyanov.natsy.jetstream.model.DiscardPolicy
Discard old messages when limits are reached
- ORIGINAL - enum entry in eu.vstoyanov.natsy.jetstream.ReplayPolicy
Replay messages at original speed