execout

package

v1.17.11 Latest Latest Go to latest Published: Jan 21, 2026 License: Apache-2.0 Imports: 18 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 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 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,
) *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