Class: NATS::KeyValue::BucketStatus

Inherits:
Object
  • Object
show all
Defined in:
lib/nats/io/kv/bucket_status.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(info, bucket) ⇒ BucketStatus

Returns a new instance of BucketStatus.



22
23
24
25
# File 'lib/nats/io/kv/bucket_status.rb', line 22

def initialize(info, bucket)
  @stream_info = info
  @bucket = bucket
end

Instance Attribute Details

#bucketObject (readonly)

Returns the value of attribute bucket.



20
21
22
# File 'lib/nats/io/kv/bucket_status.rb', line 20

def bucket
  @bucket
end

#stream_infoObject (readonly)

Returns the value of attribute stream_info.



20
21
22
# File 'lib/nats/io/kv/bucket_status.rb', line 20

def stream_info
  @stream_info
end

Instance Method Details

#historyObject



31
32
33
# File 'lib/nats/io/kv/bucket_status.rb', line 31

def history
  @stream_info.config.max_msgs_per_subject
end

#ttlObject



35
36
37
# File 'lib/nats/io/kv/bucket_status.rb', line 35

def ttl
  @stream_info.config.max_age / ::NATS::NANOSECONDS
end

#valuesObject



27
28
29
# File 'lib/nats/io/kv/bucket_status.rb', line 27

def values
  @stream_info.state.messages
end