Class NatsJSStream
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.
- DeleteAsync(CancellationToken)
Delete this stream.
- DeleteConsumerAsync(string, CancellationToken)
Delete a consumer from this stream.
- DeleteMessageAsync(StreamMsgDeleteRequest, CancellationToken)
Deletes a message from a stream.
- GetConsumerAsync(string, CancellationToken)
Gets consumer information from the server and creates a NATS JetStream consumer NatsJSConsumer.
- 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.