package boltcache

import (
	"strconv"
	"testing"
	"time"
)

func TestInit(t *testing.T) {
	conf := NewDefaultConfig()
	ls, err := Init(conf)
	if err != nil {
		ls.printLog("Init err:", err)
		return
	}

	defer ls.Close()

	go consume(ls)

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

}

func consume(ls *LogStore) {
	for {
		lc := ls.Get()
		if lc != nil {
			ls.printLog(lc.conf.BucketName," send old log:", string(lc.Log.Data))
			ls.Delete(lc)
		}

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