outofproc

Documentation

Index

• type Backend
• type OutOfProcExecuter
  • func NewOutOfProcExecuter(ctx context.T) *OutOfProcExecuter
  • func (e *OutOfProcExecuter) Run(cancelFlag task.CancelFlag, docStore executer.DocumentStore) chan contracts.DocumentResult
  • func (e *OutOfProcExecuter) WaitForProcess(stopTimer chan bool, process proc.OSProcess)

Types

type Backend

type Backend messaging.MessagingBackend

type OutOfProcExecuter

type OutOfProcExecuter struct {
	basicexecuter.BasicExecuter
	// contains filtered or unexported fields
}

func NewOutOfProcExecuter

func NewOutOfProcExecuter(ctx context.T) *OutOfProcExecuter

func (*OutOfProcExecuter) Run

func (e *OutOfProcExecuter) Run(
	cancelFlag task.CancelFlag,
	docStore executer.DocumentStore) chan contracts.DocumentResult

Run() prepare the ipc channel, create a data processing backend and start messaging with docment worker

func (*OutOfProcExecuter) WaitForProcess

func (e *OutOfProcExecuter) WaitForProcess(stopTimer chan bool, process proc.OSProcess)