backlog

Documentation

Index

• Constants
• type Environment
• type InputBacklog
  • func New(env Environment) (*InputBacklog, error)
  • func (b *InputBacklog) ArrivedOutputsSince(t time.Time) bool
  • func (b *InputBacklog) CandidatesToEndorseShuffled(targetTs ledger.Time) []*vertex.WrappedTx
  • func (b *InputBacklog) CandidatesToEndorseSorted(targetTs ledger.Time) []*vertex.WrappedTx
  • func (b *InputBacklog) FilterAndSortOutputs(filter func(wOut vertex.WrappedOutput) bool) []vertex.WrappedOutput
  • func (b *InputBacklog) GetOwnLatestMilestoneTx() *vertex.WrappedTx
  • func (b *InputBacklog) LoadSequencerStartTips(seqID ledger.ChainID) error
  • func (b *InputBacklog) NumOutputsInBuffer() int
• type Stats

Constants

const TraceTag = "backlog"

Types

type Environment

type Environment interface {
	global.NodeGlobal
	attacher.Environment
	ListenToAccount(account ledger.Accountable, fun func(wOut vertex.WrappedOutput))
	SequencerID() ledger.ChainID
	SequencerName() string
	GetLatestMilestone(seqID ledger.ChainID) *vertex.WrappedTx
	LatestMilestonesDescending(filter ...func(seqID ledger.ChainID, vid *vertex.WrappedTx) bool) []*vertex.WrappedTx
	LatestMilestonesShuffled(filter ...func(seqID ledger.ChainID, vid *vertex.WrappedTx) bool) []*vertex.WrappedTx
	NumSequencerTips() int
	BacklogTTLSlots() int
	MustEnsureBranch(txid ledger.TransactionID) *vertex.WrappedTx
	EvidenceBacklogSize(size int)
}

type InputBacklog

type InputBacklog struct {
	Environment
	// contains filtered or unexported fields
}

func New

func New(env Environment) (*InputBacklog, error)

func (*InputBacklog) ArrivedOutputsSince

func (b *InputBacklog) ArrivedOutputsSince(t time.Time) bool

func (*InputBacklog) CandidatesToEndorseShuffled

func (b *InputBacklog) CandidatesToEndorseShuffled(targetTs ledger.Time) []*vertex.WrappedTx

CandidatesToEndorseShuffled returns randomly ordered list of transactions which can be endorsed from the given timestamp

func (*InputBacklog) CandidatesToEndorseSorted

func (b *InputBacklog) CandidatesToEndorseSorted(targetTs ledger.Time) []*vertex.WrappedTx

CandidatesToEndorseSorted returns descending (by coverage) list of transactions which can be endorsed from the given timestamp

func (*InputBacklog) FilterAndSortOutputs

func (b *InputBacklog) FilterAndSortOutputs(filter func(wOut vertex.WrappedOutput) bool) []vertex.WrappedOutput

func (*InputBacklog) GetOwnLatestMilestoneTx

func (b *InputBacklog) GetOwnLatestMilestoneTx() *vertex.WrappedTx

func (*InputBacklog) LoadSequencerStartTips

func (b *InputBacklog) LoadSequencerStartTips(seqID ledger.ChainID) error

LoadSequencerStartTips loads tip transactions relevant to the sequencer startup from persistent state to the memDAG

func (*InputBacklog) NumOutputsInBuffer

func (b *InputBacklog) NumOutputsInBuffer() int

type Stats

type Stats struct {
	NumOtherSequencers       int
	NumOutputs               int
	OutputCount              int
	RemovedOutputsSinceReset int
}