ranged

Documentation

Index

• func NewHBTxPool(cap int) *hBTxPool
• type BTX
• type OutH
• type RangeRequester
  • func NewRangeRequester(btx BTX, workers int) *RangeRequester
  • func (rr *RangeRequester) GetRange(ctx context.Context, hr structs.HeightRange) (h structs.Heights, err error)

Functions

func NewHBTxPool

func NewHBTxPool(cap int) *hBTxPool

Types

type BTX

type BTX interface {
	BlockAndTx(ctx context.Context, height uint64) (blockWM structs.BlockWithMeta, txsWM []structs.TransactionWithMeta, err error)
}

type OutH

type OutH struct {
	Height uint64
	Block  structs.BlockWithMeta
	Error  error
}

type RangeRequester

type RangeRequester struct {
	BTX BTX
	// contains filtered or unexported fields
}

func NewRangeRequester

func NewRangeRequester(btx BTX, workers int) *RangeRequester

func (*RangeRequester) GetRange

func (rr *RangeRequester) GetRange(ctx context.Context, hr structs.HeightRange) (h structs.Heights, err error)

getRange gets given range of blocks and transactions