diff --git a/writer/writer.go b/writer/writer.go index 9d24e9f..6e7062b 100644 --- a/writer/writer.go +++ b/writer/writer.go @@ -16,39 +16,6 @@ type ErrorLevel interface { Level() int } -// type DbWriter struct { -// Db database.DB -// In chan InsertBatch -// wg *sync.WaitGroup -// } - -// func NewDbWriter(db database.DB, in chan InsertBatch) *DbWriter { -// dw := DbWriter{ -// Db: db, -// In: in, -// wg: &sync.WaitGroup{}, -// } -// for i := 0; i < runtime.NumCPU(); i++ { -// dw.wg.Add(1) -// go dw.loop() -// } -// return &dw -// } - -// func (dw *DbWriter) Close() { -// dw.wg.Wait() -// } - -// func (dw *DbWriter) loop() { -// for batch := range dw.In { -// err := dw.Db.InsertBatch(batch.Table, batch.Rows) -// if err != nil { -// log.Println(err) -// } -// } -// dw.wg.Done() -// } - type looper interface { loop() }