execout

package
v1.15.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 9, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

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 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)

Jump to

Keyboard shortcuts

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