Documentation
¶
Index ¶
- type Meilisearch
- func (m *Meilisearch) BatchIndex(ctx context.Context, nodes []model.SearchNode) error
- func (m *Meilisearch) Clear(ctx context.Context) error
- func (m *Meilisearch) Config() searcher.Config
- func (m *Meilisearch) Del(ctx context.Context, prefix string) error
- func (m *Meilisearch) EnqueueUpdate(parent string, objs []model.Obj)
- func (m *Meilisearch) Get(ctx context.Context, parent string) ([]model.SearchNode, error)
- func (m *Meilisearch) Index(ctx context.Context, node model.SearchNode) error
- func (m *Meilisearch) Release(ctx context.Context) error
- func (m *Meilisearch) Search(ctx context.Context, req model.SearchReq) ([]model.SearchNode, int64, error)
- type QueuedTask
- type TaskQueueManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Meilisearch ¶
type Meilisearch struct {
Client meilisearch.ServiceManager
IndexUid string
FilterableAttributes []string
SearchableAttributes []string
// contains filtered or unexported fields
}
func (*Meilisearch) BatchIndex ¶
func (m *Meilisearch) BatchIndex(ctx context.Context, nodes []model.SearchNode) error
func (*Meilisearch) Config ¶
func (m *Meilisearch) Config() searcher.Config
func (*Meilisearch) EnqueueUpdate ¶ added in v4.1.8
func (m *Meilisearch) EnqueueUpdate(parent string, objs []model.Obj)
EnqueueUpdate enqueues an update task to the task queue
func (*Meilisearch) Get ¶
func (m *Meilisearch) Get(ctx context.Context, parent string) ([]model.SearchNode, error)
func (*Meilisearch) Index ¶
func (m *Meilisearch) Index(ctx context.Context, node model.SearchNode) error
type QueuedTask ¶ added in v4.1.8
type QueuedTask struct {
Parent string
Objs []model.Obj // current file system state
Depth int // path depth for sorting
EnqueueAt time.Time // enqueue time
}
QueuedTask represents a task in the queue
type TaskQueueManager ¶ added in v4.1.8
type TaskQueueManager struct {
// contains filtered or unexported fields
}
TaskQueueManager manages the task queue for async index operations
func NewTaskQueueManager ¶ added in v4.1.8
func NewTaskQueueManager(m *Meilisearch) *TaskQueueManager
NewTaskQueueManager creates a new task queue manager
func (*TaskQueueManager) Enqueue ¶ added in v4.1.8
func (tqm *TaskQueueManager) Enqueue(parent string, objs []model.Obj)
Enqueue enqueues a task with current file system state
func (*TaskQueueManager) Start ¶ added in v4.1.8
func (tqm *TaskQueueManager) Start()
Start starts the task queue consumer
func (*TaskQueueManager) Stop ¶ added in v4.1.8
func (tqm *TaskQueueManager) Stop()
Stop stops the task queue consumer
Click to show internal directories.
Click to hide internal directories.