pipeline

Documentation

Index

• Variables
• func IngestStatus(ctx context.Context, client *amclient.Client, ID string) error
• func TransferStatus(ctx context.Context, client *amclient.Client, ID string) (string, error)
• type Config
• type Pipeline
  • func NewPipeline(config Config) (*Pipeline, error)
  • func (p *Pipeline) Acquire(ctx context.Context) error
  • func (p Pipeline) Client() *amclient.Client
  • func (p Pipeline) Config() *Config
  • func (p *Pipeline) Release()
  • func (p Pipeline) SSAccess() (*url.URL, string, error)
  • func (p Pipeline) TempFile(pattern string) (*os.File, error)
• type Registry
  • func NewPipelineRegistry(logger logr.Logger, configs []Config) (*Registry, error)
  • func (r *Registry) ByID(id string) (*Pipeline, error)
  • func (r *Registry) ByName(name string) (*Pipeline, error)

Variables

var (
	ErrStatusNonRetryable = errors.New("non retryable error")
	ErrStatusRetryable    = errors.New("retryable error")
	ErrStatusInProgress   = errors.New("waitable error")
)

var ErrUnknownPipeline = errors.New("unknown pipeline")

Functions

func IngestStatus

func IngestStatus(ctx context.Context, client *amclient.Client, ID string) error

IngestStatus returns a non-nil error when the SIP is not fully ingested.

func TransferStatus

func TransferStatus(ctx context.Context, client *amclient.Client, ID string) (string, error)

TransferStatus returns a non-nil error when the transfer is not fully transferred.

Types

type Config

type Config struct {
	ID                 string
	Name               string
	BaseURL            string
	User               string
	Key                string
	TransferDir        string
	TransferLocationID string
	ProcessingDir      string
	ProcessingConfig   string
	StorageServiceURL  string
	Capacity           uint64
}

type Pipeline

type Pipeline struct {
	// ID (UUID) of the pipeline. This is not provided by the user but loaded
	// on demand once we have access to the pipeline API.
	ID string
	// contains filtered or unexported fields
}

func NewPipeline

func NewPipeline(config Config) (*Pipeline, error)

func (*Pipeline) Acquire

func (p *Pipeline) Acquire(ctx context.Context) error

func (Pipeline) Client

func (p Pipeline) Client() *amclient.Client

Client returns the Archivematica API client ready for use.

func (Pipeline) Config

func (p Pipeline) Config() *Config

func (*Pipeline) Release

func (p *Pipeline) Release()

func (Pipeline) SSAccess

func (p Pipeline) SSAccess() (*url.URL, string, error)

SSAccess returns the URL and user:key pair needed to access Storage Service.

func (Pipeline) TempFile

func (p Pipeline) TempFile(pattern string) (*os.File, error)

TempFile creates a temporary file in the processing directory.

type Registry

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

Registry is a collection of known pipelines.

func NewPipelineRegistry

func NewPipelineRegistry(logger logr.Logger, configs []Config) (*Registry, error)

func (*Registry) ByID

func (r *Registry) ByID(id string) (*Pipeline, error)

func (*Registry) ByName

func (r *Registry) ByName(name string) (*Pipeline, error)