Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions src/NATS.Client.Core/INatsConnection.cs
Original file line number Diff line number Diff line change
Expand Up @@ -133,6 +133,7 @@ public interface INatsConnection : INatsClient
/// <remarks>
/// if reply option's timeout is not defined then it will be set to NatsOpts.RequestTimeout.
/// </remarks>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.Core.Extensions">RequestManyWithSentinelAsync for custom stop conditions</seealso>
IAsyncEnumerable<NatsMsg<TReply>> RequestManyAsync<TRequest, TReply>(
string subject,
TRequest? data,
Expand Down
1 change: 1 addition & 0 deletions src/NATS.Client.Core/NatsOpts.cs
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ public enum NatsRequestReplyMode
/// <summary>
/// Immutable options for NatsConnection, you can configure via `with` operator.
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.NatsContext">Load NatsOpts from NATS CLI context files</seealso>
public sealed record NatsOpts
{
public static readonly NatsOpts Default = new()
Expand Down
2 changes: 2 additions & 0 deletions src/NATS.Client.JetStream/Models/ConsumerConfig.cs
Original file line number Diff line number Diff line change
Expand Up @@ -111,13 +111,15 @@ public ConsumerConfig(string name)
/// <summary>
/// Filter the stream by a single subjects

Copilot AI Feb 25, 2026

Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

In the XML doc summary, "a single subjects" is grammatically incorrect; it should be singular ("a single subject").

Suggested change
/// Filter the stream by a single subjects
/// Filter the stream by a single subject

Copilot uses AI. Check for mistakes.
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.PCGroups">Partitioned consumer groups with subject-based partitioning</seealso>
[System.Text.Json.Serialization.JsonPropertyName("filter_subject")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public string? FilterSubject { get; set; }

/// <summary>
/// Filter the stream by multiple subjects
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.PCGroups">Partitioned consumer groups with multi-subject partitioning</seealso>
[System.Text.Json.Serialization.JsonPropertyName("filter_subjects")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public ICollection<string>? FilterSubjects { get; set; }
Expand Down
6 changes: 6 additions & 0 deletions src/NATS.Client.JetStream/Models/StreamConfig.cs
Original file line number Diff line number Diff line change
Expand Up @@ -217,6 +217,8 @@ public StreamConfig()
/// <summary>
/// Allow higher performance, direct access to get individual messages
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.JetStream.Extensions">Batch direct message retrieval via GetBatchDirectAsync</seealso>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.Counters">Distributed counters require direct-access streams</seealso>
[System.Text.Json.Serialization.JsonPropertyName("allow_direct")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public bool AllowDirect { get; set; }
Expand All @@ -243,6 +245,7 @@ public StreamConfig()
/// AllowMsgTTL allows header initiated per-message TTLs. If disabled, then the `NATS-TTL` header will be ignored.
/// </summary>
/// <remarks>This feature is only available on NATS server v2.11 and later.</remarks>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.JetStream.Extensions">Scheduled and delayed message publishing</seealso>
[System.Text.Json.Serialization.JsonPropertyName("allow_msg_ttl")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public bool AllowMsgTTL { get; set; }
Expand All @@ -267,20 +270,23 @@ public StreamConfig()
/// Allow message counter.
/// </summary>
/// <remarks>Supported by server v2.12</remarks>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.Counters">Distributed counter operations via NatsJSCounter</seealso>
[System.Text.Json.Serialization.JsonPropertyName("allow_msg_counter")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public bool AllowMsgCounter { get; set; }

/// <summary>
/// AllowMsgSchedules enables the scheduling of messages.
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.JetStream.Extensions">PublishScheduledAsync for delayed and recurring message scheduling</seealso>
[System.Text.Json.Serialization.JsonPropertyName("allow_msg_schedules")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public bool AllowMsgSchedules { get; set; }

/// <summary>
/// AllowAtomicPublish allows atomic batch publishing into the stream.
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.JetStream.Publisher">Atomic batch publishing via PublishMsgBatchAsync</seealso>
[System.Text.Json.Serialization.JsonPropertyName("allow_atomic")]
[System.Text.Json.Serialization.JsonIgnore(Condition = System.Text.Json.Serialization.JsonIgnoreCondition.WhenWritingDefault)]
public bool AllowAtomicPublish { get; set; }
Expand Down
4 changes: 4 additions & 0 deletions src/NATS.Client.KeyValueStore/INatsKVStore.cs
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,10 @@

namespace NATS.Client.KeyValueStore;

/// <summary>
/// Represents a NATS Key-Value Store bucket.
/// </summary>
/// <seealso href="https://www.nuget.org/packages/Synadia.Orbit.KeyValueStore.Extensions">KV codec extensions for typed serialization</seealso>
public interface INatsKVStore
{
/// <summary>
Expand Down
Loading