Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Directories ¶
Path | Synopsis |
---|---|
Package process wraps up the os.Process interface and also provides os-specific process lookup functions
|
Package process wraps up the os.Process interface and also provides os-specific process lookup functions |
Package main implements a separate worker which is used to execute requests from session manager.
|
Package main implements a separate worker which is used to execute requests from session manager. |
Click to show internal directories.
Click to hide internal directories.