(p []byte)
| 271 | } |
| 272 | |
| 273 | func (w *managerWriter) Write(p []byte) (n int, err error) { |
| 274 | content := StripAnsi(string(p)) |
| 275 | ts := time.Since(w.manager.start).Truncate(time.Millisecond) |
| 276 | fmt.Printf("[+%s][%s:%s] %s", ts, w.node, w.source, content) |
| 277 | w.manager.Accept(w.node, w.source, content) |
| 278 | return len(p), nil |
| 279 | } |
| 280 | |
| 281 | func GetUnexportedField(field reflect.Value) interface{} { |
| 282 | return reflect.NewAt(field.Type(), unsafe.Pointer(field.UnsafeAddr())).Elem().Interface() |