1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
# frozen_string_literal: true
require 'redis_client'
class RedisClient
class Cluster
class Error < ::RedisClient::Error
def with_config(config)
@config = config
self
end
end
ERR_ARG_NORMALIZATION = ->(arg) { Array[arg].flatten.reject { |e| e.nil? || (e.respond_to?(:empty?) && e.empty?) } }
Ractor.make_shareable(ERR_ARG_NORMALIZATION) if Object.const_defined?(:Ractor, false) && Ractor.respond_to?(:make_shareable)
private_constant :ERR_ARG_NORMALIZATION
class InitialSetupError < Error
def self.from_errors(errors)
msg = ERR_ARG_NORMALIZATION.call(errors).map(&:message).uniq.join(',')
new("Redis client could not fetch cluster information: #{msg}")
end
end
class OrchestrationCommandNotSupported < Error
def self.from_command(command)
str = ERR_ARG_NORMALIZATION.call(command).map(&:to_s).join(' ').upcase
msg = "#{str} command should be used with care " \
'only by applications orchestrating Redis Cluster, like redis-cli, ' \
'and the command if used out of the right context can leave the cluster ' \
'in a wrong state or cause data loss.'
new(msg)
end
end
class ErrorCollection < Error
EMPTY_HASH = {}.freeze
private_constant :EMPTY_HASH
attr_reader :errors
def self.with_errors(errors)
if !errors.is_a?(Hash) || errors.empty?
new(errors.to_s).with_errors(EMPTY_HASH)
else
messages = errors.map { |node_key, error| "#{node_key}: (#{error.class}) #{error.message}" }.freeze
new(messages.join(', ')).with_errors(errors)
end
end
def initialize(error_message = nil)
@errors = nil
super
end
def with_errors(errors)
@errors = errors if @errors.nil?
self
end
end
class AmbiguousNodeError < Error
def self.from_command(command)
new("Cluster client doesn't know which node the #{command} command should be sent to.")
end
end
class NodeMightBeDown < Error
def initialize(_error_message = nil)
super(
'The client is trying to fetch the latest cluster state ' \
'because a subset of nodes might be down. ' \
'It might continue to raise errors for a while.'
)
end
end
end
end
|
