dpos

Documentation

Index

• Constants
• type ActiveTrx
• type BlockReceivedVotes
• type DPoS
  • func NewDPoS(cfgFile string) *DPoS
  • func (dps *DPoS) CleanSyncCache()
  • func (dps *DPoS) Init()
  • func (dps *DPoS) ProcessMsg(bs *consensus.BlockSource)
  • func (dps *DPoS) RPC(kind uint, in, out interface{})
  • func (dps *DPoS) Start()
  • func (dps *DPoS) Stop()
• type Election
• type EvictedFunc
• type PerfType
  • func (pt PerfType) String() string
• type Processor
• type RepAckStatistics
• type RepOnlinePeriod
  • func (op *RepOnlinePeriod) String() string
• type Votes

Constants

const ConfirmChainParallelNum = 10

Types

type ActiveTrx

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

type BlockReceivedVotes

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

type DPoS

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

func NewDPoS

func NewDPoS(cfgFile string) *DPoS

func (*DPoS) CleanSyncCache

func (dps *DPoS) CleanSyncCache()

func (*DPoS) Init

func (dps *DPoS) Init()

func (*DPoS) ProcessMsg

func (dps *DPoS) ProcessMsg(bs *consensus.BlockSource)

func (*DPoS) RPC

func (dps *DPoS) RPC(kind uint, in, out interface{})

func (*DPoS) Start

func (dps *DPoS) Start()

func (*DPoS) Stop

func (dps *DPoS) Stop()

type Election

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

type EvictedFunc

type EvictedFunc func(interface{}, interface{})

type PerfType

type PerfType int32

func (PerfType) String

func (pt PerfType) String() string

type Processor

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

type RepAckStatistics

type RepAckStatistics struct {
	HeartCount      uint64 `json:"heartCount"`
	LastHeartHeight uint64 `json:"-"`
	VoteCount       uint64 `json:"voteCount"`
}

type RepOnlinePeriod

type RepOnlinePeriod struct {
	Period     uint64                              `json:"period"`
	Statistic  *sync.Map                           `json:"-"`
	Stat       map[types.Address]*RepAckStatistics `json:"statistics"`
	BlockCount uint64                              `json:"blockCount"`
}

func (*RepOnlinePeriod) String

func (op *RepOnlinePeriod) String() string

type Votes

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