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 PipelineRegistry
  • func NewPipelineRegistry(configs []Config) *PipelineRegistry
  • func (p PipelineRegistry) Client(name string) (*amclient.Client, error)
  • func (p PipelineRegistry) Config(name string) (*Config, error)
  • func (p PipelineRegistry) TempFile(name, key string) (*os.File, error)

Variables

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

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 {
	Name               string
	BaseURL            string
	User               string
	Key                string
	TransferDir        string
	TransferLocationID string
	ProcessingDir      string
}

type PipelineRegistry

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

PipelineRegistry is a collection of known pipelines.

func NewPipelineRegistry

func NewPipelineRegistry(configs []Config) *PipelineRegistry

func (PipelineRegistry) Client

func (p PipelineRegistry) Client(name string) (*amclient.Client, error)

func (PipelineRegistry) Config

func (p PipelineRegistry) Config(name string) (*Config, error)

func (PipelineRegistry) TempFile

func (p PipelineRegistry) TempFile(name, key string) (*os.File, error)