Documentation
¶
Index ¶
- func CreateSchema(ctx context.Context, conn SQConnection, schema string, tokenizer string) error
- func Delete(schema string, evt *QueueEvent) (SQStatement, []interface{})
- func ListIndexWithCount(ctx context.Context, conn SQConnection, schema string) (map[string]int64, error)
- func Replace(schema string, evt *QueueEvent) (SQStatement, []interface{})
- type EventType
- type Indexer
- type Queue
- type QueueEvent
- type Store
- type WalkFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateSchema ¶ added in v1.0.49
func Delete ¶ added in v1.0.49
func Delete(schema string, evt *QueueEvent) (SQStatement, []interface{})
func ListIndexWithCount ¶ added in v1.0.49
func ListIndexWithCount(ctx context.Context, conn SQConnection, schema string) (map[string]int64, error)
Get indexes and count of documents for each index
func Replace ¶ added in v1.0.49
func Replace(schema string, evt *QueueEvent) (SQStatement, []interface{})
Types ¶
type Indexer ¶
func NewIndexer ¶
Create a new indexer with an identifier, path to the root of the indexer and a queue
func (*Indexer) IsIndexing ¶ added in v1.0.49
Return true if indexing
type Queue ¶
func NewQueueWithCapacity ¶
Create a new queue which acts as a buffer between the file indexing and the processng/rendering which can be slower than the file indexing
func (*Queue) Add ¶
Add an item to the queue. If the item is already in the queue, then it is bumped to the end of the queue
func (*Queue) Get ¶
func (q *Queue) Get(name, path string) *QueueEvent
Return a queue event from the queue, or nil
Click to show internal directories.
Click to hide internal directories.