fastsync

type BlockData struct {
	RequestID uint32
	Data      []byte
}

type BlockMetadata struct {
	RequestID   uint32
	BlockLength int32 // -1 if fails
	Proof       []byte
}

type BlockProofProvider interface {
	GetBlockProof(h int64, opt int32) (proof []byte, err error)
}

type BlockRequest = BlockRequestV2

type BlockRequestV1 struct {
	RequestID uint32
	Height    int64
}

type BlockRequestV2 struct {
	RequestID   uint32
	Height      int64
	ProofOption int32
}

type BlockResult interface {
	Block() module.BlockData
	Votes() []byte
	Consume()
	Reject()
}

type CancelAllBlockRequests struct {
}

type FetchCallback interface {
	OnBlock(br BlockResult)
	OnEnd(err error)
}

type Manager interface {
	StartServer()
	StopServer()
	FetchBlocks(
		begin int64,
		end int64,
		cb FetchCallback,
	) (canceler func() bool, err error)
}

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

type ServerCallback interface {
	OnBeginServing(id module.PeerID)
	OnEndServing(id module.PeerID)
}