Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Analysis ¶
type Analysis struct { Filter Filter `json:"filter,omitempty"` Analyzer map[string]AnalyzerSettings `json:"analyzer,omitempty"` }
type AnalyzerSettings ¶
type Config ¶
type Config struct { IndexName string `` /* 131-byte string literal not displayed */ FlushBytes int `` /* 137-byte string literal not displayed */ FlushInterval time.Duration `` /* 140-byte string literal not displayed */ NumWorkers int `` /* 133-byte string literal not displayed */ Password string `` /* 162-byte string literal not displayed */ Username string `` /* 162-byte string literal not displayed */ Addresses []string `` /* 131-byte string literal not displayed */ CACert []byte `` /* 162-byte string literal not displayed */ DisableRetry bool `` /* 134-byte string literal not displayed */ MaxRetries int `` /* 137-byte string literal not displayed */ CompressRequestBody bool `` /* 134-byte string literal not displayed */ }
type ElasticError ¶
func (*ElasticError) Error ¶
func (j *ElasticError) Error() string
func (*ElasticError) Unwrap ¶
func (j *ElasticError) Unwrap() error
type FieldSetting ¶
type IndexSettings ¶
type IndexSettings struct { Settings Settings `json:"settings,omitempty"` Mappings Mappings `json:"mappings,omitempty"` }
func DefaultSettings ¶
func DefaultSettings(modifiers ...func(*IndexSettings)) IndexSettings
type Indexer ¶
type Indexer struct {
// contains filtered or unexported fields
}
func (*Indexer) CreateIndex ¶
func (*Indexer) DeleteIndex ¶
func (*Indexer) IndexPublications ¶
func (i *Indexer) IndexPublications( ctx context.Context, data chan crossrefindexer.SimplifiedPublication, ) error
IndexPublications is responsible for consuming all the publications sent on `data` and then close the indexer when the channel is closed
type Mappings ¶
type Mappings struct {
Properties map[string]FieldSetting `json:"properties,omitempty"`
}
type Option ¶
type Option func(*Indexer)
func WithTransport ¶
func WithTransport(rt http.RoundTripper) Option
Add custom transport. TODO: Maybe move this to config?
Click to show internal directories.
Click to hide internal directories.