add foreach, size api

zhangzengfei

2021-11-12 33cc2473a3d6ca941717c557f8e72b9904fbdc4f

 store_test.go

@@ -16,13 +16,21 @@

   defer ls.Close()

   go consume(ls)

   for i:=0; i<10000; i++{
   //go consume(ls)
   //
   for i := 0; i < 100; i++ {
      ls.ApplyLog([]byte("hello world "+strconv.Itoa(i)))
      time.Sleep(time.Second * 1)
      time.Sleep(time.Millisecond * 100)
   }

   ls.printLog("Size = ", ls.Size())

   ls.ForEach(func(v []byte) error {
      ls.printLog("val=:", string(v))
      return nil
   })

   consume(ls)
}

func consume(ls *LogStore) {
@@ -31,8 +39,10 @@
      if lc != nil {
         ls.printLog(lc.conf.BucketName," send old log:", string(lc.Log.Data))
         ls.Delete(lc)
      } else {
         return
      }

      time.Sleep(10 * time.Second)
      time.Sleep(10 * time.Millisecond)
   }
}