Class NatsJSStream

Namespace

NATS.Client.JetStream

Assembly

NATS.Client.JetStream.dll

Represents a NATS JetStream stream.

public class NatsJSStream : INatsJSStream

Inheritance

object

NatsJSStream

Implements

INatsJSStream

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

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.