executer

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

• type AssociationExecuter
  • func NewAssociationExecuter(assocSvc service.T, agentInfo *contracts.AgentInfo) *AssociationExecuter
  • func (r *AssociationExecuter) ExecuteInProgressDocument(context context.T, docState *stateModel.DocumentState, ...)
  • func (r *AssociationExecuter) ExecutePendingDocument(context context.T, pool taskpool.T, docState *stateModel.DocumentState) error
• type DocumentExecuter
• type DocumentExecuterMock
  • func (m *DocumentExecuterMock) ExecuteInProgressDocument(context context.T, interimDocState *stateModel.DocumentState, ...)
  • func (m *DocumentExecuterMock) ExecutePendingDocument(context context.T, pool taskpool.T, interimDocState *stateModel.DocumentState) error

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 *stateModel.DocumentState, cancelFlag task.CancelFlag)

ExecuteInProgressDocument parses and processes the document

func (*AssociationExecuter) ExecutePendingDocument

func (r *AssociationExecuter) ExecutePendingDocument(context context.T, pool taskpool.T, docState *stateModel.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 *stateModel.DocumentState) error
	ExecuteInProgressDocument(context context.T, docState *stateModel.DocumentState, cancelFlag task.CancelFlag)
}

DocumentExecuter represents the interface for running a document

type DocumentExecuterMock

type DocumentExecuterMock struct {
	mock.Mock
}

DocumentExecuterMock stands for a mocked document executer.

func (*DocumentExecuterMock) ExecuteInProgressDocument

func (m *DocumentExecuterMock) ExecuteInProgressDocument(context context.T, interimDocState *stateModel.DocumentState, cancelFlag task.CancelFlag)

ExecuteInProgressDocument mocks implementation for ExecuteInProgressDocument

func (*DocumentExecuterMock) ExecutePendingDocument

func (m *DocumentExecuterMock) ExecutePendingDocument(context context.T, pool taskpool.T, interimDocState *stateModel.DocumentState) error

ExecutePendingDocument mocks implementation for ExecuteInProgressDocument