Documentation
¶
Index ¶
- func BatchDeleteAllDoc(ctx context.Context, tx *gorm.DB, knowledge *model.KnowledgeBase, ...) error
- func CommonDeleting(ctx context.Context, taskCtx string, stop <-chan struct{}, wg *sync.WaitGroup) <-chan async_task.IReport
- type DocDeleteTask
- func (t *DocDeleteTask) BuildServiceType() uint32
- func (t *DocDeleteTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *DocDeleteTask) InitTask() error
- func (t *DocDeleteTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *DocDeleteTask) SubmitTask(ctx context.Context, params interface{}) (err error)
- type DocImportTask
- func (t *DocImportTask) BuildServiceType() uint32
- func (t *DocImportTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *DocImportTask) InitTask() error
- func (t *DocImportTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *DocImportTask) SubmitTask(ctx context.Context, params interface{}) (err error)
- type DocSegmentImportTask
- func (t *DocSegmentImportTask) BuildServiceType() uint32
- func (t *DocSegmentImportTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *DocSegmentImportTask) InitTask() error
- func (t *DocSegmentImportTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *DocSegmentImportTask) SubmitTask(ctx context.Context, params interface{}) (err error)
- type KnowledgeDeleteTask
- func (t *KnowledgeDeleteTask) BuildServiceType() uint32
- func (t *KnowledgeDeleteTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *KnowledgeDeleteTask) InitTask() error
- func (t *KnowledgeDeleteTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *KnowledgeDeleteTask) SubmitTask(ctx context.Context, params interface{}) (err error)
- type KnowledgeReportTask
- func (t *KnowledgeReportTask) BuildServiceType() uint32
- func (t *KnowledgeReportTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *KnowledgeReportTask) InitTask() error
- func (t *KnowledgeReportTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
- func (t *KnowledgeReportTask) SubmitTask(ctx context.Context, params interface{}) (err error)
- type Result
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BatchDeleteAllDoc ¶
func BatchDeleteAllDoc(ctx context.Context, tx *gorm.DB, knowledge *model.KnowledgeBase, docList []*model.KnowledgeDoc) error
BatchDeleteAllDoc 批量删除所有文档
func CommonDeleting ¶
Types ¶
type DocDeleteTask ¶
func (*DocDeleteTask) BuildServiceType ¶
func (t *DocDeleteTask) BuildServiceType() uint32
func (*DocDeleteTask) Deleting ¶
func (t *DocDeleteTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*DocDeleteTask) InitTask ¶
func (t *DocDeleteTask) InitTask() error
func (*DocDeleteTask) Running ¶
func (t *DocDeleteTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*DocDeleteTask) SubmitTask ¶
func (t *DocDeleteTask) SubmitTask(ctx context.Context, params interface{}) (err error)
type DocImportTask ¶
func (*DocImportTask) BuildServiceType ¶
func (t *DocImportTask) BuildServiceType() uint32
func (*DocImportTask) Deleting ¶
func (t *DocImportTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*DocImportTask) InitTask ¶
func (t *DocImportTask) InitTask() error
func (*DocImportTask) Running ¶
func (t *DocImportTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*DocImportTask) SubmitTask ¶
func (t *DocImportTask) SubmitTask(ctx context.Context, params interface{}) (err error)
type DocSegmentImportTask ¶ added in v0.2.1
func (*DocSegmentImportTask) BuildServiceType ¶ added in v0.2.1
func (t *DocSegmentImportTask) BuildServiceType() uint32
func (*DocSegmentImportTask) Deleting ¶ added in v0.2.1
func (t *DocSegmentImportTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*DocSegmentImportTask) InitTask ¶ added in v0.2.1
func (t *DocSegmentImportTask) InitTask() error
func (*DocSegmentImportTask) Running ¶ added in v0.2.1
func (t *DocSegmentImportTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*DocSegmentImportTask) SubmitTask ¶ added in v0.2.1
func (t *DocSegmentImportTask) SubmitTask(ctx context.Context, params interface{}) (err error)
type KnowledgeDeleteTask ¶
func (*KnowledgeDeleteTask) BuildServiceType ¶
func (t *KnowledgeDeleteTask) BuildServiceType() uint32
func (*KnowledgeDeleteTask) Deleting ¶
func (t *KnowledgeDeleteTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*KnowledgeDeleteTask) InitTask ¶
func (t *KnowledgeDeleteTask) InitTask() error
func (*KnowledgeDeleteTask) Running ¶
func (t *KnowledgeDeleteTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*KnowledgeDeleteTask) SubmitTask ¶
func (t *KnowledgeDeleteTask) SubmitTask(ctx context.Context, params interface{}) (err error)
type KnowledgeReportTask ¶ added in v0.2.8
func (*KnowledgeReportTask) BuildServiceType ¶ added in v0.2.8
func (t *KnowledgeReportTask) BuildServiceType() uint32
func (*KnowledgeReportTask) Deleting ¶ added in v0.2.8
func (t *KnowledgeReportTask) Deleting(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*KnowledgeReportTask) InitTask ¶ added in v0.2.8
func (t *KnowledgeReportTask) InitTask() error
func (*KnowledgeReportTask) Running ¶ added in v0.2.8
func (t *KnowledgeReportTask) Running(ctx context.Context, taskCtx string, stop <-chan struct{}) <-chan async_task.IReport
func (*KnowledgeReportTask) SubmitTask ¶ added in v0.2.8
func (t *KnowledgeReportTask) SubmitTask(ctx context.Context, params interface{}) (err error)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.