Package eu.vstoyanov.natsy.jetstream.model
See: Description
-
Enum Summary Enum Description AckPolicy Acknowledgment policy for consumers DeliverPolicy Deliver policy determines where to start delivering messages KeyValueOperation What a Key-Value revision records KvWatchOption How a Key-Value watch starts, and what it carriesAn option changes where the watch begins or how much of each revision the server sends. ObjectWatchOption How an Object Store watch starts, and what it leaves outAn option changes where the watch begins or which entries reach the collector. DiscardPolicy Discard policy determines which messages to discard when limits are reached -
Class Summary Class Description PauseResponse Response from pause operation ConsumerStats A snapshot of everything worth monitoring about a consumer, from one server round trip. KeyValueEntry Represents an entry in the Key-Value store with typed payload Entry One revision of one key, exactly as eu.vstoyanov.natsy.jetstream.KeyValueStore.watch emits it ObjectMetadata 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). ObjectStoreLink What an entry points at instead of holding bytes of its own. ObjectStoreInfo Information about an object in the object store Entry One revision of one object, exactly as eu.vstoyanov.natsy.jetstream.ObjectStore.watch emits it PlacementBuilder Builder for Placement configuration Placement Placement configuration for stream clusteringControls where a stream is placed within a NATS cluster. StreamSourceBuilder Builder for StreamSource configuration StreamSource Stream source configuration for stream aggregationUsed to aggregate messages from other streams or external sources. RepublishBuilder Builder for Republish configuration Republish Republish configuration: a copy of every matching message, on a subject of its ownThe copy is a plain core-NATS message rather than a stream message, so a subscriber gets it without a consumer - which is how a stream feeds a cache or an audit listener that must not acknowledge anything. -
Object Summary Object Description KeyValueEntryMapper Companion for creating KeyValueEntry from NATS KeyValueEntry InitialSyncComplete Everything the bucket already held has been delivered; what follows is a change Companion InitialSyncComplete Everything the bucket already held has been delivered; what follows is a change -
Interface Summary Interface Description KvWatchEvent What a Key-Value 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 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.