foreach 添加error返回

zhangzengfei

2021-12-01 0d1558fa7cabaf35f7da9adf0f5a5804c9404f2a

foreach 添加error返回

 api.go

@@ -52,8 +52,8 @@
}

// 遍历数据, 输出原始数据
func (ls *LogStore) ForEach(f func(v *LogCon) error) {
    ls.store.ForEach(f)
func (ls *LogStore) ForEach(f func(v *LogCon) error) error {
    return ls.store.ForEach(f)
}

func (ls *LogStore) Size() int {

 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 {