Class: NATS::JetStream::API::StreamConfig
- Inherits:
-
Struct
- Object
- Struct
- NATS::JetStream::API::StreamConfig
- Defined in:
- lib/nats/io/js.rb
Overview
StreamConfig represents the configuration of a stream from JetStream.
Instance Attribute Summary collapse
-
#allow_direct ⇒ Object
Returns the value of attribute allow_direct.
-
#allow_rollup_hdrs ⇒ Object
Returns the value of attribute allow_rollup_hdrs.
- #config ⇒ Hash
- #created ⇒ String
-
#deny_delete ⇒ Object
Returns the value of attribute deny_delete.
-
#deny_purge ⇒ Object
Returns the value of attribute deny_purge.
-
#description ⇒ Object
Returns the value of attribute description.
- #did_create ⇒ Boolean
- #discard ⇒ String
- #duplicate_window ⇒ Integer
- #max_age ⇒ Integer
- #max_bytes ⇒ Integer
- #max_consumers ⇒ Integer
- #max_msg_size ⇒ Integer
- #max_msgs ⇒ Integer
- #max_msgs_per_subject ⇒ Integer
-
#mirror ⇒ Object
Returns the value of attribute mirror.
-
#mirror_direct ⇒ Object
Returns the value of attribute mirror_direct.
- #name ⇒ String
-
#no_ack ⇒ Object
Returns the value of attribute no_ack.
- #num_replicas ⇒ Integer
-
#placement ⇒ Object
Returns the value of attribute placement.
-
#republish ⇒ Object
Returns the value of attribute republish.
- #retention ⇒ String
-
#sealed ⇒ Object
Returns the value of attribute sealed.
-
#sources ⇒ Object
Returns the value of attribute sources.
- #state ⇒ StreamState
- #storage ⇒ String
- #subjects ⇒ Array
- #type ⇒ String
Instance Method Summary collapse
-
#initialize(opts = {}) ⇒ StreamConfig
constructor
A new instance of StreamConfig.
- #to_json(*args) ⇒ Object
Constructor Details
#initialize(opts = {}) ⇒ StreamConfig
1319 1320 1321 1322 1323 1324 |
# File 'lib/nats/io/js.rb', line 1319 def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end |
Instance Attribute Details
#allow_direct ⇒ Object
Returns the value of attribute allow_direct
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def allow_direct @allow_direct end |
#allow_rollup_hdrs ⇒ Object
Returns the value of attribute allow_rollup_hdrs
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def allow_rollup_hdrs @allow_rollup_hdrs end |
#config ⇒ Hash
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#created ⇒ String
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#deny_delete ⇒ Object
Returns the value of attribute deny_delete
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def deny_delete @deny_delete end |
#deny_purge ⇒ Object
Returns the value of attribute deny_purge
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def deny_purge @deny_purge end |
#description ⇒ Object
Returns the value of attribute description
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def description @description end |
#did_create ⇒ Boolean
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#discard ⇒ String
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#duplicate_window ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#max_age ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#max_bytes ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#max_consumers ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#max_msg_size ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#max_msgs ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#max_msgs_per_subject ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#mirror ⇒ Object
Returns the value of attribute mirror
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def mirror @mirror end |
#mirror_direct ⇒ Object
Returns the value of attribute mirror_direct
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def mirror_direct @mirror_direct end |
#name ⇒ String
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#no_ack ⇒ Object
Returns the value of attribute no_ack
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def no_ack @no_ack end |
#num_replicas ⇒ Integer
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#placement ⇒ Object
Returns the value of attribute placement
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def placement @placement end |
#republish ⇒ Object
Returns the value of attribute republish
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def republish @republish end |
#retention ⇒ String
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#sealed ⇒ Object
Returns the value of attribute sealed
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def sealed @sealed end |
#sources ⇒ Object
Returns the value of attribute sources
1292 1293 1294 |
# File 'lib/nats/io/js.rb', line 1292 def sources @sources end |
#state ⇒ StreamState
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#storage ⇒ String
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#subjects ⇒ Array
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
#type ⇒ String
1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324 1325 1326 1327 1328 1329 1330 1331 |
# File 'lib/nats/io/js.rb', line 1292 StreamConfig = Struct.new( :name, :description, :subjects, :retention, :max_consumers, :max_msgs, :max_bytes, :discard, :max_age, :max_msgs_per_subject, :max_msg_size, :storage, :num_replicas, :no_ack, :duplicate_window, :placement, :mirror, :sources, :sealed, :deny_delete, :deny_purge, :allow_rollup_hdrs, :republish, :allow_direct, :mirror_direct, keyword_init: true) do def initialize(opts={}) # Filter unrecognized fields just in case. rem = opts.keys - members opts.delete_if { |k| rem.include?(k) } super(opts) end def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end end |
Instance Method Details
#to_json(*args) ⇒ Object
1326 1327 1328 1329 1330 |
# File 'lib/nats/io/js.rb', line 1326 def to_json(*args) config = self.to_h config.delete_if { |_k, v| v.nil? } config.to_json(*args) end |