(handle string, spec garden.ProcessSpec, processIO garden.ProcessIO)
| 162 | } |
| 163 | |
| 164 | func (c *connection) Run(handle string, spec garden.ProcessSpec, processIO garden.ProcessIO) (garden.Process, error) { |
| 165 | reqBody := new(bytes.Buffer) |
| 166 | |
| 167 | err := transport.WriteMessage(reqBody, spec) |
| 168 | if err != nil { |
| 169 | return nil, err |
| 170 | } |
| 171 | |
| 172 | hijackedConn, hijackedResponseReader, err := c.hijacker.Hijack( |
| 173 | routes.Run, |
| 174 | reqBody, |
| 175 | rata.Params{ |
| 176 | "handle": handle, |
| 177 | }, |
| 178 | nil, |
| 179 | "application/json", |
| 180 | ) |
| 181 | if err != nil { |
| 182 | return nil, err |
| 183 | } |
| 184 | |
| 185 | return c.streamProcess(handle, processIO, hijackedConn, hijackedResponseReader) |
| 186 | } |
| 187 | |
| 188 | func (c *connection) Attach(handle string, processID string, processIO garden.ProcessIO) (garden.Process, error) { |
| 189 | reqBody := new(bytes.Buffer) |
nothing calls this directly
no test coverage detected