class PlaceOS::Edge::Client

• PlaceOS::Edge::Client
• Reference
• Object

Included Modules

• PlaceOS::Core::ProcessManager::Common

Defined in:

Constant Summary

Log = ::Log.for(self)

WEBSOCKET_API_PATH = "/api/engine/v2/edges/control"

Constructors

• .new(uri : URI = PLACE_URI, secret : String | Nil = nil, sequence_id : UInt64 = 0, skip_handshake : Bool = false, ping : Bool = true, store : PlaceOS::Core::DriverStore = Core::DriverStore.new)

Instance Method Summary

• #add_binary(key : String, binary : IO)
• #attempt_download(loaded_channel, key)
• #connect(initial_socket : HTTP::WebSocket | Nil = nil, &)

  Initialize the WebSocket API

• #connect(initial_socket : HTTP::WebSocket | Nil = nil)

  Initialize the WebSocket API

• #debug(module_id : String)
• #disconnect
• #drivers

  List the driver binaries present on this client

• #fetch_binary(key : String) : IO | Nil
• #forward_debug_message(module_id, message)
• #handle_request(sequence_id : UInt64, request : Protocol::Server::Request)
• #handshake
• #host : String
• #ignore(module_id : String)
• #load(module_id, driver_key)

  Check for binary, request if it's not present Start the module with redis hooks

• #load_binaries(binaries : Array(String))

  Kicks off downloading all the binaries

• #load_binary(key : String) : Channel(Nil) | Nil

  Load binary, first checking if present locally then fetch from core

• #modules

  List the modules running on this client

• #on_redis(action : Protocol::RedisAction, hash_id : String, key_name : String, status_value : String | Nil)

  Proxy a redis action via Core

• #on_setting(module_id : String, setting_name : String, setting_value : String)

  Proxy a settings write via Core

• #queue_start(module_id : String, payload : String)
• #remove_binary(key : String)

Constructor Detail

Instance Method Detail