irdmtools

Sep 23, 2024

Changes in this version

+ const EAGAIN

+ const ENOENT

+ const ENOEXEC

+ const EXIT_OK

Jul 10, 2024

Changes in this version

type Config

+ EPrintBaseURL string

May 1, 2024

Changes in this version

+ func MigrateRdmDatasetToCitationDataset(rdmCName string, ids []string, repoHost string, prefix string, ...) error

+ func RunRdmDSToCitationDS(in io.Reader, out io.Writer, eout io.Writer, args []string, repoHost string, ...) int

type Doi2RdmOptions

+ ISSNJournals map[string]string

type RdmUtil

+ func (app *RdmUtil) CloseDB() error

+ func (app *RdmUtil) OpenDB() error

Apr 12, 2024

Changes in this version

type Config

+ func (cfg *Config) MakeDSN() string

type Doi2Rdm

+ func (app *Doi2Rdm) RunDoiToRdmCombined(in io.Reader, out io.Writer, eout io.Writer, optionFName, doi string, ...) error

Mar 25, 2024

Changes in this version

type CitationAgent

+ ArchivesSpaceID string

+ DirectoryID string

+ Lcnaf string

+ Snac string

+ Viaf string

+ Wikidata string

Mar 21, 2024

Changes in this version

type Citation

+ PrimaryObject map[string]interface{}

Mar 20, 2024

Changes in this version

type Citation

+ BookTitle string

+ Chapters string

+ Edition string

+ ISBN string

+ ISSN string

+ LocalGroup []*CitationAgent

+ PMCID string

+ PatentApplication string

+ PatentAssignee string

+ PatentNumber string

+ PlaceOfPublication string

+ ThesisDegree string

+ ThesisType string

+ ThesisYear string

+ func (cite *Citation) CrosswalkEPrint(cName string, cID string, citeUsingURL string, eprint *eprinttools.EPrint) error

type CitationAgent

+ CLgid string

Mar 15, 2024

Changes in this version

+ func CrosswalkDataCiteObject(cfg *Config, object map[string]interface{}, options *Doi2RdmOptions) (*simplified.Record, error)

+ func MigrateEPrintDatasetToCitationDataset(ep3CName string, ids []string, repoHost string, citeCName string) error

+ func QueryDataCiteObject(cfg *Config, doi string, options *Doi2RdmOptions) (map[string]interface{}, error)

+ func RunEPrintDSToCitationDS(in io.Reader, out io.Writer, eout io.Writer, args []string, repoHost string, ...) int

+ type Citation struct

+ Abstract string

+ AlternateId []*CitationIdentifier

+ AlternateTitle []string

+ Author []*CitationAgent

+ CiteUsingURL string

+ Collection string

+ CollectionID string

+ Contributor []*CitationAgent

+ DOI string

+ Date map[string]*CitationDate

+ Editor []*CitationAgent

+ ID string

+ Issue string

+ Pages string

+ Publication string

+ PublicationDate string

+ Publisher string

+ PublisherLocation string

+ ResourceType string

+ Reviewer []*CitationAgent

+ Series string

+ SeriesNumber string

+ ThesisAdvisor []*CitationAgent

+ ThesisCommittee []*CitationAgent

+ Title string

+ Translator []*CitationAgent

+ Type string

+ Volume string

+ func EPrintToCitation(repoName string, key string, eprint *eprinttools.EPrint, repoHost string, ...) (*Citation, error)

+ func RdmToCitation(record *simplified.Record) (*Citation, error)

+ func (cite *Citation) CrosswalkRecord(cName string, cID string, citeUsingURL string, rec *simplified.Record) error

+ type CitationAgent struct

+ CLpid string

+ DroppingParticle string

+ FamilyName string

+ ISNI string

+ Literal string

+ LivedName string

+ NonDroppingParticle string

+ ORCID string

+ Prefix string

+ Suffix string

+ func CrosswalkCreatorToCitationAgent(creator *simplified.Creator) (*CitationAgent, string, error)

+ func CrosswalkPersonOrOrgToCitationAgent(personOrOrg *simplified.PersonOrOrg) (*CitationAgent, error)

+ func (ca *CitationAgent) ToString() string

+ type CitationDate struct

+ DateParts [][]int

+ Raw string

+ type CitationIdentifier struct

+ Type string

+ Value string

type Doi2Rdm

+ func (app *Doi2Rdm) RunCrossRefToRdm(in io.Reader, out io.Writer, eout io.Writer, optionFName, doi string, ...) error

+ func (app *Doi2Rdm) RunDataCiteToRdm(in io.Reader, out io.Writer, eout io.Writer, optionFName, doi string, ...) error

Feb 22, 2024

Changes in this version

+ var DefaultDoi2RdmOptionsYAML = []byte(...)

+ func DoiPrefix(s string) (string, error)

+ func LinkToDoi(s string) (string, error)

+ type Doi2RdmOptions struct

+ ContributorTypes map[string]string

+ Debug bool

+ DoiPrefixPublishers map[string]string

+ DotInitials bool

+ Download bool

+ ISSNPublishers map[string]string

+ MailTo string

+ ResourceTypes map[string]string

Jan 4, 2024

Changes in this version

+ func GetRecordVersions(cfg *Config, id string) ([]*map[string]interface{}, error)

type RdmUtil

+ func (app *RdmUtil) GetRecordVersions(id string) ([]byte, error)

Dec 11, 2023

Changes in this version

+ func GetRecordStaleIds(cfg *Config) ([]string, error)

type RdmUtil

+ func (app *RdmUtil) GetRecordStaleIds() ([]byte, error)

Oct 4, 2023

Changes in this version

+ func GetAllEPrintIDs(db *sql.DB) ([]int, error)

+ func GetAllEPrintIDsWithStatus(db *sql.DB, status string) ([]int, error)

+ func GetAllItems(db *sql.DB, field string) ([]string, error)

+ func GetAllORCIDs(db *sql.DB) ([]string, error)

+ func GetAllPersonNames(db *sql.DB, field string) ([]string, error)

+ func GetAllPersonOrOrgIDs(db *sql.DB, field string) ([]string, error)

+ func GetAllUniqueID(db *sql.DB, field string) ([]string, error)

+ func GetAllYears(db *sql.DB) ([]int, error)

+ func GetEPrintIDsForDateType(db *sql.DB, dateType string, start string, end string) ([]int, error)

+ func GetEPrintIDsForItem(db *sql.DB, field string, value string) ([]int, error)

+ func GetEPrintIDsForORCID(db *sql.DB, orcid string) ([]int, error)

+ func GetEPrintIDsForPersonName(db *sql.DB, field string, family string, given string) ([]int, error)

+ func GetEPrintIDsForPersonOrOrgID(db *sql.DB, personOrOrgType string, personOrOrgID string) ([]int, error)

+ func GetEPrintIDsForUniqueID(db *sql.DB, field string, value string) ([]int, error)

+ func GetEPrintIDsForYear(db *sql.DB, year int) ([]int, error)

+ func GetEPrintIDsInTimestampRange(db *sql.DB, field string, start string, end string) ([]int, error)

+ func GetEPrintIDsWithStatus(db *sql.DB, status string, start string, end string) ([]int, error)

+ func GetEPrintIDsWithStatusForDateType(db *sql.DB, status string, dateType string, start string, end string) ([]int, error)

+ func GetEPrintIDsWithStatusInTimestampRange(db *sql.DB, status string, field string, start string, end string) ([]int, error)

+ func GetModifiedKeys(cfg *Config, start string, end string) ([]int, error)

+ func GetTablesAndColumns(db *sql.DB) (map[string][]string, error)

+ func GetUserBy(db *sql.DB, queryField string, queryValue interface{}) (*eprinttools.EPrintUser, error)

+ func GetUserID(db *sql.DB, username string) ([]int, error)

+ func GetUsernames(db *sql.DB) ([]string, error)

+ func HarvestEPrintRecords(cfg *Config, recordIds []int, debug bool) error

+ func IsPublic(db *sql.DB, eprintid int) (bool, error)

+ func ProgressETA(t0 time.Time, i int, tot int) string

+ func SQLCreateEPrint(db *sql.DB, eprint *eprinttools.EPrint) (int, error)

+ func SQLCreateUser(db *sql.DB, user *eprinttools.EPrintUser) (int, error)

+ func SQLReadEPrint(db *sql.DB, baseURL string, eprintID int) (*eprinttools.EPrint, error)

+ func SQLReadUser(db *sql.DB, userid int) (*eprinttools.EPrintUser, error)

+ func SQLUpdateUser(db *sql.DB, user *eprinttools.EPrintUser) error

type Ep3Util

+ func (app *Ep3Util) GetModifiedRecordIds(start string, end string) ([]byte, error)

+ func (app *Ep3Util) RunHarvest(in io.Reader, out io.Writer, eout io.Writer, all bool, modified bool, ...) error

Sep 29, 2023

Changes in this version

type Config

+ EPrintDbHost string

+ EPrintDbPassword string

+ EPrintDbUser string

+ InvenioDbHost string

+ InvenioDbPassword string

+ InvenioDbUser string

+ RepoID string

Sep 22, 2023

Changes in this version

type EPrint2Rdm

+ func (app *EPrint2Rdm) Configure(configFName string, envPrefix string, debug bool) error

type Rdm2EPrint

+ func (app *Rdm2EPrint) RunPipeline(in io.Reader, out io.Writer, eout io.Writer, asXML bool) error

Sep 22, 2023

Changes in this version

+ func CrosswalkRdmToEPrint(cfg *Config, rec *simplified.Record, eprint *eprinttools.EPrint) error

+ func HarvestEPrints(cfg *Config, fName string, debug bool) error

+ func JSONMarshal(data interface{}) ([]byte, error)

+ func JSONMarshalIndent(data interface{}, prefix string, indent string) ([]byte, error)

+ func JSONUnmarshal(src []byte, data interface{}) error

type Config

+ EPrintArchivesPath string

+ EPrintHost string

+ EPrintPassword string

+ EPrintUser string

+ InvenioCommunityID string

+ type Ep3Util struct

+ Cfg *Config

+ Debug bool

+ func (app *Ep3Util) Configure(configFName string, envPrefix string, debug bool) error

+ func (app *Ep3Util) GetRecord(id string) ([]byte, error)

+ func (app *Ep3Util) GetRecordIds() ([]byte, error)

+ func (app *Ep3Util) Harvest(fName string) error

+ func (app *Ep3Util) Run(in io.Reader, out io.Writer, eout io.Writer, action string, params []string) error

+ type Rdm2EPrint struct

+ Cfg *Config

+ func (app *Rdm2EPrint) Configure(configFName string, envPrefix string, debug bool) error

+ func (app *Rdm2EPrint) Run(in io.Reader, out io.Writer, eout io.Writer, rdmids []string, asXML bool) error

+ func (app *Rdm2EPrint) RunHarvest(in io.Reader, out io.Writer, eout io.Writer, cName string, rdmids []string) error

Sep 15, 2023

Changes in this version

+ type RorOrgAPIResponse struct

+ Items []map[string]interface{}

+ NumberOfResults int

+ TimeTaken time.Duration

Sep 14, 2023

Changes in this version

+ func RequestLogger(targetMux http.Handler) http.Handler

+ type EPrintRest struct

+ DbHost string

+ DbPassword string

+ DbUser string

+ EPrintArchivesPath string

+ Port string

+ RepoID string

+ func (app *EPrintRest) EPrintXMLPath(db *sql.DB, id string) (string, error)

+ func (app *EPrintRest) ListenAndServe() error

+ func (app *EPrintRest) LoadEnv()

+ func (app *EPrintRest) MkDatasetPage(db *sql.DB, tmpl string, dataset string, label string) (string, error)

+ func (app *EPrintRest) Run(in io.Reader, out io.Writer, eout io.Writer) error

Aug 23, 2023

Changes in this version

+ func AddIdentifier(rec *simplified.Record, scheme string, identifier string) error

+ func AddIdentifiers(rec *simplified.Record, identifiers []*simplified.Identifier) error

Aug 18, 2023

Changes in this version

type RdmUtil

+ func (app *RdmUtil) ReviewComment(recordId string, comment string) ([]byte, error)

Aug 15, 2023

Changes in this version

+ func CheckDOI(cfg *Config, doi string) ([]map[string]interface{}, error)

type RdmUtil

+ func (app *RdmUtil) CheckDOI(doi string) ([]byte, error)

Aug 12, 2023

Changes in this version

+ func PublishRecordVersion(cfg *Config, recordId string, version string, pubDate string, debug bool) (map[string]interface{}, error)

+ func SetPubDate(cfg *Config, recordId string, pubDate string, debug bool) (map[string]interface{}, error)

+ func SetVersion(cfg *Config, recordId string, version string, debug bool) (map[string]interface{}, error)

type RdmUtil

+ func (app *RdmUtil) PublishRecordVersion(recordId string, version string, pubDate string) ([]byte, error)

+ func (app *RdmUtil) SetPubDate(recordId string, pubDate string) ([]byte, error)

+ func (app *RdmUtil) SetVersion(recordId string, version string) ([]byte, error)

Aug 8, 2023

Changes in this version

+ func DeleteEndpoint(cfg *Config, p string) ([]byte, error)

+ func GetDraftFiles(cfg *Config, recordId string, debug bool) (map[string]interface{}, error)

+ func GetReview(cfg *Config, recordId string, debug bool) (map[string]interface{}, error)

+ func ReviewRequest(cfg *Config, recordId string, decision string, comment string, debug bool) (map[string]interface{}, error)

type RdmUtil

+ func (app *RdmUtil) DeleteEndpoint(p string) ([]byte, error)

+ func (app *RdmUtil) GetDraftFiles(recordId string) ([]byte, error)

+ func (app *RdmUtil) GetReview(recordId string) ([]byte, error)

+ func (app *RdmUtil) ReviewRequest(recordId string, decision string, comment string) ([]byte, error)

Aug 4, 2023

Changes in this version

+ func NewDraft(cfg *Config, recordId string) (map[string]interface{}, error)

+ func NewRecord(cfg *Config, src []byte) (map[string]interface{}, error)

+ func NewRecordVersion(cfg *Config, recordId string) (map[string]interface{}, error)

+ func PatchEndpoint(cfg *Config, p string, payload []byte) ([]byte, error)

+ func PostEndpoint(cfg *Config, p string, payload []byte) ([]byte, error)

+ func PutEndpoint(cfg *Config, p string, payload []byte) ([]byte, error)

+ func SendToCommunity(cfg *Config, recordId string, communityId string, debug bool) (map[string]interface{}, error)

+ func SetFilesEnable(cfg *Config, recordId string, enable bool, debug bool) (map[string]interface{}, error)

type RdmUtil

+ Debug bool

+ func (app *RdmUtil) NewDraft(recordId string) ([]byte, error)

+ func (app *RdmUtil) NewRecord(src []byte) ([]byte, error)

+ func (app *RdmUtil) NewRecordVersion(recordId string) ([]byte, error)

+ func (app *RdmUtil) PatchEndpoint(p string, data []byte) ([]byte, error)

+ func (app *RdmUtil) PostEndpoint(p string, data []byte) ([]byte, error)

+ func (app *RdmUtil) PutEndpoint(p string, data []byte) ([]byte, error)

+ func (app *RdmUtil) SendToCommunity(recordId string, communityId string) ([]byte, error)

+ func (app *RdmUtil) SetFilesEnable(recordId string, enable bool) ([]byte, error)

Aug 1, 2023

Changes in this version

+ func CreateRecord(cfg *Config, src []byte) (map[string]interface{}, error)

+ func DeleteFiles(cfg *Config, recordId string, filenames []string) ([]byte, error)

+ func DiscardDraft(cfg *Config, recordId string) (map[string]interface{}, error)

+ func GetAccess(cfg *Config, recordId string, accessType string) ([]byte, error)

+ func GetEndpoint(cfg *Config, p string) ([]byte, error)

+ func PublishDraft(cfg *Config, recordId string) (map[string]interface{}, error)

+ func ReviewDraft(cfg *Config, recordId string, decision string, comment string) (map[string]interface{}, error)

+ func SetAccess(cfg *Config, recordId string, accessType string, accessValue string) ([]byte, error)

+ func SubmitDraft(cfg *Config, recordId string) (map[string]interface{}, error)

+ func UploadFiles(cfg *Config, recordId string, filenames []string) ([]byte, error)

type RdmUtil

+ func (app *RdmUtil) CreateRecord(src []byte) ([]byte, error)

+ func (app *RdmUtil) DeleteFiles(recordId string, filenames []string) ([]byte, error)

+ func (app *RdmUtil) DiscardDraft(recordId string) ([]byte, error)

+ func (app *RdmUtil) GetAccess(id string, accessType string) ([]byte, error)

+ func (app *RdmUtil) GetEndpoint(p string) ([]byte, error)

+ func (app *RdmUtil) PublishDraft(recordId string) ([]byte, error)

+ func (app *RdmUtil) ReviewDraft(recordId string, decision string, comment string) ([]byte, error)

+ func (app *RdmUtil) SetAccess(id string, accessType string, accessValue string) ([]byte, error)

+ func (app *RdmUtil) SubmitDraft(recordId string) ([]byte, error)

+ func (app *RdmUtil) UploadFiles(recordId string, filenames []string) ([]byte, error)

Jul 28, 2023

Changes in this version

+ func CreateDraft(cfg *Config, src []byte) (map[string]interface{}, error)

+ func DeleteDraft(cfg *Config, recordId string) (map[string]interface{}, error)

+ func GetDraft(cfg *Config, id string) (map[string]interface{}, error)

+ func GetFile(cfg *Config, id string, fName string) (*simplified.Entry, error)

+ func GetFiles(cfg *Config, id string) (*simplified.Files, error)

+ func GetVersionLatest(cfg *Config, id string) (map[string]interface{}, error)

+ func GetVersions(cfg *Config, id string) (map[string]interface{}, error)

+ func RetrieveFile(cfg *Config, id string, fName string) ([]byte, error)

+ func UpdateDraft(cfg *Config, recordId string, src []byte) (map[string]interface{}, error)

type RdmUtil

+ func (app *RdmUtil) CreateDraft(src []byte) ([]byte, error)

+ func (app *RdmUtil) DeleteDraft(recordId string) ([]byte, error)

+ func (app *RdmUtil) GetDraft(id string) ([]byte, error)

+ func (app *RdmUtil) GetFile(id string, fName string) ([]byte, error)

+ func (app *RdmUtil) GetFiles(id string) ([]byte, error)

+ func (app *RdmUtil) GetVersionLatest(id string) ([]byte, error)

+ func (app *RdmUtil) GetVersions(id string) ([]byte, error)

+ func (app *RdmUtil) RetrieveFile(id string, fName string) ([]byte, error)

+ func (app *RdmUtil) UpdateDraft(recordId string, src []byte) ([]byte, error)

Jul 17, 2023

Changes in this version

+ func SetLanguages(rec *simplified.Record, key string, value interface{}) error

Jul 12, 2023

Changes in this version

+ func AddRelatedIdentifier(rec *simplified.Record, scheme string, identifier string) error

+ func SetImprintField(rec *simplified.Record, key string, value interface{}) error

+ func SetPublicationDateByType(rec *simplified.Record, dt string, publicationType string) error

Jul 10, 2023

Changes in this version

+ func SetCustomField(rec *simplified.Record, customField string, key string, value interface{}) error

+ func SetJournalField(rec *simplified.Record, key string, value interface{}) error

Jun 7, 2023

Changes in this version

+ func SetIssue(rec *simplified.Record, issue string) error

May 22, 2023

Changes in this version

+ const ReleaseDate

+ const ReleaseHash

+ func FmtHelp(src string, appName string, version string, releaseDate string, ...) string

Apr 19, 2023

Changes in this version

+ func AddDate(rec *simplified.Record, dt *simplified.DateType) error

+ func AddRights(rec *simplified.Record, rights []*simplified.Right) error

+ func AddSubjects(rec *simplified.Record, subjects []*simplified.Subject) error

+ func GetRawRecord(cfg *Config, id string) (map[string]interface{}, error)

+ func SetPublicationDate(rec *simplified.Record, pubDate string) error

type Config

+ func NewConfig() *Config

type RateLimit

+ OldLimit int

type RdmUtil

+ func (app *RdmUtil) GetRawRecord(id string) ([]byte, error)

Apr 11, 2023

Changes in this version

+ func CheckWaitInterval(iTime time.Time, wait time.Duration) (time.Time, bool)

+ func ProgressETR(t0 time.Time, i int, tot int) string

+ func ProgressIPS(t0 time.Time, i int, timeUnit time.Duration) string

Apr 8, 2023

Changes in this version

+ func AddAdditionalTitles(rec *simplified.Record, title *simplified.TitleDetail) error

+ func AddRelatedIdentifiers(rec *simplified.Record, identifiers []*simplified.Identifier) error

+ func GetEPrint(baseURL string, eprintID int, timeout time.Duration, retryCount int) (*eprinttools.EPrints, error)

+ func GetKeys(baseURL string, timeout time.Duration, retryCount int) ([]int, error)

+ func LoadTypesMap(fName string, mapTypes map[string]string) error

+ func SetContributors(rec *simplified.Record, creators []*simplified.Creator) error

+ func SetCreators(rec *simplified.Record, creators []*simplified.Creator) error

+ func SetPresentationType(rec *simplified.Record, presentationType string) error

+ func SetTitle(rec *simplified.Record, title string) error

Apr 4, 2023

Changes in this version

+ func LoadResourceTypeMap(fName string, resourceTypes map[string]string) error

+ type EPrintKeysPage struct

+ Anchors []string

+ XMLName xml.Name

Mar 31, 2023

Changes in this version

+ const LicenseText

+ const Version

+ func AddBookTitle(rec *simplified.Record, bookTitle string) error

+ func AddContributors(rec *simplified.Record, contributor *simplified.PersonOrOrg, ...) error

+ func AddCreator(rec *simplified.Record, creator *simplified.PersonOrOrg, role *simplified.Role) error

+ func AddFunder(rec *simplified.Record, funder string, ror string, award string) error

+ func AddKeyword(rec *simplified.Record, keyword string) error

+ func AddPublicationDate(rec *simplified.Record, dt string, publicationType string) error

+ func AddRelatedDOI(rec *simplified.Record, doi string) error

+ func AddRelatedURL(rec *simplified.Record, url string) error

+ func AddSubject(rec *simplified.Record, subject string) error

+ func CrosswalkCrossRefWork(cfg *Config, work *crossrefapi.Works) (*simplified.Record, error)

+ func CrosswalkEPrintToRecord(eprint *eprinttools.EPrint, rec *simplified.Record) error

+ func GetModifiedRecordIds(cfg *Config, start string, end string) ([]string, error)

+ func GetRecordIds(cfg *Config) ([]string, error)

+ func Harvest(cfg *Config, fName string, debug bool) error

+ func PresentationType(rec *simplified.Record, presentationType string) error

+ func Query(cfg *Config, q string, sort string) ([]map[string]interface{}, error)

+ func QueryCrossRefWork(cfg *Config, doi string, mailTo string, dotInitials bool, ...) (*crossrefapi.Works, error)

+ func QueryDataCite(cfg *Config, doi string, mailTo string, dotInitials bool, ...) (map[string]interface{}, error)

+ func SampleConfig(configFName string) ([]byte, error)

+ func SetArticleNumber(rec *simplified.Record, articleNo string) error

+ func SetDOI(rec *simplified.Record, doi string) error

+ func SetDescription(rec *simplified.Record, description string) error

+ func SetEdition(rec *simplified.Record, edition string) error

+ func SetFullTextStatus(rec *simplified.Record, status bool) error

+ func SetFunding(rec *simplified.Record, funding []*simplified.Funder) error

+ func SetISBNs(rec *simplified.Record, isbns []*simplified.Identifier) error

+ func SetISSNs(rec *simplified.Record, issns []*simplified.Identifier) error

+ func SetMonographType(rec *simplified.Record, monographType string) error

+ func SetPageRange(rec *simplified.Record, pageRange string) error

+ func SetProject(rec *simplified.Record, project string) error

+ func SetPublication(rec *simplified.Record, publication string) error

+ func SetPublisher(rec *simplified.Record, publisher string) error

+ func SetPublisherLocation(rec *simplified.Record, publisherLocation string) error

+ func SetReferred(rec *simplified.Record, referred bool) error

+ func SetRelatedIdentifiers(rec *simplified.Record, identifiers []*simplified.Identifier) error

+ func SetResourceType(rec *simplified.Record, resourceType string) error

+ func SetSeries(rec *simplified.Record, series string) error

+ func SetTitles(rec *simplified.Record, titles []string) error

+ func SetVolume(rec *simplified.Record, volume string) error

+ type Config struct

+ CName string

+ Debug bool

+ InvenioAPI string

+ InvenioDSN string

+ InvenioStorage string

+ InvenioToken string

+ MailTo string

+ RepoName string

+ func (cfg *Config) LoadConfig(configFName string) error

+ func (cfg *Config) LoadEnv(prefix string) error

+ type Doi2Rdm struct

+ Cfg *Config

+ func (app *Doi2Rdm) Configure(configFName string, envPrefix string, debug bool) error

+ func (app *Doi2Rdm) Run(in io.Reader, out io.Writer, eout io.Writer, options map[string]string, ...) error

+ type EPrint2Rdm struct

+ Cfg *Config

+ func (app *EPrint2Rdm) Run(in io.Reader, out io.Writer, eout io.Writer, username string, password string, ...) error

+ type Hits struct

+ Hits []map[string]interface{}

+ Total int

+ type Links struct

+ Next string

+ Prev string

+ Self string

+ type OAIHeader struct

+ DateStamp string

+ Identifier string

+ SetSpec []string

+ Status string

+ type OAIListIdentifiers struct

+ Headers []OAIHeader

+ ResumptionToken string

+ type OAIListIdentifiersResponse struct

+ ListIdentifiers *OAIListIdentifiers

+ Request string

+ RequestAttr map[string]string

+ ResponseDate string

+ XMLNS string

+ XMLName xml.Name

+ type QueryResponse struct

+ Hits *Hits

+ Links *Links

+ SortBy string

+ type RateLimit struct

+ Limit int

+ Remaining int

+ Reset int

+ func GetRecord(cfg *Config, id string) (map[string]interface{}, *RateLimit, error)

+ func (rl *RateLimit) Fprintf(out io.Writer)

+ func (rl *RateLimit) FromHeader(header http.Header)

+ func (rl *RateLimit) FromResponse(resp *http.Response)

+ func (rl *RateLimit) ResetString() string

+ func (rl *RateLimit) String() string

+ func (rl *RateLimit) Throttle(i int, tot int)

+ func (rl *RateLimit) TimeToReset() (time.Duration, time.Time)

+ func (rl *RateLimit) TimeToWait(unit time.Duration) time.Duration

+ type RdmUtil struct

+ Cfg *Config

+ func (app *RdmUtil) Configure(configFName string, envPrefix string, debug bool) error

+ func (app *RdmUtil) GetModifiedIds(start string, end string) ([]byte, error)

+ func (app *RdmUtil) GetRecord(id string) ([]byte, error)

+ func (app *RdmUtil) GetRecordIds() ([]byte, error)

+ func (app *RdmUtil) Harvest(fName string) error

+ func (app *RdmUtil) Query(q string, sort string) ([]byte, error)

+ func (app *RdmUtil) Run(in io.Reader, out io.Writer, eout io.Writer, action string, params []string) error