Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DocumentParser ¶
type DocumentParser interface {
Start(chan<- redisearch.Document) error
Stop()
}
func NewSingleFileReader ¶
func NewSingleFileReader(name string, opener DocumentReaderOpener) DocumentParser
type DocumentReader ¶
type DocumentReader interface {
Read() (redisearch.Document, error)
}
type DocumentReaderOpener ¶
type DocumentReaderOpener interface {
Open(io.Reader) (DocumentReader, error)
}
type DocumentReaderOpenerFunc ¶
type DocumentReaderOpenerFunc func(io.Reader) (DocumentReader, error)
func (DocumentReaderOpenerFunc) Open ¶
func (f DocumentReaderOpenerFunc) Open(r io.Reader) (DocumentReader, error)
type FolderReader ¶
type FolderReader struct {
// contains filtered or unexported fields
}
func NewFolderReader ¶
func NewFolderReader(path, pattern string, concurrency int, opener DocumentReaderOpener) *FolderReader
func (*FolderReader) Start ¶
func (fr *FolderReader) Start(ch chan<- redisearch.Document) error
func (*FolderReader) Stop ¶
func (fr *FolderReader) Stop()
type Indexer ¶
type Indexer struct {
// contains filtered or unexported fields
}
func New ¶
func New(name, host string, concurrency int, ch chan redisearch.Document, parser DocumentParser, sp SchemaProvider, chunkSize int) *Indexer
func (*Indexer) GetNumIndexed ¶
Returns the number of documents indexed
type SchemaProvider ¶
type SchemaProvider interface {
Schema() *redisearch.Schema
}
type SchemaProviderFunc ¶
type SchemaProviderFunc func() *redisearch.Schema
func (SchemaProviderFunc) Schema ¶
func (s SchemaProviderFunc) Schema() *redisearch.Schema
type SingleFileReader ¶
type SingleFileReader struct {
// contains filtered or unexported fields
}
func (*SingleFileReader) Start ¶
func (r *SingleFileReader) Start(ch chan<- redisearch.Document) error
func (*SingleFileReader) Stop ¶
func (r *SingleFileReader) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.