consensus

Documentation

Index

• Constants
• Variables
• type Engine
  • func NewEngine(chain *blockchain.Blockchain, gossipHandler *protocol.IdenaGossipHandler, ...) *Engine
  • func (engine *Engine) GetProcess() string
  • func (engine *Engine) ReadonlyAppState() (*appstate.AppState, error)
  • func (engine *Engine) Start()
  • func (engine *Engine) Synced() bool
• type ForkDetector
• type ForkResolver
  • func NewForkResolver(forkDetectors []ForkDetector, downloader *protocol.Downloader, ...) *ForkResolver
  • func (resolver *ForkResolver) ApplyFork() error
  • func (resolver *ForkResolver) HasLoadedFork() bool
  • func (resolver *ForkResolver) Start()
• type ForwardPeersProvider

Constants

const (
	MaxStoredAvgTimeDiffs = 20
)

Variables

var (
	ForkDetected = errors.New("fork is detected")
)

Types

type Engine

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

func NewEngine

func NewEngine(chain *blockchain.Blockchain, gossipHandler *protocol.IdenaGossipHandler, proposals *pengings.Proposals, config *config.ConsensusConf,
	appState *appstate.AppState,
	votes *pengings.Votes,
	txpool *mempool.TxPool, secStore *secstore.SecStore, downloader *protocol.Downloader,
	offlineDetector *blockchain.OfflineDetector,
	statsCollector collector.StatsCollector) *Engine

func (*Engine) GetProcess

func (engine *Engine) GetProcess() string

func (*Engine) ReadonlyAppState

func (engine *Engine) ReadonlyAppState() (*appstate.AppState, error)

func (*Engine) Start

func (engine *Engine) Start()

func (*Engine) Synced

func (engine *Engine) Synced() bool

type ForkDetector

type ForkDetector interface {
	HasPotentialFork() bool
	GetForkedPeers() mapset.Set
	ClearPotentialForks()
}

type ForkResolver

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

func NewForkResolver

func NewForkResolver(forkDetectors []ForkDetector, downloader *protocol.Downloader, chain *blockchain.Blockchain,
	statsCollector collector.StatsCollector) *ForkResolver

func (*ForkResolver) ApplyFork

func (resolver *ForkResolver) ApplyFork() error

func (*ForkResolver) HasLoadedFork

func (resolver *ForkResolver) HasLoadedFork() bool

func (*ForkResolver) Start

func (resolver *ForkResolver) Start()

type ForwardPeersProvider

type ForwardPeersProvider interface {
	PotentialForwardPeers(round uint64) []peer.ID
	PeerHeights() []uint64
}