Class: NATS::JetStream::API::StreamCreateResponse

Inherits:

Struct

• Object
• Struct
• NATS::JetStream::API::StreamCreateResponse

Defined in:

lib/nats/io/jetstream/api.rb

Overview

StreamCreateResponse is the response from the JetStream $JS.API.STREAM.CREATE API.

Instance Attribute Summary

• #config ⇒ StreamConfig
• #created ⇒ String
• #did_create ⇒ Boolean
• #state ⇒ StreamState
• #type ⇒ String

Instance Method Summary

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

  A new instance of StreamCreateResponse.

Constructor Details

#initialize(opts = {}) ⇒ StreamCreateResponse

Returns a new instance of StreamCreateResponse.

# File 'lib/nats/io/jetstream/api.rb', line 274

def initialize(opts = {})
  rem = opts.keys - members
  opts.delete_if { |k| rem.include?(k) }
  opts[:config] = StreamConfig.new(opts[:config])
  opts[:state] = StreamState.new(opts[:state])
  super
  freeze
end

Instance Attribute Details

#config ⇒ StreamConfig

Returns:

• (StreamConfig)

# File 'lib/nats/io/jetstream/api.rb', line 272

StreamCreateResponse = Struct.new(:type, :config, :created, :state, :did_create,
  keyword_init: true) do
  def initialize(opts = {})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    super
    freeze
  end
end

#created ⇒ String

Returns:

• (String)

# File 'lib/nats/io/jetstream/api.rb', line 272

StreamCreateResponse = Struct.new(:type, :config, :created, :state, :did_create,
  keyword_init: true) do
  def initialize(opts = {})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    super
    freeze
  end
end

#did_create ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/nats/io/jetstream/api.rb', line 272

StreamCreateResponse = Struct.new(:type, :config, :created, :state, :did_create,
  keyword_init: true) do
  def initialize(opts = {})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    super
    freeze
  end
end

#state ⇒ StreamState

Returns:

• (StreamState)

# File 'lib/nats/io/jetstream/api.rb', line 272

StreamCreateResponse = Struct.new(:type, :config, :created, :state, :did_create,
  keyword_init: true) do
  def initialize(opts = {})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    super
    freeze
  end
end

#type ⇒ String

Returns:

• (String)

# File 'lib/nats/io/jetstream/api.rb', line 272

StreamCreateResponse = Struct.new(:type, :config, :created, :state, :did_create,
  keyword_init: true) do
  def initialize(opts = {})
    rem = opts.keys - members
    opts.delete_if { |k| rem.include?(k) }
    opts[:config] = StreamConfig.new(opts[:config])
    opts[:state] = StreamState.new(opts[:state])
    super
    freeze
  end
end