validation

Documentation

Index

• Constants
• type Manager
  • func NewManager(nodeMgr *node.Manager, assetMgr *assets.Manager, ...) *Manager
  • func (m *Manager) CompulsoryElection(validators []string) error
  • func (m *Manager) GetNextElectionTime() time.Time
  • func (m *Manager) PairValidatorsAndValidatableNodes() []*VWindow
  • func (m *Manager) PushResult(vr *api.ValidationResult)
  • func (m *Manager) ResetValidatorGroup(validators, validatables []string)
  • func (m *Manager) Start(ctx context.Context)
  • func (m *Manager) StartElection()
  • func (m *Manager) Stop(ctx context.Context) error
• type VWindow
• type ValidatableGroup

Constants

const (
	FILECOIN_EPOCH_DURATION   = 30
	GAME_CHAIN_EPOCH_LOOKBACK = 10
)

Types

type Manager

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

Manager validation manager

func NewManager

func NewManager(nodeMgr *node.Manager, assetMgr *assets.Manager, configFunc dtypes.GetSchedulerConfigFunc, p *pubsub.PubSub, lmgr *leadership.Manager) *Manager

NewManager return new node manager instance

func (*Manager) CompulsoryElection

func (m *Manager) CompulsoryElection(validators []string) error

func (*Manager) GetNextElectionTime

func (m *Manager) GetNextElectionTime() time.Time

GetNextElectionTime Get the time of the next election

func (*Manager) PairValidatorsAndValidatableNodes

func (m *Manager) PairValidatorsAndValidatableNodes() []*VWindow

PairValidatorsAndValidatableNodes randomly pair validators and validatable nodes based on their bandwidth capabilities.

func (*Manager) PushResult

func (m *Manager) PushResult(vr *api.ValidationResult)

PushResult push validation result info to queue

func (*Manager) ResetValidatorGroup

func (m *Manager) ResetValidatorGroup(validators, validatables []string)

ResetValidatorGroup clears and initializes the validator and validatable groups

func (*Manager) Start

func (m *Manager) Start(ctx context.Context)

Start start validate and elect task

func (*Manager) StartElection

func (m *Manager) StartElection()

StartElection triggers an election manually.

func (*Manager) Stop

func (m *Manager) Stop(ctx context.Context) error

Stop stop

type VWindow

type VWindow struct {
	NodeID           string // Node ID of the validation window.
	ValidatableNodes map[string]int64
}

VWindow represents a validation window that contains a validator id and validatable node list.

type ValidatableGroup

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

ValidatableGroup Each ValidatableGroup will be paired with a VWindow