Class: NATS::JetStream::API::StreamCreateResponse
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb
Overview
StreamCreateResponse is the response from the JetStream $JS.API.STREAM.CREATE API.
Instance Attribute Summary collapse
Instance Method Summary collapse
-
#initialize(opts = {}) ⇒ StreamCreateResponse
constructor
A new instance of StreamCreateResponse.
Methods inherited from Struct
Constructor Details
#initialize(opts = {}) ⇒ StreamCreateResponse
Returns a new instance of StreamCreateResponse.
267 268 269 270 271 272 273 274 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb', line 267 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(opts) freeze end |
Instance Attribute Details
#config ⇒ StreamConfig
265 266 267 268 269 270 271 272 273 274 275 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb', line 265 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(opts) freeze end end |
#created ⇒ String
265 266 267 268 269 270 271 272 273 274 275 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb', line 265 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(opts) freeze end end |
#did_create ⇒ Boolean
265 266 267 268 269 270 271 272 273 274 275 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb', line 265 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(opts) freeze end end |
#state ⇒ StreamState
265 266 267 268 269 270 271 272 273 274 275 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb', line 265 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(opts) freeze end end |
#type ⇒ String
265 266 267 268 269 270 271 272 273 274 275 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/nats-pure-2.2.1/lib/nats/io/jetstream/api.rb', line 265 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(opts) freeze end end |