activities

Documentation

Overview

Package activities implements workflow activities specific to Norway Health Authority.

Index

• Variables
• func ParseNameLocalActivity(ctx context.Context, name string) (*nha.NameInfo, error)
• type TransferIdentifier
• type TransferIdentifierPair
• type TransferIdentifiers
• type UpdateHARIActivity
  • func NewUpdateHARIActivity(m *manager.Manager) *UpdateHARIActivity
  • func (a UpdateHARIActivity) Execute(ctx context.Context, params *UpdateHARIActivityParams) error
• type UpdateHARIActivityParams
• type UpdateProductionSystemActivity
  • func NewUpdateProductionSystemActivity(m *manager.Manager) *UpdateProductionSystemActivity
  • func (a *UpdateProductionSystemActivity) Execute(ctx context.Context, params *UpdateProductionSystemActivityParams) error
• type UpdateProductionSystemActivityParams

Variables

var (
	UpdateHARIActivityName             = "update-hari-activity"
	UpdateProductionSystemActivityName = "update-production-system-activity"
)

Functions

func ParseNameLocalActivity

func ParseNameLocalActivity(ctx context.Context, name string) (*nha.NameInfo, error)

Types

type TransferIdentifier

type TransferIdentifier struct {
	File        string                   `json:"file"`
	Identifiers []TransferIdentifierPair `json:"identifiers"`
}

type TransferIdentifierPair

type TransferIdentifierPair struct {
	// avleveringsidentifikator is the one we want
	Type  string `json:"identifierType"`
	Value string `json:"identifier"`
}

type TransferIdentifiers

type TransferIdentifiers []TransferIdentifier

TransferIdentifiers is the type that maps to the JSON-encoded document found in Archivematica transfers to list identifiers.

type UpdateHARIActivity

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

UpdateHARIActivity delivers a receipt to HARI.

func NewUpdateHARIActivity

func NewUpdateHARIActivity(m *manager.Manager) *UpdateHARIActivity

func (UpdateHARIActivity) Execute

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

type UpdateHARIActivityParams

type UpdateHARIActivityParams struct {
	SIPID        string
	StoredAt     time.Time
	FullPath     string
	PipelineName string
	NameInfo     nha.NameInfo
}

type UpdateProductionSystemActivity

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

UpdateProductionSystemActivity sends a receipt to the production system using their filesystem interface using GoAnywhere.

func NewUpdateProductionSystemActivity

func NewUpdateProductionSystemActivity(m *manager.Manager) *UpdateProductionSystemActivity

func (*UpdateProductionSystemActivity) Execute

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

type UpdateProductionSystemActivityParams

type UpdateProductionSystemActivityParams struct {
	StoredAt     time.Time
	PipelineName string
	NameInfo     nha.NameInfo
	FullPath     string
}