Class NatsKVStore

Namespace

NATS.Client.KeyValueStore

Assembly

NATS.Client.KeyValueStore.dll

Key Value Store

public class NatsKVStore : INatsKVStore

Inheritance

object

NatsKVStore

Implements

INatsKVStore

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Properties

Bucket

Name of the Key Value Store bucket

Methods

CreateAsync<T>(string, T, 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

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

PurgeDeletesAsync(NatsKVPurgeOpts?, CancellationToken)

Purge all deleted entries

PutAsync<T>(string, T, INatsSerialize<T>?, CancellationToken)

Put a value into the bucket using the key

UpdateAsync<T>(string, T, ulong, 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>(string, INatsDeserialize<T>?, NatsKVWatchOpts?, CancellationToken)

Start a watcher for specific keys