Method Init

internal/stats/dau_manager.go:56–144

()

}

func (this *DAUManager) Init() error {
	// recover from cache
	_ = this.recover()

	// create table
	store, storeErr := kvstore.DefaultStore()
	if storeErr != nil {
		return storeErr
	}

	db, dbErr := store.NewDB("dau")
	if dbErr != nil {
		return dbErr
	}

	{
		table, err := kvstore.NewTable[[]byte]("ip", kvstore.NewNilValueEncoder())
		if err != nil {
			return err
		}
		db.AddTable(table)
		this.ipTable = table
	}

	{
		table, err := kvstore.NewTable[uint64]("stats", kvstore.NewIntValueEncoder[uint64]())
		if err != nil {
			return err
		}
		db.AddTable(table)
	}

	// clean expires items
	goman.New(func() {
		idles.RunTicker(this.cleanTicker, func() {
			err := this.CleanStats()
			if err != nil {
				remotelogs.Error("DAU_MANAGER", "clean stats failed: "+err.Error())
			}
		})
	})

	// dump ip to kvstore
	goman.New(func() {
		// cache latest IPs to reduce kv queries
		var cachedIPs []IPInfo
		var maxIPs = runtime.NumCPU() * 8
		if maxIPs <= 0 {
			maxIPs = 8
		} else if maxIPs > 64 {
			maxIPs = 64
		}

		var day = fasttime.Now().Ymd()

	Loop:
		for ipInfo := range this.ipChan {
			// check day