Class: Kazoo::Partition

Inherits:
Object
  • Object
show all
Defined in:
lib/kazoo/partition.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(topic, id, replicas: nil) ⇒ Partition

Returns a new instance of Partition.



5
6
7
8
 
# File 'lib/kazoo/partition.rb', line 5

def initialize(topic, id, replicas: nil)
  @topic, @id, @replicas = topic, id, replicas
  @mutex = Mutex.new
end

Instance Attribute Details

#id ⇒ Object (readonly)

Returns the value of attribute id.



3
4
5
 
# File 'lib/kazoo/partition.rb', line 3

def id
  @id
end

#replicas ⇒ Object (readonly)

Returns the value of attribute replicas.



3
4
5
 
# File 'lib/kazoo/partition.rb', line 3

def replicas
  @replicas
end

#topic ⇒ Object (readonly)

Returns the value of attribute topic.



3
4
5
 
# File 'lib/kazoo/partition.rb', line 3

def topic
  @topic
end

Instance Method Details

#cluster ⇒ Object 



10
11
12
 
# File 'lib/kazoo/partition.rb', line 10

def cluster
  topic.cluster
end

#isr ⇒ Object 



25
26
27
28
29
30
 
# File 'lib/kazoo/partition.rb', line 25

def isr
  @mutex.synchronize do
    refresh_state if @isr.nil?
    @isr
  end
end

#leader ⇒ Object 



18
19
20
21
22
23
 
# File 'lib/kazoo/partition.rb', line 18

def leader
  @mutex.synchronize do
    refresh_state if @leader.nil?
    @leader
  end
end

#replication_factor ⇒ Object 



14
15
16
 
# File 'lib/kazoo/partition.rb', line 14

def replication_factor
  replicas.length
end

#under_replicated? ⇒ Boolean

Returns:

  • (Boolean) 


32
33
34
 
# File 'lib/kazoo/partition.rb', line 32

def under_replicated?
  isr.length < replication_factor
end