xpoa

package

v1.0.2 Latest Latest Go to latest Published: Jan 27, 2022 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/superconsensus/matrixcore

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CalFault(input, sum int64) bool
func Find(a string, t []string) bool
func NewXpoaConsensus(cCtx cctx.ConsensusCtx, cCfg def.ConsensusConfig) consensus.ConsensusImplInterface
func NewXpoaSchedule(xconfig *xpoaConfig, cCtx context.ConsensusCtx, startHeight, version int64) *xpoaSchedule
func ParseVersion(cfg string) (int64, error)
type ProposerInfo
type ValidatorsInfo
type XpoaStatus

Constants ¶

View Source

const (
	MAXSLEEPTIME = 1000
	MAXMAPSIZE   = 1000
)

Variables ¶

View Source

var (
	MinerSelectErr   = errors.New("Node isn't a miner, calculate error.")
	EmptyValidors    = errors.New("Current validators is empty.")
	NotValidContract = errors.New("Cannot get valid res with contract.")
	InvalidQC        = errors.New("QC struct is invalid.")
)

Functions ¶

func CalFault ¶

func CalFault(input, sum int64) bool

func Find ¶

func Find(a string, t []string) bool

func NewXpoaConsensus ¶

func NewXpoaConsensus(cCtx cctx.ConsensusCtx, cCfg def.ConsensusConfig) consensus.ConsensusImplInterface

NewXpoaConsensus 初始化实例

func NewXpoaSchedule ¶

func NewXpoaSchedule(xconfig *xpoaConfig, cCtx context.ConsensusCtx, startHeight, version int64) *xpoaSchedule

func ParseVersion ¶ added in v1.0.2

func ParseVersion(cfg string) (int64, error)

ParseVersion 支持string格式和int格式的version type

Types ¶

type ProposerInfo ¶

type ProposerInfo struct {
	Address []string `json:"address"`
}

type ValidatorsInfo ¶

type ValidatorsInfo struct {
	Validators []string `json:"validators"`
	Miner      string   `json:"miner"`
}

type XpoaStatus ¶

type XpoaStatus struct {
	Name        string
	Version     int64 `json:"version"`
	StartHeight int64 `json:"startHeight"`
	Index       int   `json:"index"`
	// contains filtered or unexported fields
}

xpoaStatus 实现了ConsensusStatus接口

func (*XpoaStatus) GetConsensusBeginInfo ¶

func (x *XpoaStatus) GetConsensusBeginInfo() int64

共识起始高度

func (*XpoaStatus) GetConsensusName ¶

func (x *XpoaStatus) GetConsensusName() string

获取共识类型

func (*XpoaStatus) GetCurrentTerm ¶

func (x *XpoaStatus) GetCurrentTerm() int64

获取当前状态机term

func (*XpoaStatus) GetCurrentValidatorsInfo ¶

func (x *XpoaStatus) GetCurrentValidatorsInfo() []byte

获取当前矿工信息

func (*XpoaStatus) GetStepConsensusIndex ¶

func (x *XpoaStatus) GetStepConsensusIndex() int

获取共识item所在consensus slice中的index

func (*XpoaStatus) GetVersion ¶

func (x *XpoaStatus) GetVersion() int64

获取共识版本号

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL