Interface INatsKVStore

Namespace: NATS.Client.KeyValueStore

Assembly: NATS.Client.KeyValueStore.dll

public interface INatsKVStore

Properties

Bucket: Name of the Key Value Store bucket

JetStreamContext: Provides access to the JetStream context associated with the Object Store operations.

Methods

CreateAsync<T>(string, T, INatsSerialize<T>?, CancellationToken): Create a new entry in the bucket only if it doesn't exist

CreateAsync<T>(string, T, TimeSpan, INatsSerialize<T>?, CancellationToken): Create a new entry in the bucket only if it doesn't exist

DeleteAsync(string, NatsKVDeleteOpts?, CancellationToken): Delete an entry from the bucket

GetEntryAsync<T>(string, ulong, INatsDeserialize<T>?, CancellationToken): Get an entry from the bucket using the key

GetKeysAsync(NatsKVWatchOpts?, CancellationToken): Get all the keys in the bucket

GetKeysAsync(IEnumerable<string>, NatsKVWatchOpts?, CancellationToken): Get a filtered set of keys in the bucket

GetStatusAsync(CancellationToken): Get the bucket status

HistoryAsync<T>(string, INatsDeserialize<T>?, NatsKVWatchOpts?, CancellationToken): Get the history of an entry by key

PurgeAsync(string, NatsKVDeleteOpts?, CancellationToken): Purge an entry from the bucket

PurgeAsync(string, TimeSpan, NatsKVDeleteOpts?, CancellationToken): Purge an entry from the bucket

PurgeDeletesAsync(NatsKVPurgeOpts?, CancellationToken): Purge all deleted entries

PutAsync<T>(string, T, INatsSerialize<T>?, CancellationToken): Put a value into the bucket using the key

TryCreateAsync<T>(string, T, INatsSerialize<T>?, CancellationToken): Tries to create a new entry in the bucket only if it doesn't exist

TryCreateAsync<T>(string, T, TimeSpan, INatsSerialize<T>?, CancellationToken): Tries to create a new entry in the bucket only if it doesn't exist

TryDeleteAsync(string, NatsKVDeleteOpts?, CancellationToken): Delete an entry from the bucket

TryGetEntryAsync<T>(string, ulong, INatsDeserialize<T>?, CancellationToken): Try to get an entry from the bucket using the key.

TryPurgeAsync(string, NatsKVDeleteOpts?, CancellationToken): Tries to purge an entry from the bucket

TryPurgeAsync(string, TimeSpan, NatsKVDeleteOpts?, CancellationToken): Tries to purge an entry from the bucket

TryPutAsync<T>(string, T, INatsSerialize<T>?, CancellationToken): Tries to put a value into the bucket using the key

TryUpdateAsync<T>(string, T, ulong, INatsSerialize<T>?, CancellationToken): Tries to update an entry in the bucket only if last update revision matches

TryUpdateAsync<T>(string, T, ulong, TimeSpan, INatsSerialize<T>?, CancellationToken): Tries to update an entry in the bucket only if last update revision matches

UpdateAsync<T>(string, T, ulong, INatsSerialize<T>?, CancellationToken): Update an entry in the bucket only if last update revision matches

UpdateAsync<T>(string, T, ulong, TimeSpan, INatsSerialize<T>?, CancellationToken): Update an entry in the bucket only if last update revision matches

WatchAsync<T>(INatsDeserialize<T>?, NatsKVWatchOpts?, CancellationToken): Start a watcher for all the keys in the bucket

WatchAsync<T>(IEnumerable<string>, INatsDeserialize<T>?, NatsKVWatchOpts?, CancellationToken): Start a watcher for specific keys

WatchAsync<T>(string, INatsDeserialize<T>?, NatsKVWatchOpts?, CancellationToken): Start a watcher for specific keys

Edit this page