Module: Quark::MdkRuntime

Defined in:
lib/mdk_runtime.rb,
lib/mdk_runtime/files.rb,
lib/mdk_runtime/actors.rb,
lib/mdk_runtime/promise.rb

Defined Under Namespace

Modules: Actors, Files, Promise Classes: Dependencies, EnvironmentVariable, EnvironmentVariables, FakeEnvVars, FakeTime, FakeTimeRequest, FakeWSActor, FakeWebSockets, Happening, MDKRuntime, QuarkRuntimeTime, QuarkRuntimeWSActor, QuarkRuntimeWebSockets, RealEnvVars, Schedule, ScheduleTask, SchedulingActor, Time, WSActor, WSClose, WSClosed, WSConnectError, WSMessage, WebSockets

Class Method Summary collapse

Class Method Details

._FakeTimeRequest ⇒ Object 



1910
 
# File 'lib/mdk_runtime.rb', line 1910

def self._FakeTimeRequest; FakeTimeRequest; end

._ScheduleTask ⇒ Object 



1297
 
# File 'lib/mdk_runtime.rb', line 1297

def self._ScheduleTask; ScheduleTask; end

.actors ⇒ Object 



6
 
# File 'lib/mdk_runtime/actors.rb', line 6

def self.actors; Actors; end

.defaultRuntime ⇒ Object

Create a MDKRuntime with the default configuration and start its actors.



1539
1540
1541
1542
1543
1544
1545
1546
1547
1548
1549
1550
1551
1552
1553
1554
1555
1556
1557
1558
 
# File 'lib/mdk_runtime.rb', line 1539

def self.defaultRuntime()
    
    runtime = ::Quark.mdk_runtime.MDKRuntime.new()
    (runtime).dispatcher = ::Quark.mdk_runtime.actors.MessageDispatcher.new(::Quark.mdk_runtime.actors._QuarkRuntimeLaterCaller.new())
    (runtime).dependencies.registerService("envvar", ::Quark.mdk_runtime.RealEnvVars.new())
    timeService = ::Quark.mdk_runtime.QuarkRuntimeTime.new()
    websockets = ::Quark.mdk_runtime.QuarkRuntimeWebSockets.new()
    (runtime).dependencies.registerService("time", timeService)
    (runtime).dependencies.registerService("schedule", timeService)
    (runtime).dependencies.registerService("websockets", websockets)
    fileActor = ::Quark.mdk_runtime.files.FileActorImpl.new(runtime)
    (runtime).dependencies.registerService("files", fileActor)
    (runtime).dispatcher.startActor(timeService)
    (runtime).dispatcher.startActor(websockets)
    (runtime).dispatcher.startActor(fileActor)
    return runtime


    nil
end

.Dependencies ⇒ Object 



17
 
# File 'lib/mdk_runtime.rb', line 17

def self.Dependencies; Dependencies; end

.EnvironmentVariable ⇒ Object 



763
 
# File 'lib/mdk_runtime.rb', line 763

def self.EnvironmentVariable; EnvironmentVariable; end

.EnvironmentVariables ⇒ Object 



857
 
# File 'lib/mdk_runtime.rb', line 857

def self.EnvironmentVariables; EnvironmentVariables; end

.FakeEnvVars ⇒ Object 



2136
 
# File 'lib/mdk_runtime.rb', line 2136

def self.FakeEnvVars; FakeEnvVars; end

.fakeRuntime ⇒ Object 



2212
2213
2214
2215
2216
2217
2218
2219
2220
2221
2222
2223
2224
2225
2226
2227
2228
2229
2230
2231
 
# File 'lib/mdk_runtime.rb', line 2212

def self.fakeRuntime()
    
    runtime = ::Quark.mdk_runtime.MDKRuntime.new()
    (runtime).dependencies.registerService("envvar", ::Quark.mdk_runtime.FakeEnvVars.new())
    (runtime).dispatcher = ::Quark.mdk_runtime.actors.MessageDispatcher.new(::Quark.mdk_runtime.actors._ManualLaterCaller.new())
    timeService = ::Quark.mdk_runtime.FakeTime.new()
    websockets = ::Quark.mdk_runtime.FakeWebSockets.new()
    (runtime).dependencies.registerService("time", timeService)
    (runtime).dependencies.registerService("schedule", timeService)
    (runtime).dependencies.registerService("websockets", websockets)
    fileActor = ::Quark.mdk_runtime.files.FileActorImpl.new(runtime)
    (runtime).dependencies.registerService("files", fileActor)
    (runtime).dispatcher.startActor(timeService)
    (runtime).dispatcher.startActor(websockets)
    (runtime).dispatcher.startActor(fileActor)
    return runtime


    nil
end

.FakeTime ⇒ Object 



1983
 
# File 'lib/mdk_runtime.rb', line 1983

def self.FakeTime; FakeTime; end

.FakeWebSockets ⇒ Object 



1801
 
# File 'lib/mdk_runtime.rb', line 1801

def self.FakeWebSockets; FakeWebSockets; end

.FakeWSActor ⇒ Object 



1561
 
# File 'lib/mdk_runtime.rb', line 1561

def self.FakeWSActor; FakeWSActor; end

.files ⇒ Object 



6
 
# File 'lib/mdk_runtime/files.rb', line 6

def self.files; Files; end

.Happening ⇒ Object 



695
 
# File 'lib/mdk_runtime.rb', line 695

def self.Happening; Happening; end

.log_to_file(s) ⇒ Object

On Python, log to a per-process file if MDK_LOG_MESSAGES env variable is set.



903
904
905
906
907
908
909
910
911
 
# File 'lib/mdk_runtime.rb', line 903

def self.log_to_file(s)
    
    if ((::Quark.quark.os.Environment.getEnvironment().__get__("MDK_LOG_MESSAGES")) != (nil))
        o = ""
    end


    nil
end

.MDKRuntime ⇒ Object 



111
 
# File 'lib/mdk_runtime.rb', line 111

def self.MDKRuntime; MDKRuntime; end

.promise ⇒ Object 



6
 
# File 'lib/mdk_runtime/promise.rb', line 6

def self.promise; Promise; end

.QuarkRuntimeTime ⇒ Object 



1377
 
# File 'lib/mdk_runtime.rb', line 1377

def self.QuarkRuntimeTime; QuarkRuntimeTime; end

.QuarkRuntimeWebSockets ⇒ Object 



1186
 
# File 'lib/mdk_runtime.rb', line 1186

def self.QuarkRuntimeWebSockets; QuarkRuntimeWebSockets; end

.QuarkRuntimeWSActor ⇒ Object 



913
 
# File 'lib/mdk_runtime.rb', line 913

def self.QuarkRuntimeWSActor; QuarkRuntimeWSActor; end

.RealEnvVars ⇒ Object 



1478
 
# File 'lib/mdk_runtime.rb', line 1478

def self.RealEnvVars; RealEnvVars; end

.Schedule ⇒ Object 



625
 
# File 'lib/mdk_runtime.rb', line 625

def self.Schedule; Schedule; end

.SchedulingActor ⇒ Object 



285
 
# File 'lib/mdk_runtime.rb', line 285

def self.SchedulingActor; SchedulingActor; end

.Time ⇒ Object 



244
 
# File 'lib/mdk_runtime.rb', line 244

def self.Time; Time; end

.WebSockets ⇒ Object 



319
 
# File 'lib/mdk_runtime.rb', line 319

def self.WebSockets; WebSockets; end

.WSActor ⇒ Object 



428
 
# File 'lib/mdk_runtime.rb', line 428

def self.WSActor; WSActor; end

.WSClose ⇒ Object 



523
 
# File 'lib/mdk_runtime.rb', line 523

def self.WSClose; WSClose; end

.WSClosed ⇒ Object 



574
 
# File 'lib/mdk_runtime.rb', line 574

def self.WSClosed; WSClosed; end

.WSConnectError ⇒ Object 



363
 
# File 'lib/mdk_runtime.rb', line 363

def self.WSConnectError; WSConnectError; end

.WSMessage ⇒ Object 



463
 
# File 'lib/mdk_runtime.rb', line 463

def self.WSMessage; WSMessage; end