| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Transient.Move.Services.Executor
Synopsis
- executorService :: [([Char], [Char])]
- initExecute :: Int -> Cloud [Node]
- networkExecute :: String -> String -> Cloud String
- networkExecuteStream' :: String -> Cloud String
- networkExecuteStream :: String -> Cloud String
- rnodecmd :: IORef (Map k a)
- sendExecuteStream :: String -> String -> Cloud ()
- controlNodeProcess :: String -> Cloud b
- newtype GetLogCmd = GetLogCmd String
- newtype ExecuteStream = ExecuteStream String
- data ReceiveExecuteStream = ReceiveExecuteStream String ByteString
- data GetProcesses = GetProcesses
- getProcesses :: Node -> Cloud [String]
- nodeForProcess :: String -> Cloud Node
Documentation
executorService :: [([Char], [Char])] Source #
networkExecute :: String -> String -> Cloud String Source #
execute a command in some node by an executor service, and return the result when the program finishes
networkExecuteStream' :: String -> Cloud String Source #
execute a process in some machine trough the local monitor and the executor.
This call return a process identifier
The process can be controlled with other services like controlNodeProcess
networkExecuteStream :: String -> Cloud String Source #
execute a shell command in some node using the executor service. The response is received as an stream of responses, one per line
sendExecuteStream :: String -> String -> Cloud () Source #
send a message that will be read by the standard input of the program initiated by networkExecuteStream, identified by the command line.
the stream of responses is returned by that primitive. sendExecuteStream never return anything, since it is asynchronous
controlNodeProcess :: String -> Cloud b Source #
newtype ExecuteStream Source #
Constructors
| ExecuteStream String |
Instances
| Read ExecuteStream Source # | |
Defined in Transient.Move.Services.Executor Methods readsPrec :: Int -> ReadS ExecuteStream # readList :: ReadS [ExecuteStream] # | |
| Show ExecuteStream Source # | |
Defined in Transient.Move.Services.Executor Methods showsPrec :: Int -> ExecuteStream -> ShowS # show :: ExecuteStream -> String # showList :: [ExecuteStream] -> ShowS # | |
| Loggable ExecuteStream Source # | |
Defined in Transient.Move.Services.Executor Methods serialize :: ExecuteStream -> Builder # deserializePure :: ByteString -> Maybe (ExecuteStream, ByteString) # | |
data ReceiveExecuteStream Source #
Constructors
| ReceiveExecuteStream String ByteString |
Instances
| Read ReceiveExecuteStream Source # | |
Defined in Transient.Move.Services.Executor Methods readsPrec :: Int -> ReadS ReceiveExecuteStream # readList :: ReadS [ReceiveExecuteStream] # | |
| Show ReceiveExecuteStream Source # | |
Defined in Transient.Move.Services.Executor Methods showsPrec :: Int -> ReceiveExecuteStream -> ShowS # show :: ReceiveExecuteStream -> String # showList :: [ReceiveExecuteStream] -> ShowS # | |
| Loggable ReceiveExecuteStream Source # | |
Defined in Transient.Move.Services.Executor Methods serialize :: ReceiveExecuteStream -> Builder # deserializePure :: ByteString -> Maybe (ReceiveExecuteStream, ByteString) # | |
data GetProcesses Source #
Constructors
| GetProcesses |
Instances
| Read GetProcesses Source # | |
Defined in Transient.Move.Services.Executor Methods readsPrec :: Int -> ReadS GetProcesses # readList :: ReadS [GetProcesses] # | |
| Show GetProcesses Source # | |
Defined in Transient.Move.Services.Executor Methods showsPrec :: Int -> GetProcesses -> ShowS # show :: GetProcesses -> String # showList :: [GetProcesses] -> ShowS # | |
| Loggable GetProcesses Source # | |
Defined in Transient.Move.Services.Executor Methods serialize :: GetProcesses -> Builder # deserializePure :: ByteString -> Maybe (GetProcesses, ByteString) # | |