(l testcontainers.Log)
| 172 | } |
| 173 | |
| 174 | func (c *UnifiedLogConsumer) Accept(l testcontainers.Log) { |
| 175 | source := SourceStdout |
| 176 | if l.LogType == "stderr" { |
| 177 | source = SourceStderr |
| 178 | } |
| 179 | content := StripAnsi(string(l.Content)) |
| 180 | ts := time.Since(c.Manager.start).Truncate(time.Millisecond) |
| 181 | fmt.Printf("[+%s][%s:%s] %s", ts, c.Node, source, content) |
| 182 | c.Manager.Accept(c.Node, source, content) |
| 183 | } |