stream

package

v0.0.2-0...-d05d5d5 Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/streamingfast/bstream

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
type ErrInvalidArg
- func NewErrInvalidArg(m string, args ...interface{}) *ErrInvalidArg
- func (e *ErrInvalidArg) Error() string
type Option
type Stream
- func New(forkedBlocksStore dstore.Store, mergedBlocksStore dstore.Store, ...) *Stream
- func (s *Stream) Run(ctx context.Context) error

Constants ¶

View Source

const DefaultPreprocessFuncThreadNumber = 4

Variables ¶

View Source

var ErrStopBlockReached = errors.New("stop block reached")

Functions ¶

This section is empty.

Types ¶

type ErrInvalidArg ¶

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

func NewErrInvalidArg ¶

func NewErrInvalidArg(m string, args ...interface{}) *ErrInvalidArg

func (*ErrInvalidArg) Error ¶

func (e *ErrInvalidArg) Error() string

type Option ¶

type Option = func(s *Stream)

func WithBlockIndexProvider ¶

func WithBlockIndexProvider(p bstream.BlockIndexProvider) Option

func WithCursor ¶

func WithCursor(cursor *bstream.Cursor) Option

func WithCustomStepTypeFilter ¶

func WithCustomStepTypeFilter(step bstream.StepType) Option

func WithFinalBlocksOnly ¶

func WithFinalBlocksOnly() Option

func WithLogger ¶

func WithLogger(logger *zap.Logger) Option

func WithPreprocessFunc ¶

func WithPreprocessFunc(pp bstream.PreprocessFunc, threads int) Option

func WithPreprocessFuncDefaultThreadNumber ¶

func WithPreprocessFuncDefaultThreadNumber(pp bstream.PreprocessFunc) Option

func WithStopBlock ¶

func WithStopBlock(stopBlockNum uint64) Option

func WithTargetCursor ¶

func WithTargetCursor(cursor *bstream.Cursor) Option

type Stream ¶

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

func New ¶

func New(
	forkedBlocksStore dstore.Store,
	mergedBlocksStore dstore.Store,
	hub *hub.ForkableHub,
	startBlockNum int64,
	handler bstream.Handler,
	options ...Option) *Stream

func (*Stream) Run ¶

func (s *Stream) Run(ctx context.Context) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL