es

package
v0.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2018 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CollectionsScopeByContentUnit added in v0.7.7

func CollectionsScopeByContentUnit(mdb *sql.DB, cuUID string) ([]string, error)

func CollectionsScopeByFile added in v0.7.7

func CollectionsScopeByFile(mdb *sql.DB, fileUID string) ([]string, error)

func ConvertDocx

func ConvertDocx(db *sql.DB) error

func DownloadAndConvert added in v0.7.4

func DownloadAndConvert(docBatch [][]string) error

func DumpDB added in v0.7.7

func DumpDB(mdb *sql.DB, title string) error

func DumpIndexes added in v0.7.7

func DumpIndexes(esc *elastic.Client, title string, indexType string) error

func IndexName

func IndexName(namespace string, name string, lang string) string

func InitVars added in v0.7.7

func InitVars()

func LoadDocFilename added in v0.7.4

func LoadDocFilename(db *sql.DB, fileUID string) (string, error)

func TypedUIDsToUids added in v0.8.1

func TypedUIDsToUids(t string, typedUIDs []string) ([]string, error)

Types

type BaseIndex added in v0.6.7

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

func (*BaseIndex) CreateIndex added in v0.6.7

func (index *BaseIndex) CreateIndex() error

func (*BaseIndex) DeleteIndex added in v0.6.7

func (index *BaseIndex) DeleteIndex() error

func (*BaseIndex) RefreshIndex added in v0.6.7

func (index *BaseIndex) RefreshIndex() error

func (*BaseIndex) RefreshIndexByLang added in v0.6.7

func (index *BaseIndex) RefreshIndexByLang(lang string) error

type Classification

type Classification struct {
	MDB_UID            string `json:"mdb_uid"`
	Name               string `json:"name,omitempty"`
	NameSuggest        string `json:"name_suggest,omitempty"`
	Description        string `json:"description,omitempty"`
	DescriptionSuggest string `json:"description_suggest,omitempty"`
	Type               string `json:"classification_type"`
}

type ClassificationsIndex added in v0.6.7

type ClassificationsIndex struct {
	BaseIndex
}

func MakeClassificationsIndex added in v0.6.7

func MakeClassificationsIndex(namespace string, db *sql.DB, esc *elastic.Client) *ClassificationsIndex

func (*ClassificationsIndex) Add added in v0.6.7

func (index *ClassificationsIndex) Add(scope Scope) error

func (*ClassificationsIndex) Delete added in v0.6.7

func (index *ClassificationsIndex) Delete(scope Scope) error

func (*ClassificationsIndex) ReindexAll added in v0.6.7

func (index *ClassificationsIndex) ReindexAll() error

func (*ClassificationsIndex) Update added in v0.6.7

func (index *ClassificationsIndex) Update(scope Scope) error

type Collection

type Collection struct {
	MDB_UID                  string      `json:"mdb_uid"`
	TypedUIDs                []string    `json:"typed_uids"`
	Name                     string      `json:"name"`
	Description              string      `json:"description"`
	ContentType              string      `json:"content_type"`
	ContentUnitsContentTypes []string    `json:"content_units_content_types,omitempty"`
	EffectiveDate            *utils.Date `json:"effective_date"`
	OriginalLanguage         string      `json:"original_language,omitempty"`
}

type CollectionsIndex added in v0.6.7

type CollectionsIndex struct {
	BaseIndex
	// contains filtered or unexported fields
}

func MakeCollectionsIndex added in v0.6.9

func MakeCollectionsIndex(namespace string, db *sql.DB, esc *elastic.Client) *CollectionsIndex

func (*CollectionsIndex) Add added in v0.6.9

func (index *CollectionsIndex) Add(scope Scope) error

func (*CollectionsIndex) Delete added in v0.6.9

func (index *CollectionsIndex) Delete(scope Scope) error

func (*CollectionsIndex) ReindexAll added in v0.6.9

func (index *CollectionsIndex) ReindexAll() error

func (*CollectionsIndex) Update added in v0.6.9

func (index *CollectionsIndex) Update(scope Scope) error

type ContentUnit

type ContentUnit struct {
	MDB_UID                 string      `json:"mdb_uid"`
	TypedUIDs               []string    `json:"typed_uids"`
	Name                    string      `json:"name,omitempty"`
	Description             string      `json:"description,omitempty"`
	ContentType             string      `json:"content_type"`
	CollectionsContentTypes []string    `json:"collections_content_types,omitempty"`
	EffectiveDate           *utils.Date `json:"effective_date,omitempty"`
	Duration                uint64      `json:"duration,omitempty"`
	OriginalLanguage        string      `json:"original_language,omitempty"`
	Translations            []string    `json:"translations,omitempty"`
	Tags                    []string    `json:"tags,omitempty"`
	Sources                 []string    `json:"sources,omitempty"`
	Authors                 []string    `json:"authors,omitempty"`
	Persons                 []string    `json:"persons,omitempty"`
	Transcript              string      `json:"transcript,omitempty"`
}

type ContentUnitsIndex added in v0.6.7

type ContentUnitsIndex struct {
	BaseIndex
}

func MakeContentUnitsIndex added in v0.6.7

func MakeContentUnitsIndex(namespace string, db *sql.DB, esc *elastic.Client) *ContentUnitsIndex

func (*ContentUnitsIndex) Add added in v0.6.7

func (index *ContentUnitsIndex) Add(scope Scope) error

func (*ContentUnitsIndex) Delete added in v0.6.7

func (index *ContentUnitsIndex) Delete(scope Scope) error

func (*ContentUnitsIndex) ReindexAll added in v0.6.7

func (index *ContentUnitsIndex) ReindexAll() error

func (*ContentUnitsIndex) Update added in v0.6.7

func (index *ContentUnitsIndex) Update(scope Scope) error

type EffectiveDate added in v0.6.9

type EffectiveDate struct {
	EffectiveDate *utils.Date `json:"effective_date"`
}

type File

type File struct {
	MDB_UID  string      `json:"mdb_uid"`
	Name     string      `json:"name"`
	Size     uint64      `json:"size"`
	URL      string      `json:"url"`
	Secure   int         `json:"secure"`
	FilmDate *utils.Date `json:"film_date"`
	Duration float64     `json:"duration,omitempty"`
	Language string      `json:"language,omitempty"`
	MimeType string      `json:"mimetype,omitempty"`
	Type     string      `json:"type,omitempty"`
	SubType  string      `json:"subtype,omitempty"`
}

type Index added in v0.6.7

type Index interface {
	ReindexAll() error
	Add(scope Scope) error
	Update(scope Scope) error
	Delete(scope Scope) error
	CreateIndex() error
	DeleteIndex() error
	RefreshIndex() error
}

type IndexData added in v0.6.7

type IndexData struct {
	DB           *sql.DB
	Sources      map[string][]string
	Tags         map[string][]string
	Persons      map[string][]string
	Translations map[string][][]string
	Transcripts  map[string]map[string][]string
}

func MakeIndexData added in v0.7.7

func MakeIndexData(db *sql.DB, sqlScope string) (*IndexData, error)

type Indexer added in v0.6.7

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

func MakeFakeIndexer added in v0.7.0

func MakeFakeIndexer(mdb *sql.DB, esc *elastic.Client) *Indexer

func MakeIndexer added in v0.6.7

func MakeIndexer(namespace string, names []string, mdb *sql.DB, esc *elastic.Client) *Indexer

Receives namespace and list of indexes names.

func MakeProdIndexer added in v0.6.7

func MakeProdIndexer(mdb *sql.DB, esc *elastic.Client) *Indexer

func (*Indexer) CollectionAdd added in v0.6.7

func (indexer *Indexer) CollectionAdd(uid string) error

Set of MDB event handlers to incrementally change all indexes.

func (*Indexer) CollectionDelete added in v0.6.7

func (indexer *Indexer) CollectionDelete(uid string) error

func (*Indexer) CollectionUpdate added in v0.6.7

func (indexer *Indexer) CollectionUpdate(uid string) error

func (*Indexer) ContentUnitAdd added in v0.6.7

func (indexer *Indexer) ContentUnitAdd(uid string) error

func (*Indexer) ContentUnitDelete added in v0.6.7

func (indexer *Indexer) ContentUnitDelete(uid string) error

func (*Indexer) ContentUnitUpdate added in v0.6.7

func (indexer *Indexer) ContentUnitUpdate(uid string) error

func (*Indexer) CreateIndexes added in v0.6.7

func (indexer *Indexer) CreateIndexes() error

func (*Indexer) DeleteIndexes added in v0.6.7

func (indexer *Indexer) DeleteIndexes() error

func (*Indexer) FileAdd added in v0.6.7

func (indexer *Indexer) FileAdd(uid string) error

func (*Indexer) FileDelete added in v0.6.7

func (indexer *Indexer) FileDelete(uid string) error

func (*Indexer) FileUpdate added in v0.6.7

func (indexer *Indexer) FileUpdate(uid string) error

func (*Indexer) PersonAdd added in v0.6.7

func (indexer *Indexer) PersonAdd(uid string) error

func (*Indexer) PersonDelete added in v0.6.9

func (indexer *Indexer) PersonDelete(uid string) error

func (*Indexer) PersonUpdate added in v0.6.7

func (indexer *Indexer) PersonUpdate(uid string) error

func (*Indexer) PublisherAdd added in v0.6.7

func (indexer *Indexer) PublisherAdd(uid string) error

func (*Indexer) PublisherUpdate added in v0.6.7

func (indexer *Indexer) PublisherUpdate(uid string) error

func (*Indexer) RefreshAll added in v0.6.7

func (indexer *Indexer) RefreshAll() error

func (*Indexer) ReindexAll added in v0.6.7

func (indexer *Indexer) ReindexAll() error

func (*Indexer) SourceAdd added in v0.6.7

func (indexer *Indexer) SourceAdd(uid string) error

func (*Indexer) SourceUpdate added in v0.6.7

func (indexer *Indexer) SourceUpdate(uid string) error

func (*Indexer) TagAdd added in v0.6.7

func (indexer *Indexer) TagAdd(uid string) error

func (*Indexer) TagUpdate added in v0.6.7

func (indexer *Indexer) TagUpdate(uid string) error

type Scope added in v0.6.7

type Scope struct {
	ContentUnitUID string
	FileUID        string
	CollectionUID  string
	TagUID         string
	SourceUID      string
	PersonUID      string
	PublisherUID   string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL