Class: NATS::JetStream::API::SequenceInfo

Inherits:
Struct
  • Object
show all
Defined in:
lib/nats/io/jetstream/api.rb

Overview

SequenceInfo is a pair of consumer and stream sequence and last activity.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ SequenceInfo

Returns a new instance of SequenceInfo.



35
36
37
38
39
40
41
 
# File 'lib/nats/io/jetstream/api.rb', line 35

def initialize(opts = {})
  # Filter unrecognized fields and freeze.
  rem = opts.keys - members
  opts.delete_if { |k| rem.include?(k) }
  super
  freeze
end

Instance Attribute Details

#consumer_seq ⇒ Integer

Returns The consumer sequence.

Returns:

  • (Integer) —

    The consumer sequence.



33
34
35
36
37
38
39
40
41
42
 
# File 'lib/nats/io/jetstream/api.rb', line 33

SequenceInfo = Struct.new(:consumer_seq, :stream_seq, :last_active,
  keyword_init: true) do
  def initialize(opts = {})
    # Filter unrecognized fields and freeze.
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super
    freeze
  end
end

#last_active ⇒ Object

Returns the value of attribute last_active

Returns:

  • (Object) —

    the current value of last_active



33
34
35
 
# File 'lib/nats/io/jetstream/api.rb', line 33

def last_active
  @last_active
end

#stream_seq ⇒ Integer

Returns The stream sequence.

Returns:

  • (Integer) —

    The stream sequence.



33
34
35
36
37
38
39
40
41
42
 
# File 'lib/nats/io/jetstream/api.rb', line 33

SequenceInfo = Struct.new(:consumer_seq, :stream_seq, :last_active,
  keyword_init: true) do
  def initialize(opts = {})
    # Filter unrecognized fields and freeze.
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super
    freeze
  end
end