rundocument

type ExecDocument ¶

type ExecDocument interface {
	ParseDocument(context context.T, documentRaw []byte, orchestrationDir string,
		s3Bucket string, s3KeyPrefix string, messageID string, documentID string, defaultWorkingDirectory string,
		params map[string]interface{}) (pluginsInfo []contracts.PluginState, err error)
	ExecuteDocument(config contracts.Configuration, context context.T, pluginInput []contracts.PluginState, documentID string,
		documentCreatedDate string) (chan contracts.DocumentResult, error)
}

type ExecDocumentImpl ¶

type ExecDocumentImpl struct {
	DocExecutor executer.Executer
}

func (exec ExecDocumentImpl) ExecuteDocument(config contracts.Configuration, context context.T, pluginInput []contracts.PluginState, documentID string,
	documentCreatedDate string) (resultChannels chan contracts.DocumentResult, err error)

func (exec ExecDocumentImpl) ParseDocument(context context.T, documentRaw []byte, orchestrationDir string,
	s3Bucket string, s3KeyPrefix string, messageID string, documentID string, defaultWorkingDirectory string,
	params map[string]interface{}) (pluginsInfo []contracts.PluginState, err error)

type ExecutePluginDepth ¶

type ExecutePluginDepth struct {
	// contains filtered or unexported fields
}

ExecutePluginDepth is the struct that is sent through to the sub-documents to maintain the depth of execution

type NoOpDocumentMgr ¶

type NoOpDocumentMgr struct {
	// contains filtered or unexported fields
}

Workaround to keep this plugin from overwriting the DocumentState of the top-level document.

Up until version 3.0.732.0, this plugin always failed to write the DocumentState to file due to a path calculation bug. In 3.0.732.0, the path calculation bug was fixed, and the plugin started overwriting the top-level document's DocumentState, which sometimes interfered with plugins in the top-level document that executed after this one. NoOpDocumentMgr is meant to keep this plugin from overwriting the state of the top-level document. However, it does not persist the DocumentState over a reboot, and it does not track the status (e.g. "pending", "current", "corrupt") of the document. Longer-term, we may want to implement proper DocumentState bookkeeping for the documents executed by this plugin.

func NewNoOpDocumentMgr(ctx context.T) *NoOpDocumentMgr

func (m *NoOpDocumentMgr) GetDocumentState(fileName, locationFolder string) contracts.DocumentState

func (m *NoOpDocumentMgr) MoveDocumentState(fileName, srcLocationFolder, dstLocationFolder string)

func (m *NoOpDocumentMgr) PersistDocumentState(fileName, locationFolder string, state contracts.DocumentState)

func (m *NoOpDocumentMgr) RemoveDocumentState(fileName, locationFolder string)

type Plugin ¶

type Plugin struct {
	// contains filtered or unexported fields
}

Plugin is the type for the aws:copyContent plugin.

func NewPlugin(context context.T) (*Plugin, error)

func (p *Plugin) Execute(config contracts.Configuration, cancelFlag task.CancelFlag, output iohandler.IOHandler)

type RunDocumentPluginInput ¶

type RunDocumentPluginInput struct {
	contracts.PluginInput
	DocumentType       string      `json:"documentType"`
	DocumentPath       string      `json:"documentPath"`
	DocumentParameters interface{} `json:"documentParameters"`
}

RunDocumentPluginInput is a struct that holds the parameters sent through send command