Class: Protobuf::Rpc::ServiceDirectory

Inherits:
Object
  • Object
show all
Includes:
Logging, Singleton
Defined in:
lib/protobuf/rpc/service_directory.rb

Defined Under Namespace

Classes: Listing

Constant Summary collapse

DEFAULT_ADDRESS = 
"0.0.0.0"
DEFAULT_PORT = 
53000
DEFAULT_TIMEOUT = 
1

Class Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Logging

initialize_logger, #log_exception, #log_signature, #logger, logger, logger=, #sign_message

Constructor Details

#initialize ⇒ ServiceDirectory

Instance Methods



83
84
85
 
# File 'lib/protobuf/rpc/service_directory.rb', line 83

def initialize
  reset
end

Class Attribute Details

.address ⇒ Object 



63
64
65
 
# File 'lib/protobuf/rpc/service_directory.rb', line 63

def self.address
  @address ||= DEFAULT_ADDRESS
end

.port ⇒ Object 



67
68
69
 
# File 'lib/protobuf/rpc/service_directory.rb', line 67

def self.port
  @port ||= DEFAULT_PORT
end

Class Method Details

.start {|_self| ... } ⇒ Object

Yields:

  • (_self)

Yield Parameters:



71
72
73
74
 
# File 'lib/protobuf/rpc/service_directory.rb', line 71

def self.start
  yield(self) if block_given?
  self.instance.start
end

.stop ⇒ Object 



76
77
78
 
# File 'lib/protobuf/rpc/service_directory.rb', line 76

def self.stop
  self.instance.stop
end

Instance Method Details

#all_listings_for(service) ⇒ Object 



87
88
89
90
91
92
93
 
# File 'lib/protobuf/rpc/service_directory.rb', line 87

def all_listings_for(service)
  if running? && @listings_by_service.key?(service.to_s)
    @listings_by_service[service.to_s].entries.shuffle
  else
    []
  end
end

#each_listing(&block) ⇒ Object 



95
96
97
 
# File 'lib/protobuf/rpc/service_directory.rb', line 95

def each_listing(&block)
  @listings_by_uuid.each_value(&block)
end

#lookup(service) ⇒ Object 



99
100
101
102
103
104
105
 
# File 'lib/protobuf/rpc/service_directory.rb', line 99

def lookup(service)
  if running?
    if @listings_by_service.key?(service.to_s)
      @listings_by_service[service.to_s].entries.sample
    end
  end
end

#restart ⇒ Object 



107
108
109
110
 
# File 'lib/protobuf/rpc/service_directory.rb', line 107

def restart
  stop
  start
end

#running? ⇒ Boolean

Returns:

  • (Boolean) 


112
113
114
 
# File 'lib/protobuf/rpc/service_directory.rb', line 112

def running?
  !!@thread.try(:alive?)
end

#start ⇒ Object 



116
117
118
119
120
121
122
123
124
 
# File 'lib/protobuf/rpc/service_directory.rb', line 116

def start
  unless running?
    init_socket
    logger.info { sign_message("listening to udp://#{self.class.address}:#{self.class.port}") }
    @thread = Thread.new { self.send(:run) }
  end

  self
end

#stop ⇒ Object 



126
127
128
129
130
131
132
133
 
# File 'lib/protobuf/rpc/service_directory.rb', line 126

def stop
  logger.info { sign_message("Stopping directory") }

  @thread.try(:kill).try(:join)
  @socket.try(:close)

  reset
end