Interface INatsJSStream

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

public interface INatsJSStream

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 consumers names belonging to this stream.

ListConsumersAsync(CancellationToken)

Enumerates through consumers belonging 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.