Class: NATS::JetStream::API::StreamInfo

Inherits:

Struct

• Object
• Struct
• NATS::JetStream::API::StreamInfo

Defined in:

lib/nats/io/js.rb

Overview

StreamInfo is the info about a stream from JetStream.

Instance Attribute Summary

• #config ⇒ Hash
• #created ⇒ String
• #domain ⇒ String
• #state ⇒ Hash
• #type ⇒ String

Instance Method Summary

• #initialize(opts = {}) ⇒ StreamInfo constructor

  A new instance of StreamInfo.

Constructor Details

#initialize(opts = {}) ⇒ StreamInfo

Returns a new instance of StreamInfo.

# File 'lib/nats/io/js.rb', line 1244

def initialize(opts={})
  opts[:config] = StreamConfig.new(opts[:config])
  opts[:state] = StreamState.new(opts[:state])
  opts[:created] = Time.parse(opts[:created])

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

Instance Attribute Details

#config ⇒ Hash

Returns:

• (Hash)

# File 'lib/nats/io/js.rb', line 1242

StreamInfo = Struct.new(:type, :config, :created, :state, :domain,
                        keyword_init: true) do
  def initialize(opts={})
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    opts[:created] = Time.parse(opts[:created])

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

#created ⇒ String

Returns:

• (String)

# File 'lib/nats/io/js.rb', line 1242

StreamInfo = Struct.new(:type, :config, :created, :state, :domain,
                        keyword_init: true) do
  def initialize(opts={})
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    opts[:created] = Time.parse(opts[:created])

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

#domain ⇒ String

Returns:

• (String)

# File 'lib/nats/io/js.rb', line 1242

StreamInfo = Struct.new(:type, :config, :created, :state, :domain,
                        keyword_init: true) do
  def initialize(opts={})
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    opts[:created] = Time.parse(opts[:created])

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

#state ⇒ Hash

Returns:

• (Hash)

# File 'lib/nats/io/js.rb', line 1242

StreamInfo = Struct.new(:type, :config, :created, :state, :domain,
                        keyword_init: true) do
  def initialize(opts={})
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    opts[:created] = Time.parse(opts[:created])

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

#type ⇒ String

Returns:

• (String)

# File 'lib/nats/io/js.rb', line 1242

StreamInfo = Struct.new(:type, :config, :created, :state, :domain,
                        keyword_init: true) do
  def initialize(opts={})
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    opts[:created] = Time.parse(opts[:created])

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