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
8 changes: 4 additions & 4 deletions src/StackExchange.Redis/APITypes/GeoSearchShape.cs
Original file line number Diff line number Diff line change
Expand Up @@ -46,12 +46,12 @@ public GeoSearchCircle(double radius, GeoUnit unit = GeoUnit.Meters) : base(unit
_radius = radius;
}

internal override int ArgCount => 3;
internal sealed override int ArgCount => 3;

/// <summary>
/// Gets the <see cref="RedisValue"/>s for this shape.
/// </summary>
internal override void AddArgs(List<RedisValue> args)
internal sealed override void AddArgs(List<RedisValue> args)
{
args.Add(RedisLiterals.BYRADIUS);
args.Add(_radius);
Expand Down Expand Up @@ -80,9 +80,9 @@ public GeoSearchBox(double height, double width, GeoUnit unit = GeoUnit.Meters)
_width = width;
}

internal override int ArgCount => 4;
internal sealed override int ArgCount => 4;

internal override void AddArgs(List<RedisValue> args)
internal sealed override void AddArgs(List<RedisValue> args)
{
args.Add(RedisLiterals.BYBOX);
args.Add(_width);
Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/ClientInfo.cs
Original file line number Diff line number Diff line change
Expand Up @@ -287,7 +287,7 @@ private static void AddFlag(ref ClientFlags value, string raw, ClientFlags toAdd
if (raw.IndexOf(token) >= 0) value |= toAdd;
}

private class ClientInfoProcessor : ResultProcessor<ClientInfo[]>
private sealed class ClientInfoProcessor : ResultProcessor<ClientInfo[]>
{
protected override bool SetResultCore(PhysicalConnection connection, Message message, in RawResult result)
{
Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/CommandTrace.cs
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ internal CommandTrace(long uniqueId, long time, long duration, RedisValue[] argu
return BaseUrl + encoded0;
}

private class CommandTraceProcessor : ResultProcessor<CommandTrace[]>
private sealed class CommandTraceProcessor : ResultProcessor<CommandTrace[]>
{
protected override bool SetResultCore(PhysicalConnection connection, Message message, in RawResult result)
{
Expand Down
24 changes: 12 additions & 12 deletions src/StackExchange.Redis/Condition.cs
Original file line number Diff line number Diff line change
Expand Up @@ -384,7 +384,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
return false;
}

private class ConditionMessage : Message.CommandKeyBase
private sealed class ConditionMessage : Message.CommandKeyBase
{
public readonly Condition Condition;
private readonly RedisValue value;
Expand Down Expand Up @@ -425,7 +425,7 @@ protected override void WriteImpl(PhysicalConnection physical)
}
}

internal class ExistsCondition : Condition
internal sealed class ExistsCondition : Condition
{
private readonly bool expectedResult;
private readonly RedisValue expectedValue;
Expand Down Expand Up @@ -501,7 +501,7 @@ internal override bool TryValidate(in RawResult result, out bool value)
}
}

internal class EqualsCondition : Condition
internal sealed class EqualsCondition : Condition
{
internal override Condition MapKeys(Func<RedisKey, RedisKey> map) =>
new EqualsCondition(map(key), type, memberName, expectedEqual, expectedValue);
Expand Down Expand Up @@ -535,7 +535,7 @@ public override string ToString() =>

internal override void CheckCommands(CommandMap commandMap) => commandMap.AssertAvailable(cmd);

internal sealed override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
internal override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
{
yield return Message.Create(db, CommandFlags.None, RedisCommand.WATCH, key);

Expand Down Expand Up @@ -580,7 +580,7 @@ internal override bool TryValidate(in RawResult result, out bool value)
}
}

internal class ListCondition : Condition
internal sealed class ListCondition : Condition
{
internal override Condition MapKeys(Func<RedisKey, RedisKey> map) =>
new ListCondition(map(key), index, expectedResult, expectedValue);
Expand All @@ -606,7 +606,7 @@ public override string ToString() =>

internal override void CheckCommands(CommandMap commandMap) => commandMap.AssertAvailable(RedisCommand.LINDEX);

internal sealed override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
internal override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
{
yield return Message.Create(db, CommandFlags.None, RedisCommand.WATCH, key);

Expand Down Expand Up @@ -643,7 +643,7 @@ internal override bool TryValidate(in RawResult result, out bool value)
}
}

internal class LengthCondition : Condition
internal sealed class LengthCondition : Condition
{
internal override Condition MapKeys(Func<RedisKey, RedisKey> map) =>
new LengthCondition(map(key), type, compareToResult, expectedLength);
Expand Down Expand Up @@ -679,7 +679,7 @@ public LengthCondition(in RedisKey key, RedisType type, int compareToResult, lon

internal override void CheckCommands(CommandMap commandMap) => commandMap.AssertAvailable(cmd);

internal sealed override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
internal override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
{
yield return Message.Create(db, CommandFlags.None, RedisCommand.WATCH, key);

Expand Down Expand Up @@ -708,7 +708,7 @@ internal override bool TryValidate(in RawResult result, out bool value)
}
}

internal class SortedSetRangeLengthCondition : Condition
internal sealed class SortedSetRangeLengthCondition : Condition
{
internal override Condition MapKeys(Func<RedisKey, RedisKey> map) =>
new SortedSetRangeLengthCondition(map(key), min, max, compareToResult, expectedLength);
Expand Down Expand Up @@ -736,7 +736,7 @@ public override string ToString() =>

internal override void CheckCommands(CommandMap commandMap) => commandMap.AssertAvailable(RedisCommand.ZCOUNT);

internal sealed override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
internal override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
{
yield return Message.Create(db, CommandFlags.None, RedisCommand.WATCH, key);

Expand Down Expand Up @@ -765,7 +765,7 @@ internal override bool TryValidate(in RawResult result, out bool value)
}
}

internal class SortedSetScoreCondition : Condition
internal sealed class SortedSetScoreCondition : Condition
{
internal override Condition MapKeys(Func<RedisKey, RedisKey> map) =>
new SortedSetScoreCondition(map(key), sortedSetScore, expectedEqual, expectedValue);
Expand All @@ -792,7 +792,7 @@ public override string ToString() =>

internal override void CheckCommands(CommandMap commandMap) => commandMap.AssertAvailable(RedisCommand.ZCOUNT);

internal sealed override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
internal override IEnumerable<Message> CreateMessages(int db, IResultBox? resultBox)
{
yield return Message.Create(db, CommandFlags.None, RedisCommand.WATCH, key);

Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/Configuration/LoggingTunnel.cs
Original file line number Diff line number Diff line change
Expand Up @@ -277,7 +277,7 @@ public static void LogToDirectory(ConfigurationOptions options, string path)
options.Tunnel = tunnel;
}

private class DirectoryLoggingTunnel : LoggingTunnel
private sealed class DirectoryLoggingTunnel : LoggingTunnel
{
private readonly string path;
private int _nextIndex = -1;
Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/CursorEnumerable.cs
Original file line number Diff line number Diff line change
Expand Up @@ -344,7 +344,7 @@ public void Reset()
internal static CursorEnumerable<T> From(RedisBase redis, ServerEndPoint? server, Task<T[]> pending, int pageOffset)
=> new SingleBlockEnumerable(redis, server, pending, pageOffset);

private class SingleBlockEnumerable : CursorEnumerable<T>
private sealed class SingleBlockEnumerable : CursorEnumerable<T>
{
private readonly Task<T[]> _pending;
public SingleBlockEnumerable(RedisBase redis, ServerEndPoint? server, Task<T[]> pending, int pageOffset)
Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/Message.cs
Original file line number Diff line number Diff line change
Expand Up @@ -1627,7 +1627,7 @@ protected override void WriteImpl(PhysicalConnection physical)
public override int ArgCount => 0;
}

private class CommandSlotValuesMessage : Message
private sealed class CommandSlotValuesMessage : Message
{
private readonly int slot;
private readonly RedisValue[] values;
Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/RedisBatch.cs
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@

namespace StackExchange.Redis
{
internal class RedisBatch : RedisDatabase, IBatch
internal sealed class RedisBatch : RedisDatabase, IBatch
{
private List<Message>? pending;

Expand Down
6 changes: 3 additions & 3 deletions src/StackExchange.Redis/RedisDatabase.cs
Original file line number Diff line number Diff line change
Expand Up @@ -4931,7 +4931,7 @@ public Task<long> SortedSetRemoveRangeByValueAsync(RedisKey key, RedisValue min,
return ExecuteAsync(msg, ResultProcessor.Int64);
}

internal class ScanEnumerable<T> : CursorEnumerable<T>
internal sealed class ScanEnumerable<T> : CursorEnumerable<T>
{
private readonly RedisKey key;
private readonly RedisValue pattern;
Expand Down Expand Up @@ -5324,7 +5324,7 @@ private SortedSetScanResultProcessor() { }
=> SortedSetWithScores.TryParse(result, out SortedSetEntry[]? pairs, true, out count) ? pairs : null;
}

private class StringGetWithExpiryMessage : Message.CommandKeyBase, IMultiMessage
private sealed class StringGetWithExpiryMessage : Message.CommandKeyBase, IMultiMessage
{
private readonly RedisCommand ttlCommand;
private IResultBox<TimeSpan?>? box;
Expand Down Expand Up @@ -5368,7 +5368,7 @@ protected override void WriteImpl(PhysicalConnection physical)
public override int ArgCount => 1;
}

private class StringGetWithExpiryProcessor : ResultProcessor<RedisValueWithExpiry>
private sealed class StringGetWithExpiryProcessor : ResultProcessor<RedisValueWithExpiry>
{
public static readonly ResultProcessor<RedisValueWithExpiry> Default = new StringGetWithExpiryProcessor();
private StringGetWithExpiryProcessor() { }
Expand Down
2 changes: 1 addition & 1 deletion src/StackExchange.Redis/RedisServer.cs
Original file line number Diff line number Diff line change
Expand Up @@ -889,7 +889,7 @@ private protected override Message CreateMessage(in RedisValue cursor)
private protected override ResultProcessor<ScanResult> Processor => processor;

public static readonly ResultProcessor<ScanResult> processor = new ScanResultProcessor();
private class ScanResultProcessor : ResultProcessor<ScanResult>
private sealed class ScanResultProcessor : ResultProcessor<ScanResult>
{
protected override bool SetResultCore(PhysicalConnection connection, Message message, in RawResult result)
{
Expand Down
10 changes: 5 additions & 5 deletions src/StackExchange.Redis/RedisTransaction.cs
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@

namespace StackExchange.Redis
{
internal class RedisTransaction : RedisDatabase, ITransaction
internal sealed class RedisTransaction : RedisDatabase, ITransaction
{
private List<ConditionResult>? _conditions;
private List<QueuedMessage>? _pending;
Expand Down Expand Up @@ -169,7 +169,7 @@ private void QueueMessage(Message message)
return new TransactionMessage(Database, flags, cond, work);
}

private class QueuedMessage : Message
private sealed class QueuedMessage : Message
{
public Message Wrapped { get; }
private volatile bool wasQueued;
Expand Down Expand Up @@ -197,7 +197,7 @@ public override int GetHashSlot(ServerSelectionStrategy serverSelectionStrategy)
=> Wrapped.GetHashSlot(serverSelectionStrategy);
}

private class QueuedProcessor : ResultProcessor<bool>
private sealed class QueuedProcessor : ResultProcessor<bool>
{
public static readonly ResultProcessor<bool> Default = new QueuedProcessor();

Expand All @@ -216,7 +216,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
}
}

private class TransactionMessage : Message, IMultiMessage
private sealed class TransactionMessage : Message, IMultiMessage
{
private readonly ConditionResult[] conditions;

Expand Down Expand Up @@ -465,7 +465,7 @@ private bool AreAllConditionsSatisfied(ConnectionMultiplexer multiplexer)
}
}

private class TransactionProcessor : ResultProcessor<bool>
private sealed class TransactionProcessor : ResultProcessor<bool>
{
public static readonly TransactionProcessor Default = new();

Expand Down
14 changes: 7 additions & 7 deletions src/StackExchange.Redis/ResultProcessor.cs
Original file line number Diff line number Diff line change
Expand Up @@ -1336,7 +1336,7 @@ private static string Normalize(string? category) =>
category.IsNullOrWhiteSpace() ? "miscellaneous" : category.Trim();
}

private class Int64DefaultValueProcessor : ResultProcessor<long>
private sealed class Int64DefaultValueProcessor : ResultProcessor<long>
{
private readonly long _defaultValue;

Expand Down Expand Up @@ -1384,7 +1384,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
internal static ResultProcessor<StreamTrimResult[]> StreamTrimResultArray =>
Int32EnumArrayProcessor<StreamTrimResult>.Instance;

private class Int32EnumProcessor<T> : ResultProcessor<T> where T : unmanaged, Enum
private sealed class Int32EnumProcessor<T> : ResultProcessor<T> where T : unmanaged, Enum
{
private Int32EnumProcessor() { }
public static readonly Int32EnumProcessor<T> Instance = new();
Expand Down Expand Up @@ -1418,7 +1418,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
}
}

private class Int32EnumArrayProcessor<T> : ResultProcessor<T[]> where T : unmanaged, Enum
private sealed class Int32EnumArrayProcessor<T> : ResultProcessor<T[]> where T : unmanaged, Enum
{
private Int32EnumArrayProcessor() { }
public static readonly Int32EnumArrayProcessor<T> Instance = new();
Expand Down Expand Up @@ -1449,7 +1449,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
}
}

private class PubSubNumSubProcessor : Int64Processor
private sealed class PubSubNumSubProcessor : Int64Processor
{
protected override bool SetResultCore(PhysicalConnection connection, Message message, in RawResult result)
{
Expand Down Expand Up @@ -2049,7 +2049,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
}
}

private class ScriptResultProcessor : ResultProcessor<RedisResult>
private sealed class ScriptResultProcessor : ResultProcessor<RedisResult>
{
public override bool SetResult(PhysicalConnection connection, Message message, in RawResult result)
{
Expand Down Expand Up @@ -2632,7 +2632,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
}
}

internal class StreamNameValueEntryProcessor : ValuePairInterleavedProcessorBase<NameValueEntry>
internal sealed class StreamNameValueEntryProcessor : ValuePairInterleavedProcessorBase<NameValueEntry>
{
public static readonly StreamNameValueEntryProcessor Instance = new();
private StreamNameValueEntryProcessor()
Expand Down Expand Up @@ -2747,7 +2747,7 @@ protected override bool SetResultCore(PhysicalConnection connection, Message mes
}
}

private class TracerProcessor : ResultProcessor<bool>
private sealed class TracerProcessor : ResultProcessor<bool>
{
private readonly bool establishConnection;

Expand Down
Loading