activities

Sep 14, 2023

Changes in this version

+ const PopulateMetadataActivityName

type BundleActivityParams

+ ExcludeHiddenFiles bool

+ Unbag bool

+ type PopulateMetadataActivity struct

+ func NewPopulateMetadataActivity(pipelineRegistry *pipeline.Registry) *PopulateMetadataActivity

+ func (a *PopulateMetadataActivity) Execute(ctx context.Context, params *PopulateMetadataActivityParams) error

+ type PopulateMetadataActivityParams struct

+ Identifier string

+ Path string

type TransferActivityParams

+ Accession string

+ TransferType string

Feb 1, 2022

Changes in this version

+ const DisposeOriginalActivityName

type BundleActivityParams

+ IsDir bool

+ WatcherName string

+ type DisposeOriginalActivity struct

+ func NewDisposeOriginalActivity(m *manager.Manager) *DisposeOriginalActivity

+ func (a *DisposeOriginalActivity) Execute(ctx context.Context, watcherName, key string) error

Aug 6, 2020

Changes in this version

type BundleActivity

+ func (a *BundleActivity) Copy(ctx context.Context, transferDir, batchDir, key string, stripTopLevelDir bool) (string, string, error)

type BundleActivityParams

+ BatchDir string

Jun 9, 2020

Changes in this version

+ const ValidateTransferActivityName

+ type ValidateTransferActivity struct

+ func NewValidateTransferActivity() *ValidateTransferActivity

+ func (a *ValidateTransferActivity) Execute(ctx context.Context, params *ValidateTransferActivityParams) error

+ type ValidateTransferActivityParams struct

+ Config validation.Config

+ Path string

Jan 9, 2020

Changes in this version

+ const AcquirePipelineActivityName

+ type AcquirePipelineActivity struct

+ func NewAcquirePipelineActivity(m *manager.Manager) *AcquirePipelineActivity

+ func (a *AcquirePipelineActivity) Execute(ctx context.Context, name string) error

Dec 16, 2019

Changes in this version

+ const BundleActivityName

+ const CleanUpActivityName

+ const DeleteOriginalActivityName

+ const DownloadActivityName

+ const HidePackageActivityName

+ const PollIngestActivityName

+ const PollTransferActivityName

+ const TransferActivityName

+ const UpdateHARIActivityName

+ const UpdateProductionSystemActivityName

+ type BundleActivity struct

+ func NewBundleActivity() *BundleActivity

+ func (a *BundleActivity) Bundle(ctx context.Context, unar archiver.Unarchiver, ...) (string, string, error)

+ func (a *BundleActivity) Execute(ctx context.Context, params *BundleActivityParams) (*BundleActivityResult, error)

+ func (a *BundleActivity) SingleFile(ctx context.Context, transferDir, key, tempFile string) (string, error)

+ func (a *BundleActivity) Unarchiver(key, filename string) archiver.Unarchiver

+ type BundleActivityParams struct

+ Key string

+ StripTopLevelDir bool

+ TempFile string

+ TransferDir string

+ type BundleActivityResult struct

+ FullPath string

+ FullPathBeforeStrip string

+ RelPath string

+ type CleanUpActivity struct

+ func NewCleanUpActivity(m *manager.Manager) *CleanUpActivity

+ func (a *CleanUpActivity) Execute(ctx context.Context, params *CleanUpActivityParams) error

+ type CleanUpActivityParams struct

+ FullPath string

+ type DeleteOriginalActivity struct

+ func NewDeleteOriginalActivity(m *manager.Manager) *DeleteOriginalActivity

+ func (a *DeleteOriginalActivity) Execute(ctx context.Context, event *watcher.BlobEvent) error

+ type DownloadActivity struct

+ func NewDownloadActivity(m *manager.Manager) *DownloadActivity

+ func (a *DownloadActivity) Execute(ctx context.Context, event *watcher.BlobEvent) (string, error)

+ type HidePackageActivity struct

+ func NewHidePackageActivity(m *manager.Manager) *HidePackageActivity

+ func (a *HidePackageActivity) Execute(ctx context.Context, unitID, unitType, pipelineName string) error

+ type PollIngestActivity struct

+ func NewPollIngestActivity(m *manager.Manager) *PollIngestActivity

+ func (a *PollIngestActivity) Execute(ctx context.Context, params *PollIngestActivityParams) (time.Time, error)

+ type PollIngestActivityParams struct

+ PipelineName string

+ SIPID string

+ type PollTransferActivity struct

+ func NewPollTransferActivity(m *manager.Manager) *PollTransferActivity

+ func (a *PollTransferActivity) Execute(ctx context.Context, params *PollTransferActivityParams) (string, error)

+ type PollTransferActivityParams struct

+ PipelineName string

+ TransferID string

+ type TransferActivity struct

+ func NewTransferActivity(m *manager.Manager) *TransferActivity

+ func (a *TransferActivity) Execute(ctx context.Context, params *TransferActivityParams) (*TransferActivityResponse, error)

+ type TransferActivityParams struct

+ AutoApprove bool

+ Name string

+ PipelineName string

+ ProcessingConfig string

+ RelPath string

+ TransferLocationID string

+ type TransferActivityResponse struct

+ PipelineID string

+ PipelineVersion string

+ TransferID string

+ type UpdateHARIActivity struct

+ func NewUpdateHARIActivity(m *manager.Manager) *UpdateHARIActivity

+ func (a UpdateHARIActivity) Execute(ctx context.Context, params *UpdateHARIActivityParams) error

+ type UpdateHARIActivityParams struct

+ FullPath string

+ Name string

+ PipelineName string

+ SIPID string

+ StoredAt time.Time

+ type UpdateProductionSystemActivity struct

+ func NewUpdateProductionSystemActivity(m *manager.Manager) *UpdateProductionSystemActivity

+ func (a *UpdateProductionSystemActivity) Execute(ctx context.Context, params *UpdateProductionSystemActivityParams) error

+ type UpdateProductionSystemActivityParams struct

+ Name string

+ OriginalID string

+ PipelineName string

+ Status collection.Status

+ StoredAt time.Time