es6

package
v1.0.55 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RegularDatasetFilters = []map[string]string{
	{
		"name":  "created_since",
		"field": "date_created",
		"type":  "date_since",
	},
	{
		"name":  "updated_since",
		"field": "date_updated",
		"type":  "date_since",
	},
}
View Source 
var RegularPublicationFilters = []map[string]string{
	{
		"name":  "created_since",
		"field": "date_created",
		"type":  "date_since",
	},
	{
		"name":  "updated_since",
		"field": "date_updated",
		"type":  "date_since",
	},
}

filter without facet values

Functions

func NewIndexedDataset 

func NewIndexedDataset(d *models.Dataset) *indexedDataset

func NewIndexedPublication 

func NewIndexedPublication(p *models.Publication) *indexedPublication

func NewSearchService 

func NewSearchService(c SearchServiceConfig) (backends.SearchService, error)

Types

type BaseFilter 

type BaseFilter struct {
	Name   string
	Field  string
	Values []string
}

func (*BaseFilter) GetField 

func (bf *BaseFilter) GetField() string

func (*BaseFilter) GetName 

func (bf *BaseFilter) GetName() string

func (*BaseFilter) GetValues 

func (bf *BaseFilter) GetValues() []string

type Client 

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

func New 

func New(c Config) (*Client, error)

type Config 

type Config struct {
	ClientConfig elasticsearch.Config
}

type DatasetIndex 

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

func (*DatasetIndex) Delete 

func (di *DatasetIndex) Delete(id string) error

func (*DatasetIndex) DeleteAll 

func (di *DatasetIndex) DeleteAll() error

func (*DatasetIndex) Each 

func (di *DatasetIndex) Each(searchArgs *models.SearchArgs, maxSize int, cb func(string)) error

func (*DatasetIndex) Search 

func (di *DatasetIndex) Search(args *models.SearchArgs) (*models.SearchHits, error)

func (*DatasetIndex) WithScope 

func (di *DatasetIndex) WithScope(field string, terms ...string) backends.DatasetIDIndex

type DateSinceFilter 

type DateSinceFilter struct {
	BaseFilter
}

date filter

func (*DateSinceFilter) ToQuery 

func (dbf *DateSinceFilter) ToQuery() map[string]any

type FieldFilter 

type FieldFilter struct {
	BaseFilter
}

regular field filter: accepts syntax in the filter value

func (*FieldFilter) ToQuery 

func (ff *FieldFilter) ToQuery() map[string]any

type Filterable 

type Filterable interface {
	GetName() string
	GetField() string
	GetValues() []string
	ToQuery() map[string]any
}

Name: public field name (e.g. url query parameter) Field: internal field name (e.g. elasticsearch field) Values: array of string values Type: type of filter. To distinguish from other filters ToQuery: convert and return search engine specific filter

func ToTypeFilter 

func ToTypeFilter(t string, name string, field string, values []string) Filterable

type M 

type M map[string]any

func ParseScope 

func ParseScope(field string, terms ...string) M

type PublicationIndex 

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

func (*PublicationIndex) Delete 

func (pi *PublicationIndex) Delete(id string) error

func (*PublicationIndex) DeleteAll 

func (pi *PublicationIndex) DeleteAll() error

func (*PublicationIndex) Each 

func (pi *PublicationIndex) Each(searchArgs *models.SearchArgs, maxSize int, cb func(string)) error

func (*PublicationIndex) Search 

func (pi *PublicationIndex) Search(args *models.SearchArgs) (*models.SearchHits, error)

func (*PublicationIndex) WithScope 

func (pi *PublicationIndex) WithScope(field string, terms ...string) backends.PublicationIDIndex

type SearchService 

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

func (*SearchService) NewDatasetBulkIndexer 

func (s *SearchService) NewDatasetBulkIndexer(config backends.BulkIndexerConfig) (backends.BulkIndexer[*models.Dataset], error)

func (*SearchService) NewDatasetIndex 

func (s *SearchService) NewDatasetIndex(r *repositories.Repo) backends.DatasetIndex

func (*SearchService) NewDatasetIndexSwitcher 

func (s *SearchService) NewDatasetIndexSwitcher(config backends.BulkIndexerConfig) (backends.IndexSwitcher[*models.Dataset], error)

func (*SearchService) NewPublicationBulkIndexer 

func (s *SearchService) NewPublicationBulkIndexer(config backends.BulkIndexerConfig) (backends.BulkIndexer[*models.Publication], error)

func (*SearchService) NewPublicationIndex 

func (s *SearchService) NewPublicationIndex(r *repositories.Repo) backends.PublicationIndex

func (*SearchService) NewPublicationIndexSwitcher 

func (s *SearchService) NewPublicationIndexSwitcher(config backends.BulkIndexerConfig) (backends.IndexSwitcher[*models.Publication], error)

type SearchServiceConfig 

type SearchServiceConfig struct {
	Addresses        string
	DatasetIndex     string
	PublicationIndex string
	IndexRetention   int // -1: keep all old indexes, >=0: keep x old indexes
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.