Class: Quark::MdkDiscovery::StaticRoutesActor

Inherits:
DatawireQuarkCore::QuarkObject show all
Extended by:
DatawireQuarkCore::Static
Defined in:
lib/mdk_discovery.rb

Overview

Discovery actor for hard-coded static routes.

Constant Summary

Constants included from DatawireQuarkCore::Static

DatawireQuarkCore::Static::Unassigned

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from DatawireQuarkCore::Static

_lazy_statics, static, unlazy_statics

Methods inherited from DatawireQuarkCore::QuarkObject

#to_s

Constructor Details

#initialize(subscriber, knownNodes) ⇒ StaticRoutesActor

Returns a new instance of StaticRoutesActor.



309
310
311
312
313
314
315
316
 
# File 'lib/mdk_discovery.rb', line 309

def initialize(subscriber, knownNodes)
    
    self.__init_fields__
    (self)._subscriber = subscriber
    (self)._knownNodes = knownNodes

    nil
end

Instance Attribute Details

#_knownNodes ⇒ Object

Returns the value of attribute _knownNodes.



302
303
304
 
# File 'lib/mdk_discovery.rb', line 302

def _knownNodes
  @_knownNodes
end

#_subscriber ⇒ Object

Returns the value of attribute _subscriber.



302
303
304
 
# File 'lib/mdk_discovery.rb', line 302

def _subscriber
  @_subscriber
end

Instance Method Details

#__init_fields__ ⇒ Object 



378
379
380
381
382
383
384
 
# File 'lib/mdk_discovery.rb', line 378

def __init_fields__()
    
    self._subscriber = nil
    self._knownNodes = nil

    nil
end

#_getClass ⇒ Object 



346
347
348
349
350
351
 
# File 'lib/mdk_discovery.rb', line 346

def _getClass()
    
    return "mdk_discovery._StaticRoutesActor"

    nil
end

#_getField(name) ⇒ Object 



353
354
355
356
357
358
359
360
361
362
363
364
 
# File 'lib/mdk_discovery.rb', line 353

def _getField(name)
    
    if ((name) == ("_subscriber"))
        return (self)._subscriber
    end
    if ((name) == ("_knownNodes"))
        return (self)._knownNodes
    end
    return nil

    nil
end

#_setField(name, value) ⇒ Object 



366
367
368
369
370
371
372
373
374
375
376
 
# File 'lib/mdk_discovery.rb', line 366

def _setField(name, value)
    
    if ((name) == ("_subscriber"))
        (self)._subscriber = ::DatawireQuarkCore.cast(value) { ::Quark.mdk_runtime.actors.Actor }
    end
    if ((name) == ("_knownNodes"))
        (self)._knownNodes = ::DatawireQuarkCore.cast(value) { ::DatawireQuarkCore::List }
    end

    nil
end

#onMessage(origin, message) ⇒ Object 



332
333
334
335
336
337
 
# File 'lib/mdk_discovery.rb', line 332

def onMessage(origin, message)
    
    nil

    nil
end

#onStart(dispatcher) ⇒ Object 



321
322
323
324
325
326
327
328
329
330
 
# File 'lib/mdk_discovery.rb', line 321

def onStart(dispatcher)
    
    idx = 0
    while ((idx) < (((self)._knownNodes).size)) do
        dispatcher.tell(self, ::Quark.mdk_discovery.NodeActive.new(((self)._knownNodes)[idx]), (self)._subscriber)
        idx = (idx) + (1)
    end

    nil
end

#onStop ⇒ Object 



339
340
341
342
343
344
 
# File 'lib/mdk_discovery.rb', line 339

def onStop()
    
    nil

    nil
end