ead

Aug 31, 2022

Changes in this version

+ func Process(s *Service, parentCtx context.Context, t *Task) error

type Meta

+ func (m *Meta) GetSourcePath() string

+ type ProcessFn func(s *Service, parentCtx context.Context, t *Task) error

type Service

+ ProcessFn ProcessFn

+ func (s *Service) Publish(ctx context.Context, messages ...*domainpb.IndexMessage) error

+ func (s *Service) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (s *Service) SetServiceBuilder(b *domain.ServiceBuilder)

Jan 25, 2022

Changes in this version

type Meta

+ ProcessDigitalIfMissing bool

type Option

+ func SetProcessDigitalIfMissing(isEnabled bool) Option

+ type PreStoreFn func(b []byte) []byte

type Service

+ PreStoreFn PreStoreFn

Mar 10, 2021

Changes in this version

+ const PaccessKey

+ const StateCanceled

+ const StateDeleted

+ type DaoFn func(cfg *eadHub3.DaoConfig) error

+ type EADHarvester struct

+ OrgID string

+ func NewEADHarvester(s *Service) (EADHarvester, error)

+ func (e *EADHarvester) ProcessEadFromOai(r *oai.Response)

type Meta

+ ProcessAccessTime time.Time

+ ProcessDigital bool

+ Revision int32

+ TotalRecordsPublished uint64

type Metrics

+ func (m *Metrics) IncAlreadyQueued()

+ func (m *Metrics) IncCancelled()

+ func (m *Metrics) IncFailed()

+ func (m *Metrics) IncFinished()

+ func (m *Metrics) IncStarted()

+ func (m *Metrics) IncSubmitted()

+ type MetsHarvester struct

+ OrgID string

+ func NewMetsHarvest(c *ead.DaoClient) (MetsHarvester, error)

+ func (m *MetsHarvester) ProcessMetsFromOai(r *oai.Response)

type Option

+ func SetProcessDigital(isEnabled bool) Option

+ func SetRevisionService(rs *revision.Service) Option

type Service

+ DaoClient *eadHub3.DaoClient

+ DaoFn DaoFn

+ M Metrics

+ func (s *Service) AddPostHook(hook domain.PostHookService) error

+ func (s *Service) ClearRestrictions(w http.ResponseWriter, r *http.Request)

+ func (s *Service) CreateTask(r *http.Request, meta Meta) (*taskResponse, error)

+ func (s *Service) DeleteEAD(datasetID, orgID string) error

+ func (s *Service) LoadEAD(orgID, spec string) (Meta, error)

+ func (s *Service) LoadModifiedEADDate(spec string) time.Time

+ func (s *Service) ResyncCacheDir(orgID string) error

+ func (s *Service) Routes(router chi.Router)

+ func (s *Service) SaveModifiedEADDate(spec string, modified string) error

Jul 20, 2020

Changes in this version

+ const StateStarted

type Metrics

+ AlreadyQueued uint64

+ Submitted uint64

type Option

+ func SetWorkers(workers int) Option

Jun 15, 2020

Changes in this version

type Meta

+ Tags []string

Jun 5, 2020

Changes in this version

+ const StateCancelled

+ const StateFinished

+ const StateInError

+ const StatePending

+ const StateProcessingDescription

+ const StateProcessingInventories

+ const StateProcessingMetsFiles

+ const StateSubmitted

+ var ErrTaskAlreadySubmitted = errors.New("task already submitted")

+ var ErrTaskNotFound = errors.New("task not found")

+ type CreateTreeFn func(cfg *eadHub3.NodeConfig, n *eadHub3.Node, hubID string, id string) *fragments.Tree

+ type Meta struct

+ Clevels uint64

+ Created bool

+ DaoErrorLinks []string

+ DaoErrors uint64

+ DaoLinks uint64

+ DatasetID string

+ DigitalObjects uint64

+ FileSize uint64

+ OrgID string

+ ProcessingDuration time.Duration

+ ProcessingDurationFmt string

+ RecordsPublished uint64

+ Title string

+ type Metrics struct

+ Canceled uint64

+ Failed uint64

+ Finished uint64

+ Started uint64

+ type Option func(*Service) error

+ func SetCreateTree(fn CreateTreeFn) Option

+ func SetDataDir(path string) Option

+ func SetIndexService(is *index.Service) Option

+ type ProcessingState string

+ type Service struct

+ CreateTreeFn CreateTreeFn

+ func NewService(options ...Option) (*Service, error)

+ func (s *Service) CancelTask(w http.ResponseWriter, r *http.Request)

+ func (s *Service) GetName(buf *bytes.Buffer) (string, error)

+ func (s *Service) GetTask(w http.ResponseWriter, r *http.Request)

+ func (s *Service) Metrics() Metrics

+ func (s *Service) NewTask(meta *Meta) (*Task, error)

+ func (s *Service) Process(parentCtx context.Context, t *Task) error

+ func (s *Service) SaveEAD(r io.Reader, size int64) (*bytes.Buffer, Meta, error)

+ func (s *Service) Shutdown(ctx context.Context) error

+ func (s *Service) StartWorkers() error

+ func (s *Service) Tasks(w http.ResponseWriter, r *http.Request)

+ func (s *Service) Upload(w http.ResponseWriter, r *http.Request)

+ type Task struct

+ ErrorMsg string

+ ID string

+ InState ProcessingState

+ Interrupted bool

+ Meta *Meta

+ Transitions []*Transition

+ func (t *Task) Next()

+ type Transition struct

+ Duration time.Duration

+ DurationFmt string

+ Finished time.Time

+ Metrics map[string]uint64

+ Started time.Time

+ State ProcessingState