Method Write

binarylog/binarylog_end2end_test.go:72–77

(e *binlogpb.GrpcLogEntry)

}

func (s *testBinLogSink) Write(e *binlogpb.GrpcLogEntry) error {
	s.mu.Lock()
	s.buf = append(s.buf, e)
	s.mu.Unlock()
	return nil
}

func (s *testBinLogSink) Close() error { return nil }