Class: NATS::JetStream::API::StreamState

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

Overview

StreamState is the state of a stream.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ StreamState

Returns a new instance of StreamState.



1272
1273
1274
1275
1276
 
# File 'lib/nats/io/js.rb', line 1272

def initialize(opts={})
  rem = opts.keys - members
  opts.delete_if { |k| rem.include?(k) }
  super(opts)
end

Instance Attribute Details

#bytes ⇒ Integer

Returns:

  • (Integer) 


1269
1270
1271
1272
1273
1274
1275
1276
1277
 
# File 'lib/nats/io/js.rb', line 1269

StreamState = Struct.new(:messages, :bytes, :first_seq, :first_ts,
                         :last_seq, :last_ts, :consumer_count,
                         keyword_init: true) do
  def initialize(opts={})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
  end
end

#consumer_count ⇒ Integer

Returns:

  • (Integer) 


1269
1270
1271
1272
1273
1274
1275
1276
1277
 
# File 'lib/nats/io/js.rb', line 1269

StreamState = Struct.new(:messages, :bytes, :first_seq, :first_ts,
                         :last_seq, :last_ts, :consumer_count,
                         keyword_init: true) do
  def initialize(opts={})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
  end
end

#first_seq ⇒ Integer

Returns:

  • (Integer) 


1269
1270
1271
1272
1273
1274
1275
1276
1277
 
# File 'lib/nats/io/js.rb', line 1269

StreamState = Struct.new(:messages, :bytes, :first_seq, :first_ts,
                         :last_seq, :last_ts, :consumer_count,
                         keyword_init: true) do
  def initialize(opts={})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
  end
end

#first_ts ⇒ Object

Returns the value of attribute first_ts

Returns:

  • (Object) —

    the current value of first_ts



1269
1270
1271
 
# File 'lib/nats/io/js.rb', line 1269

def first_ts
  @first_ts
end

#last_seq ⇒ Integer

Returns:

  • (Integer) 


1269
1270
1271
1272
1273
1274
1275
1276
1277
 
# File 'lib/nats/io/js.rb', line 1269

StreamState = Struct.new(:messages, :bytes, :first_seq, :first_ts,
                         :last_seq, :last_ts, :consumer_count,
                         keyword_init: true) do
  def initialize(opts={})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
  end
end

#last_ts ⇒ Object

Returns the value of attribute last_ts

Returns:

  • (Object) —

    the current value of last_ts



1269
1270
1271
 
# File 'lib/nats/io/js.rb', line 1269

def last_ts
  @last_ts
end

#messages ⇒ Integer

Returns:

  • (Integer) 


1269
1270
1271
1272
1273
1274
1275
1276
1277
 
# File 'lib/nats/io/js.rb', line 1269

StreamState = Struct.new(:messages, :bytes, :first_seq, :first_ts,
                         :last_seq, :last_ts, :consumer_count,
                         keyword_init: true) do
  def initialize(opts={})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    super(opts)
  end
end