Class: LS4::MembershipService

Inherits:
Service show all
Defined in:
lib/ls4/service/membership.rb

Instance Method Summary collapse

Methods inherited from Service

init

Methods included from EventBus::SingletonMixin

#ebus_bind!, #ebus_connect, extended

Methods included from EventBus::BusMixin

#ebus_all_slots, #ebus_disconnect!

Methods included from EventBus::DeclarerBase::Methods

#connect, #ebus_all_slots, #ebus_call_log, #ebus_call_slots, #ebus_signal_error, #ebus_signal_log, #ebus_signal_slots

Methods included from EventBus::DeclarerBase

#call_slot, #signal_slot

Constructor Details

#initialize ⇒ MembershipService

Returns a new instance of MembershipService.



35
36
37
38
 
# File 'lib/ls4/service/membership.rb', line 35

def initialize
  @membership = Membership.new
  @fault_list = FaultList.new
end

Instance Method Details

#get_active_rsids ⇒ Object 



62
63
64
 
# File 'lib/ls4/service/membership.rb', line 62

def get_active_rsids
  @membership.get_active_rsids
end

#get_all_nodes ⇒ Object 



58
59
60
 
# File 'lib/ls4/service/membership.rb', line 58

def get_all_nodes
  @membership.get_all_nodes
end

#get_node(nid) ⇒ Object 



54
55
56
 
# File 'lib/ls4/service/membership.rb', line 54

def get_node(nid)
  @membership.get_node(nid)
end

#get_session_nid(nid) ⇒ Object 



70
71
72
 
# File 'lib/ls4/service/membership.rb', line 70

def get_session_nid(nid)
  ProcessBus.get_session(get_node(nid).address)
end

#is_fault(nid) ⇒ Object 



66
67
68
 
# File 'lib/ls4/service/membership.rb', line 66

def is_fault(nid)
  @fault_list.include?(nid)
end

#on_fault_list_change ⇒ Object 



87
88
89
 
# File 'lib/ls4/service/membership.rb', line 87

def on_fault_list_change
  # TODO update balance bus?
end

#on_membership_change ⇒ Object 



82
83
84
85
 
# File 'lib/ls4/service/membership.rb', line 82

def on_membership_change
  BalanceBus.update_weight
  MasterSelectBus.update_nodes
end

#run ⇒ Object 



40
41
42
43
44
45
46
47
 
# File 'lib/ls4/service/membership.rb', line 40

def run
  @fault_path = ConfigBus.get_fault_path
  @membership_path = ConfigBus.get_membership_path
  @fault_list.open(@fault_path) if @fault_path
  @membership.open(@membership_path) if @membership_path
  on_membership_change
  on_fault_list_change
end

#shutdown ⇒ Object 



49
50
51
52
 
# File 'lib/ls4/service/membership.rb', line 49

def shutdown
  @fault_list.close if @fault_path
  @membership.close if @membership_path
end

#stat_fault_info ⇒ Object 



78
79
80
 
# File 'lib/ls4/service/membership.rb', line 78

def stat_fault_info
  @fault_list
end

#stat_membership_info ⇒ Object 



74
75
76
 
# File 'lib/ls4/service/membership.rb', line 74

def stat_membership_info
  @membership
end

#stat_replset_info ⇒ Object 



91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
 
# File 'lib/ls4/service/membership.rb', line 91

def stat_replset_info
  rsid_nids = {}
  MembershipBus.get_all_nodes.each {|node|
    node.rsids.each {|rsid|
      (rsid_nids[rsid] ||= []) << node.nid
    }
  }

  rsids = WeightBus.get_registered_rsids + MembershipBus.get_active_rsids
  rsids.uniq!

  result = {}
  rsids.each {|rsid|
    weight = WeightBus.get_weight(rsid)
    nids = rsid_nids[rsid] || []
    result[rsid] = [nids, weight]
  }

  result
end