class

Meridian::SSH::Executor

Inherits Reference < Object

Constants

CONTROL_PERSIST = "60s"
CONTROL_SOCKET_DIR = File.expand_path("~/.ssh/meridian", home: true)

Connection multiplexing: every remote operation reuses one master connection per (host, port, user) instead of paying a fresh TCP + auth handshake. A single health check alone opens retries connections.

Image streams also share the master, so a long transfer occupies it and interrupts in-flight sessions if the master drops. Let Transfer::Stream opt out of multiplexing if that becomes disruptive.

MAX_OUTPUT_TAIL = 4096

Constructors

new(runner : Runner = ProcessRunner.new, streaming_runner : StreamingRunner = ProcessStreamingRunner.new)
Source

Class methods

command_failure_message(target : String, summary : String, result : Result, cap : Int32 = MAX_OUTPUT_TAIL) : String
Source

Instance methods

command_args(host : String, command : Array(String), *, env : Hash(String, String) = {} of String => String, user : String | Nil = nil, port : Int32 | Nil = nil, identity_file : String | Nil = nil, proxy_jump : String | Nil = nil, connect_timeout : Int32 | Nil = nil, keepalive : Bool | Nil = nil, keepalive_interval : Int32 | Nil = nil, batch_mode : Bool | Nil = nil) : Array(String)
Source
command_args(host : String, remote_command : String, *, user : String | Nil = nil, port : Int32 | Nil = nil, identity_file : String | Nil = nil, proxy_jump : String | Nil = nil, connect_timeout : Int32 | Nil = nil, keepalive : Bool | Nil = nil, keepalive_interval : Int32 | Nil = nil, batch_mode : Bool | Nil = nil) : Array(String)
Source
run(host : String, command : Array(String), *, env : Hash(String, String) = {} of String => String, input : String | Nil = nil, user : String | Nil = nil, port : Int32 | Nil = nil, identity_file : String | Nil = nil, proxy_jump : String | Nil = nil, connect_timeout : Int32 | Nil = nil, keepalive : Bool | Nil = nil, keepalive_interval : Int32 | Nil = nil, batch_mode : Bool | Nil = nil) : Result
Source
run!(host : String, command : Array(String), *, env : Hash(String, String) = {} of String => String, input : String | Nil = nil, user : String | Nil = nil, port : Int32 | Nil = nil, identity_file : String | Nil = nil, proxy_jump : String | Nil = nil, connect_timeout : Int32 | Nil = nil, keepalive : Bool | Nil = nil, keepalive_interval : Int32 | Nil = nil, batch_mode : Bool | Nil = nil) : Result
Source
stream(host : String, command : Array(String), *, env : Hash(String, String) = {} of String => String, input : IO = STDIN, output : IO = STDOUT, error : IO = STDERR, user : String | Nil = nil, port : Int32 | Nil = nil, identity_file : String | Nil = nil, proxy_jump : String | Nil = nil, connect_timeout : Int32 | Nil = nil, keepalive : Bool | Nil = nil, keepalive_interval : Int32 | Nil = nil, batch_mode : Bool | Nil = nil) : Int32
Source
upload(host : String, remote_path : String, content : String, *, user : String | Nil = nil, port : Int32 | Nil = nil, identity_file : String | Nil = nil, proxy_jump : String | Nil = nil, connect_timeout : Int32 | Nil = nil, keepalive : Bool | Nil = nil, keepalive_interval : Int32 | Nil = nil, batch_mode : Bool | Nil = nil) : Nil
Source

Nested types