execout

package

v1.18.1 Latest Latest Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/streamingfast/substreams

Links

Documentation ¶

Index ¶

func CmdDownloadSegment(wait time.Duration) loop.Cmd
func CmdWaitFirstTier2MapSegmentStreamed(wait time.Duration) loop.Cmd
func CmdWalkerCompleted() loop.Cmd
type MessageBuffer
- func NewMessageBuffer(maxBufferedMessage int, logger *zap.Logger) *MessageBuffer
type MsgDownloadSegment
type MsgFileDownloaded
type MsgFileNotPresent
type MsgFileReadTransientError
type MsgWaitFirstTier2MapSegmentStreamed
type MsgWalkerCompleted
type Walker
- func NewWalker(ctx context.Context, module *pbsubstreams.Module, ...) *Walker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CmdDownloadSegment ¶

func CmdDownloadSegment(wait time.Duration) loop.Cmd

func CmdWaitFirstTier2MapSegmentStreamed ¶ added in v1.15.9

func CmdWaitFirstTier2MapSegmentStreamed(wait time.Duration) loop.Cmd

func CmdWalkerCompleted ¶

func CmdWalkerCompleted() loop.Cmd

Types ¶

type MessageBuffer ¶ added in v1.18.0

type MessageBuffer struct {
	DataSize int
	// contains filtered or unexported fields
}

func NewMessageBuffer ¶ added in v1.18.0

func NewMessageBuffer(maxBufferedMessage int, logger *zap.Logger) *MessageBuffer

func (*MessageBuffer) Append ¶ added in v1.18.0

func (b *MessageBuffer) Append(msg *pbsubstreamsrpcv2.BlockScopedData, dataSize int)

func (*MessageBuffer) Flush ¶ added in v1.18.0

func (b *MessageBuffer) Flush(streamSrv *response.Stream) error

func (*MessageBuffer) Len ¶ added in v1.18.0

func (b *MessageBuffer) Len() int

func (*MessageBuffer) ShouldFlush ¶ added in v1.18.0

func (b *MessageBuffer) ShouldFlush() bool

type MsgDownloadSegment ¶

type MsgDownloadSegment struct {
	loop.IsMsg
	Wait time.Duration
}

type MsgFileDownloaded ¶

type MsgFileDownloaded struct{ loop.IsMsg }

type MsgFileNotPresent ¶

type MsgFileNotPresent struct {
	loop.IsMsg
	NextWait time.Duration

} // In which case, simply re-issue the CmdDownloadFile

type MsgFileReadTransientError ¶ added in v1.17.11

type MsgFileReadTransientError struct {
	loop.IsMsg
	Error    error
	NextWait time.Duration

} // In which case, simply re-issue the CmdDownloadFile

type MsgWaitFirstTier2MapSegmentStreamed ¶ added in v1.15.9

type MsgWaitFirstTier2MapSegmentStreamed struct {
	loop.IsMsg
}

type MsgWalkerCompleted ¶

type MsgWalkerCompleted struct{ loop.IsMsg }

type Walker ¶

type Walker struct {
	*block.Range
	// contains filtered or unexported fields
}

func NewWalker ¶

func NewWalker(
	ctx context.Context,
	module *pbsubstreams.Module,
	fileWalker *execout.FileWalker,
	walkRange *block.Range,
	stream *response.Stream,
	noopMode bool,
	bufferSize int,
	supportBuffering bool,
) *Walker

func (*Walker) CmdDownloadCurrentSegment ¶

func (r *Walker) CmdDownloadCurrentSegment(waitBefore time.Duration) loop.Cmd

func (*Walker) IsCompleted ¶

func (r *Walker) IsCompleted() bool

func (*Walker) IsNoopMode ¶ added in v1.14.6

func (r *Walker) IsNoopMode() bool

func (*Walker) IsWorking ¶

func (r *Walker) IsWorking() bool

func (*Walker) MarkNotWorking ¶

func (r *Walker) MarkNotWorking()

func (*Walker) MarkWorking ¶

func (r *Walker) MarkWorking()

func (*Walker) NextSegment ¶

func (r *Walker) NextSegment()

func (*Walker) Progress ¶ added in v1.3.2

func (r *Walker) Progress() (first, current, last int)

func (*Walker) WorkingDuration ¶ added in v1.17.11

func (r *Walker) WorkingDuration() time.Duration

WorkingDuration returns how long the walker has been in working state. Returns 0 if not currently working.

Source Files ¶

View all Source files

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