types

type DataPack interface {
	PeerId() string
	Items() int
	Stats() string
}

type FetchRequest struct {
	Peer     PeerConnection       // Peer to which the request was sent
	From     uint64               // [eth/62] Requested chain element index (used for skeleton fills only)
	Sheaders []*types.SnailHeader // [eth/62] Requested headers, sorted by request order
	Fheaders []*types.Header      // [eth/62] Requested headers, sorted by request order
	Time     time.Time            // Time when the request was made

}

type FetchResult struct {
	Pending int         // Number of data fetches still pending
	Hash    common.Hash // Hash of the header to prevent recalculating

	Signs   []*types.PbftSign
	Sheader *types.SnailHeader
	Fruits  types.SnailBlocks

	Fheader      *types.Header
	Infos        types.CommitteeMembers
	Transactions types.Transactions
	Receipts     types.Receipts
}

type LightPeer interface {
	Head() (common.Hash, *big.Int)
	RequestHeadersByHash(common.Hash, int, int, bool, bool) error
	RequestHeadersByNumber(uint64, int, int, bool, bool) error
	RequestBodies([]common.Hash, bool, uint32) error
}

type Peer interface {
	LightPeer

	RequestReceipts([]common.Hash, bool) error
	RequestNodeData([]common.Hash, bool) error
}

type PeerConnection interface {
	BlockCapacity(targetRTT time.Duration) int
	FetchHeaders(from uint64, count int) error
	FetchBodies(request *FetchRequest) error
	FetchNodeData(hashes []common.Hash) error
	FetchReceipts(request *FetchRequest) error
	HeaderCapacity(targetRTT time.Duration) int
	Lacks(hash common.Hash) bool
	MarkLacking(hash common.Hash)
	NodeDataCapacity(targetRTT time.Duration) int
	ReceiptCapacity(targetRTT time.Duration) int
	Reset()

	SetBlocksIdle(delivered int)
	SetBodiesIdle(delivered int)
	SetHeadersIdle(delivered int)
	SetNodeDataIdle(delivered int)
	SetReceiptsIdle(delivered int)

	GetID() string

	GetHeaderIdle() int32
	GetBlockIdle() int32
	GetReceiptIdle() int32
	GetStateIdle() int32

	GetHeaderThroughput() float64
	GetBlockThroughput() float64
	GetReceiptThroughput() float64
	GetStateThroughput() float64

	SetHeaderThroughput(t float64)
	SetBlockThroughput(t float64)
	SetReceiptThroughput(t float64)
	SetStateThroughput(t float64)

	GetRtt() time.Duration // Request round trip time to track responsiveness (QoS)
	SetRtt(d time.Duration)

	GetHeaderStarted() time.Time
	GetBlockStarted() time.Time
	GetReceiptStarted() time.Time
	GetStateStarted() time.Time

	GetLock() *sync.RWMutex
	GetVersion() int // Eth protocol version number to switch strategies
	GetPeer() Peer
	SetPeer(Peer)
	GetLog() log.Logger
}

type PeerDropFn func(id string, call uint32)

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

type StateSyncInter interface {
	Wait() error
	Cancel() error
	Done() <-chan struct{}
	Err() error
}