Struct Counter 

pub struct Counter { /* private fields */ }

Implementation of distributed counters using a JetStream stream.

Implementations

impl Counter

pub async fn from_stream(context: Context, stream: Stream) -> Result<Self>

Creates a counter from an existing stream.

pub async fn add<S, V>(&self, subject: S, value: V) -> Result<BigInt>

where S: ToSubject, V: Into<BigInt> + Send,

Adds a value to the counter for the given subject.

pub async fn get<S: ToSubject>(&self, subject: S) -> Result<Entry>

Gets the counter entry for a subject, including sources and last increment.

Returns complete information about a counter including its current value, source breakdown (if using stream sourcing), and the last increment value.

pub async fn load<S: ToSubject>(&self, subject: S) -> Result<BigInt>

Loads just the counter value for a subject.

This is a convenience method that returns only the value, without sources or increment information.

pub async fn increment<S>(&self, subject: S) -> Result<BigInt>

where S: ToSubject,

Increments the counter by 1 for the given subject. This is a convenience method for the common case of incrementing by 1.

pub async fn decrement<S>(&self, subject: S) -> Result<BigInt>

where S: ToSubject,

Decrements the counter by 1 for the given subject. This is a convenience method for the common case of decrementing by 1.

pub async fn get_multiple( &self, subjects: Vec<String>, ) -> Result<Pin<Box<dyn FutureStream<Item = Result<Entry>> + Send + '_>>>

Gets multiple counter entries matching the given subjects.

Efficiently fetches multiple counters in a batch operation. Returns a stream of entries.

Note: Subjects should be exact subjects, not patterns. Non-existent counters are silently skipped in the results.