| 86 | func (ws *writerSink) Close() error { return nil } |
| 87 | |
| 88 | type bufferedSink struct { |
| 89 | mu sync.Mutex |
| 90 | closer io.Closer |
| 91 | out Sink // out is built on buf. |
| 92 | buf *bufio.Writer // buf is kept for flush. |
| 93 | flusherStarted bool |
| 94 | |
| 95 | writeTicker *time.Ticker |
| 96 | done chan struct{} |
| 97 | } |
| 98 | |
| 99 | func (fs *bufferedSink) Write(e *binlogpb.GrpcLogEntry) error { |
| 100 | fs.mu.Lock() |
nothing calls this directly
no outgoing calls
no test coverage detected