dataflow

Documentation

Index

• Constants
• type SnapshotItem
• type States
  • func NewStates(window int) *States
  • func (s *States) AddChange(id uint64, state byte)
  • func (s *States) ChangesSince(startTick int, w io.Writer)

Constants

const (
	BlockBodyCleared byte = iota
	BlockBodyExpired
	BlockBodyRequested
	BlockBodyReceived
	BlockBodyEvicted
	BlockBodySkipped // Delivery requested but was skipped due to limitation on the size of the response
	BlockBodyEmpty   // Identified as empty and no need to be requested
	BlockBodyPrefetched
	BlockBodyInDb
)

const (
	HeaderInvalidated byte = iota
	HeaderRequested
	HeaderSkeletonRequested
	HeaderRetryNotReady
	HeaderEmpty
	HeaderBad
	HeaderEvicted
	HeaderInserted
)

Types

type SnapshotItem

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

type States

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

var BlockBodyDownloadStates *States = NewStates(64 * 1024)

var HeaderDownloadStates *States = NewStates(64 * 1024)

func NewStates

func NewStates(window int) *States

func (*States) AddChange

func (s *States) AddChange(id uint64, state byte)

func (*States) ChangesSince

func (s *States) ChangesSince(startTick int, w io.Writer)