Function NewSmartPool

protocol/smartpool.go:245–268

(
	pm smartpool.PoolMonitor, sr smartpool.ShareReceiver,
	nc smartpool.NetworkClient, cr ClaimRepo, co smartpool.Contract,
	ca common.Address, ma common.Address, ed string,
	interval time.Duration, threshold int, hotStop bool)

}

func NewSmartPool(
	pm smartpool.PoolMonitor, sr smartpool.ShareReceiver,
	nc smartpool.NetworkClient, cr ClaimRepo, co smartpool.Contract,
	ca common.Address, ma common.Address, ed string,
	interval time.Duration, threshold int, hotStop bool) *SmartPool {
	return &SmartPool{
		PoolMonitor:     pm,
		ShareReceiver:   sr,
		NetworkClient:   nc,
		ClaimRepo:       cr,
		Contract:        co,
		ContractAddress: ca,
		MinerAddress:    ma,
		ExtraData:       ed,
		SubmitInterval:  interval,
		ShareThreshold:  threshold,
		HotStop:         hotStop,
		loopStarted:     false,
		// TODO: should be persist between startups instead of having 0 hardcoded
		LatestCounter: big.NewInt(0),
		counterMu:     sync.RWMutex{},
		runMu:         sync.Mutex{},
	}
}