state

Documentation

Index

• type ExecOutputStorageState
  • func NewExecOutputStorageState(config *execout.Config, ...) (out *ExecOutputStorageState, err error)
  • func (m ExecOutputStorageState) BatchRequests(subRequestSplitSize uint64) block.Ranges
  • func (m ExecOutputStorageState) InitialProgressRanges() block.Ranges
  • func (m ExecOutputStorageState) Name() string
  • func (m ExecOutputStorageState) ReadyUpToBlock() uint64
• type SnapshotsMap
  • func FetchMappersState(ctx context.Context, configs *execout.Configs, outputModule string) (*SnapshotsMap, error)
  • func (s *SnapshotsMap) String() string

Types

type ExecOutputStorageState

type ExecOutputStorageState struct {
	ModuleName         string
	ModuleInitialBlock uint64

	SegmentsPresent block.Ranges
	SegmentsMissing block.Ranges
}

func NewExecOutputStorageState

func NewExecOutputStorageState(config *execout.Config, saveInterval, requestStartBlock, linearHandoffBlock uint64, snapshots block.Ranges) (out *ExecOutputStorageState, err error)

func (ExecOutputStorageState) BatchRequests

func (m ExecOutputStorageState) BatchRequests(subRequestSplitSize uint64) block.Ranges

func (ExecOutputStorageState) InitialProgressRanges

func (m ExecOutputStorageState) InitialProgressRanges() block.Ranges

func (ExecOutputStorageState) Name

func (m ExecOutputStorageState) Name() string

func (ExecOutputStorageState) ReadyUpToBlock

func (m ExecOutputStorageState) ReadyUpToBlock() uint64

type SnapshotsMap

type SnapshotsMap struct {
	sync.Mutex
	Snapshots map[string]block.Ranges
}

func FetchMappersState

func FetchMappersState(ctx context.Context, configs *execout.Configs, outputModule string) (*SnapshotsMap, error)

func (*SnapshotsMap) String

func (s *SnapshotsMap) String() string