Table of Contents

Class NatsJSStream

Namespace
NATS.Client.JetStream
Assembly
NATS.Client.JetStream.dll

Represents a NATS JetStream stream.

public class NatsJSStream : INatsJSStream
Inheritance
NatsJSStream
Implements
Inherited Members

Properties

Info

Stream info object as retrieved from NATS JetStream server at the time this object was created, updated or refreshed.

Methods

CreateOrUpdateConsumerAsync(ConsumerConfig, CancellationToken)

Creates new consumer if it doesn't exists or updates an existing one with the same name.

CreateOrderedConsumerAsync(NatsJSOrderedConsumerOpts?, CancellationToken)
DeleteAsync(CancellationToken)

Delete this stream.

DeleteConsumerAsync(string, CancellationToken)

Delete a consumer from this stream.

DeleteMessageAsync(StreamMsgDeleteRequest, CancellationToken)

Deletes a message from a stream.

GetAsync(StreamMsgGetRequest, CancellationToken)
GetConsumerAsync(string, CancellationToken)

Gets consumer information from the server and creates a NATS JetStream consumer NatsJSConsumer.

GetDirectAsync<T>(StreamMsgGetRequest, INatsDeserialize<T>?, CancellationToken)
ListConsumerNamesAsync(CancellationToken)

Enumerates through consumer names that belong to this stream.

ListConsumersAsync(CancellationToken)

Enumerates through consumers that belong to this stream.

PurgeAsync(StreamPurgeRequest, CancellationToken)

Purge data from this stream. Leaves the stream.

RefreshAsync(CancellationToken)

Retrieve the stream info from the server and update this stream.

UpdateAsync(StreamConfig, CancellationToken)

Update stream properties on the server.