(consensusType string, account *account.Account, txpool *actor.PID, ledger *actor.PID, p2p *actor.PID)
| 43 | ) |
| 44 | |
| 45 | func NewConsensusService(consensusType string, account *account.Account, txpool *actor.PID, ledger *actor.PID, p2p *actor.PID) (ConsensusService, error) { |
| 46 | if consensusType == "" { |
| 47 | consensusType = CONSENSUS_DBFT |
| 48 | } |
| 49 | var consensus ConsensusService |
| 50 | var err error |
| 51 | switch consensusType { |
| 52 | case CONSENSUS_DBFT: |
| 53 | consensus, err = dbft.NewDbftService(account, txpool, p2p) |
| 54 | case CONSENSUS_SOLO: |
| 55 | consensus, err = solo.NewSoloService(account, txpool) |
| 56 | case CONSENSUS_VBFT: |
| 57 | consensus, err = vbft.NewVbftServer(account, txpool, p2p) |
| 58 | } |
| 59 | log.Infof("ConsensusType:%s", consensusType) |
| 60 | return consensus, err |
| 61 | } |
no test coverage detected