mirror of
https://github.com/swift-server/RediStack.git
synced 2026-05-03 07:32:28 +00:00
Add RedisHashSlot (#91)
This commit is contained in:
Fabian Fett
GitHub
+32
-67
@@ -26,7 +26,7 @@ components that this product depends on.
|
||||
|
||||
-------------------------------------------------------------------------------
|
||||
|
||||
This product was heavily influenced by implementations from the Vapor and NozeIO frameworks.
|
||||
This product was heavily influenced by Vapor and NozeIO.
|
||||
|
||||
* NozeIO
|
||||
* LICENSE (Apache License 2.0)
|
||||
@@ -41,71 +41,36 @@ This product was heavily influenced by implementations from the Vapor and NozeIO
|
||||
|
||||
---
|
||||
|
||||
This product contains the entire library from Apple's SwiftLog API.
|
||||
This product contains a a derivation of Georges Menie's crc16 algorithm that was adopted
|
||||
to Redis coding style by Salvatore Sanfilippo.
|
||||
|
||||
* LICENSE (Apache License 2.0):
|
||||
* https://github.com/apple/swift-log/blob/master/LICENSE.txt
|
||||
* HOMEPAGE:
|
||||
* https://github.com/apple/swift-log
|
||||
|
||||
---
|
||||
|
||||
This product contains the entire library from Apple's SwiftMetrics API.
|
||||
|
||||
* LICENSE (Apache License 2.0):
|
||||
* https://github.com/apple/swift-metrics/blob/master/LICENSE.txt
|
||||
* HOMEPAGE:
|
||||
* https://github.com/apple/swift-metrics
|
||||
|
||||
---
|
||||
|
||||
This product contains the entire library and derivations of various scripts from Apple's SwiftNIO.
|
||||
|
||||
* LICENSE (Apache License 2.0):
|
||||
* https://github.com/apple/swift-nio/blob/master/LICENSE.txt
|
||||
* LICENSE:
|
||||
/*
|
||||
* Copyright 2001-2010 Georges Menie (www.menie.org)
|
||||
* Copyright 2010 Salvatore Sanfilippo (adapted to Redis coding style)
|
||||
* All rights reserved.
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are met:
|
||||
*
|
||||
* * Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
* * Redistributions in binary form must reproduce the above copyright
|
||||
* notice, this list of conditions and the following disclaimer in the
|
||||
* documentation and/or other materials provided with the distribution.
|
||||
* * Neither the name of the University of California, Berkeley nor the
|
||||
* names of its contributors may be used to endorse or promote products
|
||||
* derived from this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND ANY
|
||||
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
||||
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||
* DISCLAIMED. IN NO EVENT SHALL THE REGENTS AND CONTRIBUTORS BE LIABLE FOR ANY
|
||||
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
|
||||
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
|
||||
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
||||
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*/
|
||||
* HOMEPAGE:
|
||||
* https://github.com/apple/swift-nio
|
||||
|
||||
---
|
||||
|
||||
This product contains a derivation of the Tony Stone's 'process_test_files.rb'.
|
||||
|
||||
* LICENSE (Apache License 2.0):
|
||||
* https://www.apache.org/licenses/LICENSE-2.0
|
||||
* HOMEPAGE:
|
||||
* https://codegists.com/snippet/ruby/generate_xctest_linux_runnerrb_tonystone_ruby
|
||||
|
||||
---
|
||||
|
||||
This product contains NodeJS's http-parser.
|
||||
|
||||
* LICENSE (MIT):
|
||||
* https://github.com/nodejs/http-parser/blob/master/LICENSE-MIT
|
||||
* HOMEPAGE:
|
||||
* https://github.com/nodejs/http-parser
|
||||
|
||||
---
|
||||
|
||||
This product contains "cpp_magic.h" from Thomas Nixon & Jonathan Heathcote's uSHET
|
||||
|
||||
* LICENSE (MIT):
|
||||
* https://github.com/18sg/uSHET/blob/master/LICENSE
|
||||
* HOMEPAGE:
|
||||
* https://github.com/18sg/uSHET
|
||||
|
||||
---
|
||||
|
||||
This product contains "sha1.c" and "sha1.h" from FreeBSD (Copyright (C) 1995, 1996, 1997, and 1998 WIDE Project)
|
||||
|
||||
* LICENSE (BSD-3):
|
||||
* https://opensource.org/licenses/BSD-3-Clause
|
||||
* HOMEPAGE:
|
||||
* https://github.com/freebsd/freebsd/tree/master/sys/crypto
|
||||
|
||||
---
|
||||
This product contains "ifaddrs-android.c" and "ifaddrs-android.h" from dxr.mozilla.org. Webrtc is the owner, but we use edited version from mozilla repo (Copyright (c) 2011, The WebRTC project authors. All rights reserved)
|
||||
|
||||
* LICENSE (BSD):
|
||||
* https://webrtc.googlesource.com/src/+/master/LICENSE
|
||||
* HOMEPAGE:
|
||||
* https://webrtc.googlesource.com/
|
||||
* https://redis.io/docs/reference/cluster-spec/#appendix-a-crc16-reference-implementation-in-ansi-c
|
||||
|
||||
@@ -0,0 +1,222 @@
|
||||
//===----------------------------------------------------------------------===//
|
||||
//
|
||||
// This source file is part of the RediStack open source project
|
||||
//
|
||||
// Copyright (c) 2023 RediStack project authors
|
||||
// Licensed under Apache License v2.0
|
||||
//
|
||||
// See LICENSE.txt for license information
|
||||
// See CONTRIBUTORS.txt for the list of RediStack project authors
|
||||
//
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
//
|
||||
//===----------------------------------------------------------------------===//
|
||||
|
||||
typealias HashSlots = [ClosedRange<RedisHashSlot>]
|
||||
|
||||
/// A wrapper around UInt16 that represents a Redis HashSlot. A HashSlot determines which
|
||||
/// Shard to connect to in a Redis Cluster.
|
||||
public struct RedisHashSlot: Hashable, Sendable {
|
||||
/// An unknown `HashSlot` value
|
||||
public static let unknown = RedisHashSlot(.max)
|
||||
|
||||
/// The max valid `HashSlot` value
|
||||
public static let max = RedisHashSlot(16383)
|
||||
/// The min valid `HashSlot` value
|
||||
public static let min = RedisHashSlot(0)
|
||||
/// The number of all hash slots
|
||||
public static let count: Int = 16384
|
||||
|
||||
private var _raw: UInt16
|
||||
|
||||
private init(_ value: UInt16) {
|
||||
precondition(value < 16384 || value == .max)
|
||||
self._raw = value
|
||||
}
|
||||
}
|
||||
|
||||
extension RedisHashSlot: Comparable {
|
||||
public static func < (lhs: RedisHashSlot, rhs: RedisHashSlot) -> Bool {
|
||||
lhs.rawValue < rhs.rawValue
|
||||
}
|
||||
}
|
||||
|
||||
extension RedisHashSlot: RawRepresentable {
|
||||
public typealias RawValue = UInt16
|
||||
|
||||
public init?(rawValue: UInt16) {
|
||||
guard rawValue < 16384 else { return nil }
|
||||
self._raw = rawValue
|
||||
}
|
||||
|
||||
public init?(rawValue: Int) {
|
||||
guard rawValue >= 0, rawValue < 16384 else { return nil }
|
||||
self._raw = UInt16(rawValue)
|
||||
}
|
||||
|
||||
public var rawValue: UInt16 { self._raw }
|
||||
}
|
||||
|
||||
extension RedisHashSlot: Strideable {
|
||||
public typealias Stride = Int
|
||||
|
||||
public func distance(to other: RedisHashSlot) -> Int {
|
||||
Int(other.rawValue - self.rawValue)
|
||||
}
|
||||
|
||||
public func advanced(by n: Int) -> RedisHashSlot {
|
||||
// we are fine that this might crash. Same behavior as normal Int and friends.
|
||||
RedisHashSlot(UInt16(Int(self.rawValue) + n))
|
||||
}
|
||||
}
|
||||
|
||||
extension RedisHashSlot: ExpressibleByIntegerLiteral {
|
||||
public typealias IntegerLiteralType = UInt16
|
||||
|
||||
public init(integerLiteral value: UInt16) {
|
||||
precondition(value < 16384 || value == .max)
|
||||
self._raw = value
|
||||
}
|
||||
}
|
||||
|
||||
extension RedisHashSlot: CustomStringConvertible {
|
||||
public var description: String {
|
||||
switch self {
|
||||
case RedisHashSlot.min...RedisHashSlot.max:
|
||||
return "\(self.rawValue)"
|
||||
case RedisHashSlot.unknown:
|
||||
return "unknown"
|
||||
default:
|
||||
fatalError("Invalid value: \(self._raw)")
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
extension RedisHashSlot {
|
||||
/// Creates a slot for a given `key`. A ``HashSlot`` is used to determine which shard to connect to.
|
||||
/// - Parameter key: The key used in a redis command
|
||||
public init(key: String) {
|
||||
// Banging is safe because the modulo ensures we are in range
|
||||
self.init(rawValue: UInt16(crc16(RedisHashSlot.hashTag(forKey: key)) % 16384))!
|
||||
}
|
||||
|
||||
/// Computes the range of the key that is used to compute the slot for a given key
|
||||
/// - Parameter key: The key for your operation
|
||||
/// - Returns: A substring utf8 view that shall be used in the crc16 computation
|
||||
static func hashTag(forKey key: String) -> Substring.UTF8View {
|
||||
let utf8View = key.utf8
|
||||
|
||||
var firstOpenCurly: String.UTF8View.Index?
|
||||
var index = utf8View.startIndex
|
||||
|
||||
while index < utf8View.endIndex {
|
||||
defer { index = utf8View.index(after: index) }
|
||||
|
||||
switch utf8View[index] {
|
||||
case UInt8(ascii: "{") where firstOpenCurly == nil:
|
||||
firstOpenCurly = index
|
||||
case UInt8(ascii: "}"):
|
||||
guard let firstOpenCurly = firstOpenCurly else {
|
||||
continue
|
||||
}
|
||||
|
||||
if firstOpenCurly == utf8View.index(before: index) {
|
||||
// we had a `{}` combination... this means the complete key shall be used for hashing
|
||||
return utf8View[...]
|
||||
}
|
||||
|
||||
return utf8View[(utf8View.index(after: firstOpenCurly))..<index]
|
||||
default:
|
||||
continue
|
||||
}
|
||||
}
|
||||
|
||||
return utf8View[...]
|
||||
}
|
||||
}
|
||||
|
||||
/*
|
||||
* Copyright 2001-2010 Georges Menie (www.menie.org)
|
||||
* Copyright 2010 Salvatore Sanfilippo (adapted to Redis coding style)
|
||||
* All rights reserved.
|
||||
* Redistribution and use in source and binary forms, with or without
|
||||
* modification, are permitted provided that the following conditions are met:
|
||||
*
|
||||
* * Redistributions of source code must retain the above copyright
|
||||
* notice, this list of conditions and the following disclaimer.
|
||||
* * Redistributions in binary form must reproduce the above copyright
|
||||
* notice, this list of conditions and the following disclaimer in the
|
||||
* documentation and/or other materials provided with the distribution.
|
||||
* * Neither the name of the University of California, Berkeley nor the
|
||||
* names of its contributors may be used to endorse or promote products
|
||||
* derived from this software without specific prior written permission.
|
||||
*
|
||||
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND ANY
|
||||
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
||||
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||
* DISCLAIMED. IN NO EVENT SHALL THE REGENTS AND CONTRIBUTORS BE LIABLE FOR ANY
|
||||
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
|
||||
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
|
||||
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
||||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
||||
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
*/
|
||||
|
||||
/* CRC16 implementation according to CCITT standards.
|
||||
*
|
||||
* Note by @antirez: this is actually the XMODEM CRC 16 algorithm, using the
|
||||
* following parameters:
|
||||
*
|
||||
* Name : "XMODEM", also known as "ZMODEM", "CRC-16/ACORN"
|
||||
* Width : 16 bit
|
||||
* Poly : 1021 (That is actually x^16 + x^12 + x^5 + 1)
|
||||
* Initialization : 0000
|
||||
* Reflect Input byte : False
|
||||
* Reflect Output CRC : False
|
||||
* Xor constant to output CRC : 0000
|
||||
* Output for "123456789" : 31C3
|
||||
*/
|
||||
|
||||
let crc16tab: [UInt16] = [
|
||||
0x0000, 0x1021, 0x2042, 0x3063, 0x4084, 0x50a5, 0x60c6, 0x70e7,
|
||||
0x8108, 0x9129, 0xa14a, 0xb16b, 0xc18c, 0xd1ad, 0xe1ce, 0xf1ef,
|
||||
0x1231, 0x0210, 0x3273, 0x2252, 0x52b5, 0x4294, 0x72f7, 0x62d6,
|
||||
0x9339, 0x8318, 0xb37b, 0xa35a, 0xd3bd, 0xc39c, 0xf3ff, 0xe3de,
|
||||
0x2462, 0x3443, 0x0420, 0x1401, 0x64e6, 0x74c7, 0x44a4, 0x5485,
|
||||
0xa56a, 0xb54b, 0x8528, 0x9509, 0xe5ee, 0xf5cf, 0xc5ac, 0xd58d,
|
||||
0x3653, 0x2672, 0x1611, 0x0630, 0x76d7, 0x66f6, 0x5695, 0x46b4,
|
||||
0xb75b, 0xa77a, 0x9719, 0x8738, 0xf7df, 0xe7fe, 0xd79d, 0xc7bc,
|
||||
0x48c4, 0x58e5, 0x6886, 0x78a7, 0x0840, 0x1861, 0x2802, 0x3823,
|
||||
0xc9cc, 0xd9ed, 0xe98e, 0xf9af, 0x8948, 0x9969, 0xa90a, 0xb92b,
|
||||
0x5af5, 0x4ad4, 0x7ab7, 0x6a96, 0x1a71, 0x0a50, 0x3a33, 0x2a12,
|
||||
0xdbfd, 0xcbdc, 0xfbbf, 0xeb9e, 0x9b79, 0x8b58, 0xbb3b, 0xab1a,
|
||||
0x6ca6, 0x7c87, 0x4ce4, 0x5cc5, 0x2c22, 0x3c03, 0x0c60, 0x1c41,
|
||||
0xedae, 0xfd8f, 0xcdec, 0xddcd, 0xad2a, 0xbd0b, 0x8d68, 0x9d49,
|
||||
0x7e97, 0x6eb6, 0x5ed5, 0x4ef4, 0x3e13, 0x2e32, 0x1e51, 0x0e70,
|
||||
0xff9f, 0xefbe, 0xdfdd, 0xcffc, 0xbf1b, 0xaf3a, 0x9f59, 0x8f78,
|
||||
0x9188, 0x81a9, 0xb1ca, 0xa1eb, 0xd10c, 0xc12d, 0xf14e, 0xe16f,
|
||||
0x1080, 0x00a1, 0x30c2, 0x20e3, 0x5004, 0x4025, 0x7046, 0x6067,
|
||||
0x83b9, 0x9398, 0xa3fb, 0xb3da, 0xc33d, 0xd31c, 0xe37f, 0xf35e,
|
||||
0x02b1, 0x1290, 0x22f3, 0x32d2, 0x4235, 0x5214, 0x6277, 0x7256,
|
||||
0xb5ea, 0xa5cb, 0x95a8, 0x8589, 0xf56e, 0xe54f, 0xd52c, 0xc50d,
|
||||
0x34e2, 0x24c3, 0x14a0, 0x0481, 0x7466, 0x6447, 0x5424, 0x4405,
|
||||
0xa7db, 0xb7fa, 0x8799, 0x97b8, 0xe75f, 0xf77e, 0xc71d, 0xd73c,
|
||||
0x26d3, 0x36f2, 0x0691, 0x16b0, 0x6657, 0x7676, 0x4615, 0x5634,
|
||||
0xd94c, 0xc96d, 0xf90e, 0xe92f, 0x99c8, 0x89e9, 0xb98a, 0xa9ab,
|
||||
0x5844, 0x4865, 0x7806, 0x6827, 0x18c0, 0x08e1, 0x3882, 0x28a3,
|
||||
0xcb7d, 0xdb5c, 0xeb3f, 0xfb1e, 0x8bf9, 0x9bd8, 0xabbb, 0xbb9a,
|
||||
0x4a75, 0x5a54, 0x6a37, 0x7a16, 0x0af1, 0x1ad0, 0x2ab3, 0x3a92,
|
||||
0xfd2e, 0xed0f, 0xdd6c, 0xcd4d, 0xbdaa, 0xad8b, 0x9de8, 0x8dc9,
|
||||
0x7c26, 0x6c07, 0x5c64, 0x4c45, 0x3ca2, 0x2c83, 0x1ce0, 0x0cc1,
|
||||
0xef1f, 0xff3e, 0xcf5d, 0xdf7c, 0xaf9b, 0xbfba, 0x8fd9, 0x9ff8,
|
||||
0x6e17, 0x7e36, 0x4e55, 0x5e74, 0x2e93, 0x3eb2, 0x0ed1, 0x1ef0,
|
||||
]
|
||||
|
||||
func crc16<Bytes: Sequence>(_ bytes: Bytes) -> UInt16 where Bytes.Element == UInt8 {
|
||||
var crc: UInt16 = 0
|
||||
for byte in bytes {
|
||||
crc = (crc &<< 8) ^ crc16tab[(Int(crc &>> 8) ^ Int(byte)) & 0x00FF]
|
||||
}
|
||||
return crc
|
||||
}
|
||||
@@ -0,0 +1,78 @@
|
||||
//===----------------------------------------------------------------------===//
|
||||
//
|
||||
// This source file is part of the RediStack open source project
|
||||
//
|
||||
// Copyright (c) 2023 RediStack project authors
|
||||
// Licensed under Apache License v2.0
|
||||
//
|
||||
// See LICENSE.txt for license information
|
||||
// See CONTRIBUTORS.txt for the list of RediStack project authors
|
||||
//
|
||||
// SPDX-License-Identifier: Apache-2.0
|
||||
//
|
||||
//===----------------------------------------------------------------------===//
|
||||
|
||||
@testable import RediStack
|
||||
import XCTest
|
||||
|
||||
final class RedisHashSlotTests: XCTestCase {
|
||||
func testEdgeValues() {
|
||||
XCTAssertEqual(RedisHashSlot.min.rawValue, 0)
|
||||
XCTAssertEqual(RedisHashSlot.max.rawValue, UInt16(pow(2.0, 14.0)) - 1)
|
||||
XCTAssertEqual(RedisHashSlot.unknown.rawValue, UInt16.max)
|
||||
}
|
||||
|
||||
func testExpressibleByIntegerLiteral() {
|
||||
let value: RedisHashSlot = 123
|
||||
XCTAssertEqual(value.rawValue, 123)
|
||||
}
|
||||
|
||||
func testStridable() {
|
||||
let value: RedisHashSlot = 123
|
||||
XCTAssertEqual(value.advanced(by: 12), 135)
|
||||
}
|
||||
|
||||
func testComparable() {
|
||||
let value: RedisHashSlot = 123
|
||||
XCTAssertGreaterThan(value.advanced(by: 1), value)
|
||||
XCTAssertLessThan(value.advanced(by: -1), value)
|
||||
}
|
||||
|
||||
func testCRC16() {
|
||||
XCTAssertEqual(crc16("123456789".utf8), 0x31C3)
|
||||
|
||||
// test cases generated here: https://crccalc.com
|
||||
XCTAssertEqual(crc16("Peter".utf8), 0x5E67)
|
||||
XCTAssertEqual(crc16("Fabian".utf8), 0x504F)
|
||||
XCTAssertEqual(crc16("Inverness".utf8), 0x7619)
|
||||
XCTAssertEqual(crc16("Redis is awesome".utf8), 0x345C)
|
||||
XCTAssertEqual(crc16([0xFF, 0xFF, 0x00, 0x00]), 0x84C0)
|
||||
XCTAssertEqual(crc16([0x00, 0x00]), 0x0000)
|
||||
}
|
||||
|
||||
func testHashTagComputation() {
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{user1000}.following").elementsEqual(RedisHashSlot.hashTag(forKey: "{user1000}.followers")))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{user1000}.following").elementsEqual("user1000".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{user1000}.followers").elementsEqual("user1000".utf8))
|
||||
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "foo{}{bar}").elementsEqual("foo{}{bar}".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "foo{{bar}}zap").elementsEqual("{bar".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "foo{bar}{zap}").elementsEqual("bar".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{}foo{bar}{zap}").elementsEqual("{}foo{bar}{zap}".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "foo").elementsEqual("foo".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "foo}").elementsEqual("foo}".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{foo}").elementsEqual("foo".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "bar{foo}").elementsEqual("foo".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "bar{}").elementsEqual("bar{}".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{}").elementsEqual("{}".utf8))
|
||||
XCTAssert(RedisHashSlot.hashTag(forKey: "{}bar").elementsEqual("{}bar".utf8))
|
||||
}
|
||||
|
||||
func testDescription() {
|
||||
XCTAssertEqual(String(describing: RedisHashSlot.min), "0")
|
||||
XCTAssertEqual(String(describing: RedisHashSlot.max), "16383")
|
||||
XCTAssertEqual(String(describing: RedisHashSlot.unknown), "unknown")
|
||||
XCTAssertEqual(String(describing: RedisHashSlot(rawValue: 3000)!), "3000")
|
||||
XCTAssertEqual(String(describing: RedisHashSlot(rawValue: 20)!), "20")
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user