execout

Documentation

Index

• func CmdDownloadSegment(wait time.Duration) loop.Cmd
• func CmdWalkerCompleted() loop.Cmd
• type MsgDownloadSegment
• type MsgFileDownloaded
• type MsgFileNotPresent
• type MsgWalkerCompleted
• type Walker
  • func NewWalker(ctx context.Context, module *pbsubstreams.Module, ...) *Walker
  • func (r *Walker) CmdDownloadCurrentSegment(waitBefore time.Duration) loop.Cmd
  • func (r *Walker) IsCompleted() bool
  • func (r *Walker) IsWorking() bool
  • func (r *Walker) MarkNotWorking()
  • func (r *Walker) MarkWorking()
  • func (r *Walker) NextSegment()
  • func (r *Walker) Progress() (first, current, last int)

Functions

func CmdDownloadSegment

func CmdDownloadSegment(wait time.Duration) loop.Cmd

func CmdWalkerCompleted

func CmdWalkerCompleted() loop.Cmd

Types

type MsgDownloadSegment

type MsgDownloadSegment struct {
	Wait time.Duration
}

type MsgFileDownloaded

type MsgFileDownloaded struct{}

type MsgFileNotPresent

type MsgFileNotPresent struct {
	NextWait time.Duration

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

type MsgWalkerCompleted

type MsgWalkerCompleted struct{}

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,
) *Walker

func (*Walker) CmdDownloadCurrentSegment

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

func (*Walker) IsCompleted

func (r *Walker) IsCompleted() 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

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