Documentation ¶
Overview ¶
Package executer allows execute Pending association and InProgress association
Package executer allows execute Pending association and InProgress association ¶
Package executer allows execute Pending association and InProgress association
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AssociationExecuter ¶
type AssociationExecuter struct {
// contains filtered or unexported fields
}
AssociationExecuter represents the implementation of document executer
func NewAssociationExecuter ¶
func NewAssociationExecuter(assocSvc service.T, agentInfo *contracts.AgentInfo) *AssociationExecuter
NewAssociationExecuter returns a new document executer
func (*AssociationExecuter) ExecuteInProgressDocument ¶
func (r *AssociationExecuter) ExecuteInProgressDocument(context context.T, docState *docModel.DocumentState, cancelFlag task.CancelFlag)
ExecuteInProgressDocument parses and processes the document
func (*AssociationExecuter) ExecutePendingDocument ¶
func (r *AssociationExecuter) ExecutePendingDocument(context context.T, pool taskpool.T, docState *docModel.DocumentState) error
ExecutePendingDocument moves doc to current folder and submit it for execution
type DocumentExecuter ¶
type DocumentExecuter interface { ExecutePendingDocument(context context.T, pool taskpool.T, docState *docModel.DocumentState) error ExecuteInProgressDocument(context context.T, docState *docModel.DocumentState, cancelFlag task.CancelFlag) }
DocumentExecuter represents the interface for running a document
type DocumentExecuterMock ¶
DocumentExecuterMock stands for a mocked document executer.
func (*DocumentExecuterMock) ExecuteInProgressDocument ¶
func (m *DocumentExecuterMock) ExecuteInProgressDocument(context context.T, interimDocState *docModel.DocumentState, cancelFlag task.CancelFlag)
ExecuteInProgressDocument mocks implementation for ExecuteInProgressDocument
func (*DocumentExecuterMock) ExecutePendingDocument ¶
func (m *DocumentExecuterMock) ExecutePendingDocument(context context.T, pool taskpool.T, interimDocState *docModel.DocumentState) error
ExecutePendingDocument mocks implementation for ExecuteInProgressDocument