class PlaceOS::Core::ProcessManager::Edge

Included Modules

Defined in:

placeos-core/process_manager/edge.cr

Constant Summary

Log = ::Log.for(self)

Constructors

Class Method Summary

Instance Method Summary

Instance methods inherited from module PlaceOS::Core::ProcessManager

attach_debugger(module_id : String, socket : HTTP::WebSocket) attach_debugger, debug(module_id : String, &_on_message : DebugCallback) debug, driver_loaded?(driver_key : String) : Bool driver_loaded?, driver_status(driver_key : String) : DriverStatus | Nil driver_status, execute(module_id : String, payload : String, user_id : String | Nil) execute, ignore(module_id : String, &_on_message : DebugCallback)
ignore(module_id : String) : Array(DebugCallback)
ignore
, kill(driver_key : String) kill, load(module_id : String, driver_key : String) load, loaded_modules loaded_modules, module_loaded?(module_id : String) : Bool module_loaded?, on_exec(request : Request, response_callback : Request -> ) on_exec, on_setting(id : String, setting_name : String, setting_value : YAML::Any) on_setting, on_system_model(request : Request, response_callback : Request -> ) on_system_model, run_count : Count run_count, start(module_id : String, payload : String) start, stop(module_id : String) stop, system_status : SystemStatus system_status, unload(module_id : String) unload

Class methods inherited from module PlaceOS::Core::ProcessManager

path_to_key(path : String) : String path_to_key

Constructor Detail

def self.new(edge_id : String, socket : HTTP::WebSocket) #

[View source]

Class Method Detail

def self.extract_remote_error_class(message : String) : Tuple(String, String) #

Uses a Regex to extract the remote exception.


[View source]

Instance Method Detail

def debug(module_id : String, &on_message : DebugCallback) #

[View source]
def driver_loaded?(driver_key : String) : Bool #
Description copied from module PlaceOS::Core::ProcessManager

Check for the presence of a running driver on a ProcessManager


[View source]
def driver_status(driver_key : String) : DriverStatus | Nil #
Description copied from module PlaceOS::Core::ProcessManager

Generate a system status report


[View source]
def edge_id : String #

[View source]
def execute(module_id : String, payload : String, user_id : String | Nil) #
Description copied from module PlaceOS::Core::ProcessManager

Execute a driver method on a module


[View source]
def fetch_binary(driver_key : String) : Protocol::Message::BinaryBody #

[View source]
def forward_debug_message(module_id : String, message : String) #

[View source]
def handle_request(sequence_id : UInt64, request : Protocol::Client::Request) #

[View source]
def ignore(module_id : String, &on_message : DebugCallback) #

[View source]
def ignore(module_id : String) : Array(DebugCallback) #

Remove all debug listeners on a module, returning the debug callback array


[View source]
def kill(driver_key : String) #

[View source]
def load(module_id : String, driver_key : String) #

[View source]
def loaded_modules #
Description copied from module PlaceOS::Core::ProcessManager

Count of distinct modules loaded on a ProcessManager


[View source]
def module_loaded?(module_id : String) : Bool #
Description copied from module PlaceOS::Core::ProcessManager

Check for the presence of a module on a ProcessManager


[View source]
def on_exec(request : Request, response_callback : Request -> ) #
Description copied from module PlaceOS::Core::ProcessManager

Handler for execute requests from a module


[View source]
def on_redis(action : Protocol::RedisAction, hash_id : String, key_name : String, status_value : String | Nil) #

[View source]
def on_system_model(request : Request, response_callback : Request -> ) #
Description copied from module PlaceOS::Core::ProcessManager

Handler for retrieving PlaceOS::Model::ControlSystems for logic modules


[View source]
def run_count : Count #
Description copied from module PlaceOS::Core::ProcessManager

Returns the count of ...

  • unique drivers running
  • module processes

[View source]
def start(module_id : String, payload : String) #

[View source]
def stop(module_id : String) #

[View source]
def system_status : SystemStatus #
Description copied from module PlaceOS::Core::ProcessManager

Generate a system status report


[View source]
def transport : Transport #

[View source]
def unload(module_id : String) #

[View source]