Documentation
¶
Overview ¶
Package workflow contains a Temporal workflow for ingesting and preserving SIPs using Archivematica or A3M.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProcessingWorkflow ¶
type ProcessingWorkflow struct {
// contains filtered or unexported fields
}
func NewProcessingWorkflow ¶
func NewProcessingWorkflow( cfg config.Configuration, rng io.Reader, ingestsvc ingest.Service, wsvc watcher.Service, ) *ProcessingWorkflow
func (*ProcessingWorkflow) Execute ¶
func (w *ProcessingWorkflow) Execute(ctx temporalsdk_workflow.Context, req *ingest.ProcessingWorkflowRequest) error
ProcessingWorkflow orchestrates all the activities related to the processing of a SIP in Archivematica, including is retrieval, creation of transfer, etc...
Retrying this workflow would result in a new Archivematica transfer. We do not have a retry policy in place. The user could trigger a new instance via the API.
func (*ProcessingWorkflow) SessionHandler ¶
func (w *ProcessingWorkflow) SessionHandler( sessCtx temporalsdk_workflow.Context, attempt int, state *workflowState, ) error
SessionHandler runs activities that belong to the same session.
type Timer ¶
func (*Timer) WithTimeout ¶
func (t *Timer) WithTimeout( ctx temporalsdk_workflow.Context, d time.Duration, ) (temporalsdk_workflow.Context, temporalsdk_workflow.CancelFunc)
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package activities implements Enduro's workflow activities.
|
Package activities implements Enduro's workflow activities. |
Click to show internal directories.
Click to hide internal directories.