consensus

Documentation

Overview

Package consensus implements different PalletOne consensus engines.

Index

• type AdapterJury
  • func (a *AdapterJury) AdapterFunRequest(reqId common.Hash, contractId common.Address, msgType uint32, ...) ([]byte, error)
  • func (a *AdapterJury) AdapterFunResult(reqId common.Hash, contractId common.Address, msgType uint32, ...) ([]byte, error)
  • func (a *AdapterJury) GetLocalJuryAddrs() []common.Address
• type ContractInf
• type DPOSEngine
  • func New(dag dag.IDag, txpool txspool.ITxPool) *DPOSEngine
  • func (engine *DPOSEngine) Engine() int
  • func (engine *DPOSEngine) SendEvents(content []byte)
  • func (engine *DPOSEngine) Stop()
  • func (engine *DPOSEngine) SubscribeCeEvent(ch chan<- core.ConsensusEvent) event.Subscription
• type Engine

Types

type AdapterJury

type AdapterJury struct {
	Processor *jury.Processor
}

func (*AdapterJury) AdapterFunRequest

func (a *AdapterJury) AdapterFunRequest(reqId common.Hash, contractId common.Address, msgType uint32,
	consultContent []byte, myAnswer []byte) ([]byte, error)

func (*AdapterJury) AdapterFunResult

func (a *AdapterJury) AdapterFunResult(reqId common.Hash, contractId common.Address, msgType uint32,
	consultContent []byte, timeOut time.Duration) ([]byte, error)

func (*AdapterJury) GetLocalJuryAddrs

func (a *AdapterJury) GetLocalJuryAddrs() []common.Address

type ContractInf

type ContractInf interface {
	SubscribeContractEvent(ch chan<- jury.ContractEvent) event.Subscription
	ProcessContractEvent(event *jury.ContractEvent) (broadcast bool, err error)
	ProcessElectionEvent(event *jury.ElectionEvent) (err error)
	ProcessAdapterEvent(event *jury.AdapterEvent) (result *jury.AdapterEvent, err error)

	//AdapterFunRequest(reqId common.Hash, contractId common.Address, timeOut time.Duration,
	// msgType uint32, msg string) (interface{}, error)
	AddContractLoop(rwM rwset.TxManager, txpool txspool.ITxPool, addr common.Address, ks *keystore.KeyStore) error
	CheckContractTxValid(rwM rwset.TxManager, tx *modules.Transaction, execute bool) bool
	IsSystemContractTx(tx *modules.Transaction) bool
}

type DPOSEngine

type DPOSEngine struct {
	// contains filtered or unexported fields
}

func New

func New(dag dag.IDag, txpool txspool.ITxPool) *DPOSEngine

func (*DPOSEngine) Engine

func (engine *DPOSEngine) Engine() int

func (*DPOSEngine) SendEvents

func (engine *DPOSEngine) SendEvents(content []byte)

func (*DPOSEngine) Stop

func (engine *DPOSEngine) Stop()

func (*DPOSEngine) SubscribeCeEvent

func (engine *DPOSEngine) SubscribeCeEvent(ch chan<- core.ConsensusEvent) event.Subscription

type Engine

type Engine interface {
}

Engine is an algorithm agnostic consensus engine.