Write will be called to write the log entry into the sink. It should be thread-safe so it can be called in parallel.
(*binlogpb.GrpcLogEntry)
| 43 | // |
| 44 | // It should be thread-safe so it can be called in parallel. |
| 45 | Write(*binlogpb.GrpcLogEntry) error |
| 46 | // Close will be called when the Sink is replaced by a new Sink. |
| 47 | Close() error |
| 48 | } |
no outgoing calls