firehose

Documentation

Index

• type BlockGetter
  • func NewBlockGetter(mergedBlocksStore dstore.Store, forkedBlocksStore dstore.Store, ...) *BlockGetter
  • func (g *BlockGetter) Get(ctx context.Context, num uint64, id string, logger *zap.Logger) (out *pbbstream.Block, err error)

Types

type BlockGetter

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

func NewBlockGetter

func NewBlockGetter(
	mergedBlocksStore dstore.Store,
	forkedBlocksStore dstore.Store,
	hub *hub.ForkableHub,
) *BlockGetter

func (*BlockGetter) Get

func (g *BlockGetter) Get(
	ctx context.Context,
	num uint64,
	id string,
	logger *zap.Logger) (out *pbbstream.Block, err error)