 src/amp/logging/logging.go |
| ... | ... | @@ -295,6 +295,7 @@ func AddConsoleLogger() { |
| 295 | 295 | } |
| 296 | 296 | go console.log() |
| 297 | 297 | AddReceiver(console.receiver, MixedLog) |
| 298 | + ConsoleFilters = append(ConsoleFilters, defaultConsoleFilter) |
| 298 | 299 | } |
| 299 | 300 | |
| 300 | 301 | func AddReceiver(receiver chan *Record, logType int) { |
| ... | ... | @@ -310,6 +311,19 @@ func AddConsoleFilter(filter Filter) { |
| 310 | 311 | ConsoleFilters = append(ConsoleFilters, filter) |
| 311 | 312 | } |
| 312 | 313 | |
| 314 | +func defaultConsoleFilter(record *Record) (write bool, data []interface{}) { |
| 315 | + if len(record.Items) > 0 { |
| 316 | + meta := record.Items[0] |
| 317 | + switch meta.(type) { |
| 318 | + case string: |
| 319 | + if meta.(string) == "m" { |
| 320 | + return true, record.Items[1:] |
| 321 | + } |
| 322 | + } |
| 323 | + } |
| 324 | + return true, nil |
| 325 | +} |
| 326 | + |
| 313 | 327 | func Wait() { |
| 314 | 328 | if waitable { |
| 315 | 329 | checker <- 1 |
tav ·