Class: MockRedis::Stream::Id

Inherits:
Object
  • Object
show all
Includes:
Comparable
Defined in:
lib/mock_redis/stream/id.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(id, min: nil, sequence: 0) ⇒ Id

Returns a new instance of Id.



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
 
# File 'lib/mock_redis/stream/id.rb', line 8

def initialize(id, min: nil, sequence: 0)
  @exclusive = false
  case id
  when '*'
    @timestamp = (Time.now.to_f * 1000).to_i
    @sequence = 0
    if self <= min
      @timestamp = min.timestamp
      @sequence = min.sequence + 1
    end
  when '-'
    @timestamp = @sequence = 0
  when '+'
    @timestamp = @sequence = Float::INFINITY
  else
    if id.is_a? String
      # See https://redis.io/topics/streams-intro
      # Ids are a unix timestamp in milliseconds followed by an
      # optional dash sequence number, e.g. -0. They can also optionally
      # be prefixed with '(' to change the XRANGE to exclusive.
      (_, @timestamp, @sequence) = id.match(/^\(?(\d+)-?(\d+)?$/).to_a
      @exclusive = true if id[0] == '('
      if @timestamp.nil?
        raise Redis::CommandError,
              'ERR Invalid stream ID specified as stream command argument'
      end
      @timestamp = @timestamp.to_i
    else
      @timestamp = id
    end
    @sequence = @sequence.nil? ? sequence : @sequence.to_i
    if self <= min
      raise Redis::CommandError,
            'ERR The ID specified in XADD is equal or smaller than ' \
            'the target stream top item'
    end
  end
end

Instance Attribute Details

#exclusive ⇒ Object

Returns the value of attribute exclusive.



6
7
8
 
# File 'lib/mock_redis/stream/id.rb', line 6

def exclusive
  @exclusive
end

#sequence ⇒ Object

Returns the value of attribute sequence.



6
7
8
 
# File 'lib/mock_redis/stream/id.rb', line 6

def sequence
  @sequence
end

#timestamp ⇒ Object

Returns the value of attribute timestamp.



6
7
8
 
# File 'lib/mock_redis/stream/id.rb', line 6

def timestamp
  @timestamp
end

Instance Method Details

#<=>(other) ⇒ Object 



51
52
53
54
55
 
# File 'lib/mock_redis/stream/id.rb', line 51

def <=>(other)
  return 1 if other.nil?
  return @sequence <=> other.sequence if @timestamp == other.timestamp
  @timestamp <=> other.timestamp
end

#to_s ⇒ Object 



47
48
49
 
# File 'lib/mock_redis/stream/id.rb', line 47

def to_s
  "#{@timestamp}-#{@sequence}"
end