protocols

Documentation

Index

• Variables
• type BlockTimeChecker
• type BlockTimeCounter
  • func NewBlockTimeCounter() *BlockTimeCounter
  • func (btc *BlockTimeCounter) BlockForTimeExists(t time.Time, nodePosition int) (bool, error)
  • func (btc *BlockTimeCounter) RangeByTime(t time.Time) (start, end time.Time, err error)
  • func (btc *BlockTimeCounter) TimeToGenerate(at time.Time, nodePosition int) (bool, error)

Variables

var (
	WrongNodePositionError = errors.New("wrong node position")
	TimeError              = errors.New("current time before first block")
	DuplicateBlockError    = errors.New("block for this time interval exists")
)

Types

type BlockTimeChecker

type BlockTimeChecker interface {
	TimeToGenerate(position int64) (bool, error)
	BlockForTimeExists(t time.Time, nodePosition int) (bool, error)
	RangeByTime(at time.Time) (start, end time.Time, err error)
}

BlockTimeChecker allow check queue to generate current block

type BlockTimeCounter

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

func NewBlockTimeCounter

func NewBlockTimeCounter() *BlockTimeCounter

NewBlockTimeCounter return initialized BlockTimeCounter

func (*BlockTimeCounter) BlockForTimeExists

func (btc *BlockTimeCounter) BlockForTimeExists(t time.Time, nodePosition int) (bool, error)

BlockForTimeExists checks conformity between time and nodePosition changes functionality of ValidateBlock prevent blockTimeCalculator

func (*BlockTimeCounter) RangeByTime

func (btc *BlockTimeCounter) RangeByTime(t time.Time) (start, end time.Time, err error)

RangeByTime returns start and end of interval by time

func (*BlockTimeCounter) TimeToGenerate

func (btc *BlockTimeCounter) TimeToGenerate(at time.Time, nodePosition int) (bool, error)

TimeToGenerate returns true if the generation queue at time belongs to the specified node