firehose

README

StreamingFast Firehose

A firehose-style stream of streamingfast Blocks app wrapper as part of StreamingFast.

Contributing

Issues and PR in this repo related strictly to the core firehose service.

Report any protocol-specific issues in their respective repositories

Please first refer to the general StreamingFast contribution guide, if you wish to contribute to this code base.

License

Apache 2.0

Documentation

Index

• Variables
• 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)
• type StreamFactory
  • func NewStreamFactory(mergedBlocksStore dstore.Store, forkedBlocksStore dstore.Store, ...) *StreamFactory
  • func (sf *StreamFactory) New(ctx context.Context, handler bstream.Handler, request *pbfirehose.Request, ...) (*stream.Stream, error)

Variables

var StreamMergedBlocksPreprocThreads = 25

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)

type StreamFactory

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

func NewStreamFactory

func NewStreamFactory(
	mergedBlocksStore dstore.Store,
	forkedBlocksStore dstore.Store,
	hub *hub.ForkableHub,
	transformRegistry *transform.Registry,
) *StreamFactory

func (*StreamFactory) New

func (sf *StreamFactory) New(
	ctx context.Context,
	handler bstream.Handler,
	request *pbfirehose.Request,
	logger *zap.Logger) (*stream.Stream, error)