nonvalidator

Documentation

Index

• type Config
• type NonValidator
  • func NewNonValidator(config Config) (*NonValidator, error)
  • func (n *NonValidator) AdvanceTime(t time.Time)
  • func (n *NonValidator) HandleMessage(msg *common.Message, from common.NodeID) error
  • func (n *NonValidator) Start()
  • func (n *NonValidator) Stop()

Types

type Config

type Config struct {
	Storage                    common.Storage
	Comm                       common.Communication
	SignatureAggregatorCreator common.SignatureAggregatorCreator

	Logger common.Logger

	// How many sequences we allow to look past our next sequence to commit
	MaxSequenceWindow uint64

	// our node ID
	ID common.NodeID

	StartTime time.Time

	// RandomSource is used by the replication state to pick which nodes to
	// request sequences from. If nil, a cryptographically secure source is used.
	RandomSource *rand.Rand

	// TransitionToValidator is called when our non-validator indexes the highest known epoch
	// and it is in the validator set
	TransitionToValidator func(epoch uint64, validators common.Nodes)
}

type NonValidator

type NonValidator struct {
	Config
	// contains filtered or unexported fields
}

func NewNonValidator

func NewNonValidator(config Config) (*NonValidator, error)

NewNonValidator creates a NonValidator with the given `config`.

func (*NonValidator) AdvanceTime

func (n *NonValidator) AdvanceTime(t time.Time)

func (*NonValidator) HandleMessage

func (n *NonValidator) HandleMessage(msg *common.Message, from common.NodeID) error

func (*NonValidator) Start

func (n *NonValidator) Start()

func (*NonValidator) Stop

func (n *NonValidator) Stop()