zaz600 / go-musthave-shortener Goto Github PK

batch := repo.NewBatch(100) // создаешь новый объект, который использует два метода Add и Flush
defer batch.Flush() /// (в любом случае ты попробуешь сделать запись)
for _, e := range linkEntitites {
     batch.Add(e)
}

func (b *Batch) Add(ctx context.Context, e LinkEntity) error {
      b.entitites = append(b.entitites,e)
      if cap(b.entitites == len(b.entittes)) {
               b.Flush(ctx)
       }
}

// и еще метод flush, который у тебя уже есть