Lines Matching defs:monitor
1 package monitor package
26 type monitor struct { struct
27 sink log.SinkAdapter
30 logger log.InterceptLogger
33 logCh chan []byte
36 doneCh chan struct{}
40 droppedCount *atomic.Uint32
41 bufSize int
46 dropCheckInterval time.Duration
51 started *atomic.Bool
83 func (d *monitor) Stop() {
91 func (d *monitor) Start() <-chan []byte {
148 func (d *monitor) Write(p []byte) (n int, err error) {