foreach 添加error返回

zhangzengfei

2021-12-01 0d1558fa7cabaf35f7da9adf0f5a5804c9404f2a

 bolt_store.go

@@ -242,10 +242,10 @@
   return tx.Commit()
}

func (b *BoltStore) ForEach(f func(lc *LogCon) error) {
func (b *BoltStore) ForEach(f func(lc *LogCon) error) error {
   tx, err := b.conn.Begin(true)
   if err != nil {
      return
      return err
   }
   defer tx.Rollback()

@@ -256,13 +256,13 @@
      cLog := &confLog{}
      err := b.GetConfLog(start, cLog)
      if err != nil {
         return
         return err
      }

      bucketName := cLog.BucketName
      bucket := tx.Bucket([]byte(bucketName))
      if bucket == nil {
         return
         return err
      }

      bucket.ForEach(func(k, v []byte) error {
@@ -275,6 +275,8 @@
         return err
      })
   }

   return nil
}

func (b *BoltStore) Delete(lc *LogCon) error {