fix: update function signatures
This commit is contained in:
parent
f2efe09d59
commit
4d48d814c9
@ -17,6 +17,7 @@
|
|||||||
package models
|
package models
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"strconv"
|
"strconv"
|
||||||
"time"
|
"time"
|
||||||
@ -526,7 +527,7 @@ func (s *RemoveTaskFromTypesense) Handle(msg *message.Message) (err error) {
|
|||||||
_, err = typesenseClient.
|
_, err = typesenseClient.
|
||||||
Collection("tasks").
|
Collection("tasks").
|
||||||
Document(strconv.FormatInt(event.Task.ID, 10)).
|
Document(strconv.FormatInt(event.Task.ID, 10)).
|
||||||
Delete()
|
Delete(context.Background())
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -558,7 +559,7 @@ func (l *AddTaskToTypesense) Handle(msg *message.Message) (err error) {
|
|||||||
|
|
||||||
_, err = typesenseClient.Collection("tasks").
|
_, err = typesenseClient.Collection("tasks").
|
||||||
Documents().
|
Documents().
|
||||||
Create(ttask)
|
Create(context.Background(), ttask)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -17,6 +17,7 @@
|
|||||||
package models
|
package models
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
@ -411,7 +412,7 @@ func (t *typesenseTaskSearcher) Search(opts *taskSearchOptions) (tasks []*Task,
|
|||||||
|
|
||||||
result, err := typesenseClient.Collection("tasks").
|
result, err := typesenseClient.Collection("tasks").
|
||||||
Documents().
|
Documents().
|
||||||
Search(params)
|
Search(context.Background(), params)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
@ -17,6 +17,7 @@
|
|||||||
package models
|
package models
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"fmt"
|
"fmt"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@ -195,9 +196,9 @@ func CreateTypesenseCollections() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// delete any collection which might exist
|
// delete any collection which might exist
|
||||||
_, _ = typesenseClient.Collection("tasks").Delete()
|
_, _ = typesenseClient.Collection("tasks").Delete(context.Background())
|
||||||
|
|
||||||
_, err := typesenseClient.Collections().Create(taskSchema)
|
_, err := typesenseClient.Collections().Create(context.Background(), taskSchema)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -304,7 +305,7 @@ func reindexTasks(s *xorm.Session, tasks map[int64]*Task) (err error) {
|
|||||||
|
|
||||||
_, err = typesenseClient.Collection("tasks").
|
_, err = typesenseClient.Collection("tasks").
|
||||||
Documents().
|
Documents().
|
||||||
Import(typesenseTasks, &api.ImportDocumentsParams{
|
Import(context.Background(), typesenseTasks, &api.ImportDocumentsParams{
|
||||||
Action: pointer.String("upsert"),
|
Action: pointer.String("upsert"),
|
||||||
BatchSize: pointer.Int(100),
|
BatchSize: pointer.Int(100),
|
||||||
})
|
})
|
||||||
@ -381,14 +382,14 @@ func indexDummyTask() (err error) {
|
|||||||
|
|
||||||
_, err = typesenseClient.Collection("tasks").
|
_, err = typesenseClient.Collection("tasks").
|
||||||
Documents().
|
Documents().
|
||||||
Create(dummyTask)
|
Create(context.Background(), dummyTask)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
_, err = typesenseClient.Collection("tasks").
|
_, err = typesenseClient.Collection("tasks").
|
||||||
Document(dummyTask.ID).
|
Document(dummyTask.ID).
|
||||||
Delete()
|
Delete(context.Background())
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user