Merge branch 'main' into feature/distributed-tracing

Author: adam-fowler

Package.swift

@@ -11,7 +11,6 @@ let defaultSwiftSettings: [SwiftSetting] =
 
 let package = Package(
     name: "valkey-swift",
-    platforms: [.macOS(.v13)],
     products: [
         .library(name: "Valkey", targets: ["Valkey"]),
         .library(name: "ValkeyBloom", targets: ["ValkeyBloom"]),
@@ -102,6 +101,7 @@ let package = Package(
 )
 
 if Context.environment["ENABLE_VALKEY_BENCHMARKS"] != nil {
+    package.platforms = [.macOS(.v13)]
     package.dependencies.append(
         .package(url: "https://github.com/ordo-one/package-benchmark", from: "1.0.0")
     )

README.md

@@ -11,7 +11,7 @@ let valkeyClient = ValkeyClient(.hostname("localhost", port: 6379), logger: logg
 try await withThrowingTaskgroup(of: Void.self) { group in
     group.addTask {
         // run connection pool in the background
-        try await valkeyClient.run()
+        await valkeyClient.run()
     }
     // use valkey client
 }

Sources/Valkey/Cluster/ValkeyClusterClientStateMachine.swift

@@ -23,6 +23,7 @@ import Glibc
 import Musl
 #endif
 
+@available(valkeySwift 1.0, *)
 package struct ValkeyClusterTimer: Sendable, Hashable {
     package enum UseCase: Hashable {
         case nextDiscovery
@@ -43,6 +44,7 @@ package struct ValkeyClusterTimer: Sendable, Hashable {
 }
 
 @usableFromInline
+@available(valkeySwift 1.0, *)
 package struct ValkeyClusterClientStateMachineConfiguration {
     /// The duration after which the cluster client rejects all requests, because it can't find a cluster consensus
     @usableFromInline
@@ -58,6 +60,7 @@ package struct ValkeyClusterClientStateMachineConfiguration {
 }
 
 @usableFromInline
+@available(valkeySwift 1.0, *)
 package struct ValkeyClusterClientStateMachine<
     ConnectionPool: ValkeyNodeConnectionPool,
     ConnectionPoolFactory: ValkeyNodeConnectionPoolFactory,
@@ -755,6 +758,7 @@ package struct ValkeyClusterClientStateMachine<
     }
 }
 
+@available(valkeySwift 1.0, *)
 extension ValkeyClusterClientStateMachine {
     /// Calculates the delay for the next connection attempt after the given number of failed `attempts`.
     ///

Sources/Valkey/Cluster/ValkeyNodeConnectionPool.swift

@@ -17,6 +17,7 @@ import NIOSSL
 
 /// A connection pool against a node
 @usableFromInline
+@available(valkeySwift 1.0, *)
 package protocol ValkeyNodeConnectionPool: AnyObject, Sendable {
     /// Function that process background events, cancel the task or call ``triggerShutdown`` to
     /// shutdown the server
@@ -28,6 +29,7 @@ package protocol ValkeyNodeConnectionPool: AnyObject, Sendable {
 
 /// A connection pool factory that creates `ConnectionPool`s
 @usableFromInline
+@available(valkeySwift 1.0, *)
 package protocol ValkeyNodeConnectionPoolFactory: Sendable {
     associatedtype ConnectionPool: ValkeyNodeConnectionPool
 

Sources/Valkey/Cluster/ValkeyNodeDiscovery.swift

@@ -14,6 +14,7 @@
 
 /// A type that allows the cluster client to initially find at least one node in the cluster, or find the
 /// nodes again if connection to them has been lost.
+@available(valkeySwift 1.0, *)
 public protocol ValkeyNodeDiscovery: Sendable {
     /// A type that describes a single node in a valkey cluster
     associatedtype NodeDescription: ValkeyNodeDescriptionProtocol

Sources/Valkey/Cluster/ValkeyTopologyCandidate.swift

@@ -18,6 +18,7 @@
 /// designed specifically for efficient comparison during cluster updates. It preserves
 /// only the essential properties needed to determine if a topology has changed, while
 /// maintaining consistent ordering of elements to ensure reliable equality checks.
+@available(valkeySwift 1.0, *)
 package struct ValkeyTopologyCandidate: Hashable {
     /// Represents a shard (hash slot range) within a Valkey cluster topology.
     ///
@@ -114,6 +115,7 @@ package struct ValkeyTopologyCandidate: Hashable {
     }
 }
 
+@available(valkeySwift 1.0, *)
 package struct ValkeyClusterVoter<ConnectionPool: ValkeyNodeConnectionPool> {
     package var client: ConnectionPool
     package var nodeID: ValkeyNodeID

Sources/Valkey/Cluster/ValkeyTopologyElection.swift

@@ -23,6 +23,7 @@
 /// - Tracking vote counts for each topology candidate
 /// - Managing revotes (nodes changing their vote)
 /// - Determining when a winner has been elected
+@available(valkeySwift 1.0, *)
 package struct ValkeyTopologyElection {
     /// Represents a candidate in the topology election, tracking votes and thresholds.
     ///

Sources/Valkey/Commands/BitmapCommands.swift

@@ -491,6 +491,7 @@ public struct SETBIT: ValkeyCommand {
     }
 }
 
+@available(valkeySwift 1.0, *)
 extension ValkeyClientProtocol {
     /// Counts the number of set bits (population counting) in a string.
     ///

Sources/Valkey/Commands/ClusterCommands.swift

@@ -873,6 +873,7 @@ public struct READWRITE: ValkeyCommand {
     }
 }
 
+@available(valkeySwift 1.0, *)
 extension ValkeyClientProtocol {
     /// Signals that a cluster client is following an -ASK redirect.
     ///

Sources/Valkey/Commands/ConnectionCommands.swift

@@ -1029,6 +1029,7 @@ public struct SELECT: ValkeyCommand {
     }
 }
 
+@available(valkeySwift 1.0, *)
 extension ValkeyClientProtocol {
     /// Authenticates the connection.
     ///