datareader

Documentation

Index

• Variables
• func NewReader(cfg dataextractor.Config) smachine.SubroutineStateMachine
• type SMLineReader
  • func (p *SMLineReader) GetInitStateFor(smachine.StateMachine) smachine.InitFunc
  • func (p *SMLineReader) GetStateMachineDeclaration() smachine.StateMachineDeclaration
  • func (p *SMLineReader) GetSubroutineInitState(smachine.SubroutineStartContext) smachine.InitFunc
  • func (p *SMLineReader) InjectDependencies(_ smachine.StateMachine, _ smachine.SlotLink, ...)
• type SMReadBatcher

Variables

var ErrNextEntryNotFound = throw.E("Next entry not found, possible corruption of reverse index")

var ErrPrevRefNotFound = throw.E("PrevRef not found")

var ErrStartRefNotFound = throw.E("StartRef not found")

Functions

func NewReader

func NewReader(cfg dataextractor.Config) smachine.SubroutineStateMachine

Types

type SMLineReader

type SMLineReader struct {
	smachine.StateMachineDeclTemplate
	// contains filtered or unexported fields
}

func (*SMLineReader) GetInitStateFor

func (p *SMLineReader) GetInitStateFor(smachine.StateMachine) smachine.InitFunc

func (*SMLineReader) GetStateMachineDeclaration

func (p *SMLineReader) GetStateMachineDeclaration() smachine.StateMachineDeclaration

func (*SMLineReader) GetSubroutineInitState

func (p *SMLineReader) GetSubroutineInitState(smachine.SubroutineStartContext) smachine.InitFunc

func (*SMLineReader) InjectDependencies

func (p *SMLineReader) InjectDependencies(_ smachine.StateMachine, _ smachine.SlotLink, injector injector.DependencyInjector)

type SMReadBatcher

type SMReadBatcher struct {
}