elasticsearch

Documentation

Index

• func DeleteFromElasticSearch(work string, collection string, doctype string)
• func GetContentIDChangedAt(physID string, contentID string, redisClient *redis.Client) string
• func GetESLogFromDmdsec(nonModsDmdsecIDs []string, logDivList []types.Div, physDivList []types.Div, ...) map[string]types.ESLog
• func GetESPhysFromPhysStructMap(physicalIDToAttrMap map[string]types.PhysicalAttributes, ...) map[string]types.ESPhys
• func GetUpdateDates(id string, doctype string, redisClient *redis.Client) (string, string)
• func WriteToIndex(esDoc types.ESDoc)
• func WriteToLogIndex()
• func WriteToPhysIndex()
• type DeleteAnchorMatch
• type DeleteAnchorQuery
• type DeleteCollection
• type DeleteWork
• type DeleteWorkMatch
• type DeleteWorkQuery
• type OldESDatesMsg
• type OldSolrDatesMsg

Functions

func DeleteFromElasticSearch

func DeleteFromElasticSearch(work string, collection string, doctype string)

func GetContentIDChangedAt

func GetContentIDChangedAt(physID string, contentID string, redisClient *redis.Client) string

GetContentIDChangedAt ...

func GetESLogFromDmdsec

func GetESLogFromDmdsec(
	nonModsDmdsecIDs []string,
	logDivList []types.Div,
	physDivList []types.Div,
	dmdsecMap map[string]types.Dmdsec,
	amdsecMap map[string]types.Amdsec,
	logToPhysLinkMap map[string]types.LogToPhysLink,
	physicalIDToAttrMap map[string]types.PhysicalAttributes,
	ccontext string,
	product string,
	recordIdentifier string,
	workID string,
	doctype string,
	parentInfo *types.Parent,
	parentDivInfo types.ParentDivInfo,
	dmdidOfFirstPhysDiv string,
	dateIndexed string,
	dateModified string,
	redisClient *redis.Client) map[string]types.ESLog

GetESLogFromDmdsec ...

func GetESPhysFromPhysStructMap

func GetESPhysFromPhysStructMap(
	physicalIDToAttrMap map[string]types.PhysicalAttributes,
	fileIDToAttrMap map[string]types.FileSecAttributes,
	physToLogLinkMap map[string]types.PhysToLogLink,
	logToPhysLinkMap map[string]types.LogToPhysLink,
	metsJob *types.Mets,
	redisClient *redis.Client,
	isExternal bool) map[string]types.ESPhys

GetESPhysFromPhysStructMap ...

func GetUpdateDates

func GetUpdateDates(id string, doctype string, redisClient *redis.Client) (string, string)

GetUpdateDates ...

func WriteToIndex

func WriteToIndex(esDoc types.ESDoc)

WriteToIndex ...

func WriteToLogIndex

func WriteToLogIndex()

WriteToLogIndex ...

func WriteToPhysIndex

func WriteToPhysIndex()

WriteToPhysIndex ...

Types

type DeleteAnchorMatch

type DeleteAnchorMatch struct {
	DeleteCollection DeleteCollection `json:"match"`
}

DeleteAnchorMatch ...

type DeleteAnchorQuery

type DeleteAnchorQuery struct {
	DeleteAnchorMatch DeleteAnchorMatch `json:"query"`
}

DeleteAnchorQuery ...

type DeleteCollection

type DeleteCollection struct {
	Collection string `json:"collection"`
}

DeleteCollection ...

type DeleteWork

type DeleteWork struct {
	Work string `json:"work"`
}

DeleteWork ...

type DeleteWorkMatch

type DeleteWorkMatch struct {
	DeleteWork DeleteWork `json:"match"`
}

DeleteWorkMatch ...

type DeleteWorkQuery

type DeleteWorkQuery struct {
	DeleteWorkMatch DeleteWorkMatch `json:"query"`
}

DeleteWorkQuery ...

type OldESDatesMsg

type OldESDatesMsg struct {
	ID           string `json:"id"`
	Datemodified string `json:"datemodified,omitempty"`
	Dateindexed  string `json:"dateindexed,omitempty"`
}

OldESDatesMsg ...

type OldSolrDatesMsg

type OldSolrDatesMsg struct {
	ID           string `json:"id"`
	Datemodified string `json:"datemodified,omitempty"`
	Dateindexed  string `json:"dateindexed,omitempty"`
}

OldSolrDatesMsg ...