Write implements io.Writer (for stdout/stderr from container)
(p []byte)
| 110 | |
| 111 | // Write implements io.Writer (for stdout/stderr from container) |
| 112 | func (w *webSocketStream) Write(p []byte) (int, error) { |
| 113 | m := dto.NewExecOutput(string(p)) |
| 114 | output, err := m.Bytes() |
| 115 | if err != nil { |
| 116 | return 0, err |
| 117 | } |
| 118 | |
| 119 | err = w.conn.WriteMessage(websocket.TextMessage, output) |
| 120 | if err != nil { |
| 121 | w.writeErr <- err |
| 122 | } |
| 123 | return len(p), err |
| 124 | } |
no test coverage detected