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 *bstream.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

StreamMergedBlocksPreprocThreads defines the number of threads that the filesource is allowed to use PER FILE. Used for decoding bstream blocks to protobuf and applying other transforms

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 *bstream.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,
	decodeBlock bool,
	logger *zap.Logger) (*stream.Stream, error)