services

package
v1.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 20, 2025 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MeilisearchDocument

type MeilisearchDocument struct {
	ID          uint      `json:"id"`
	Title       string    `json:"title"`
	Description string    `json:"description"`
	URL         string    `json:"url"`
	SaveURL     string    `json:"save_url"`
	FileSize    string    `json:"file_size"`
	Key         string    `json:"key"`
	Category    string    `json:"category"`
	Tags        []string  `json:"tags"`
	PanName     string    `json:"pan_name"`
	PanID       *uint     `json:"pan_id"`
	Author      string    `json:"author"`
	CreatedAt   time.Time `json:"created_at"`
	UpdatedAt   time.Time `json:"updated_at"`
	// 高亮字段
	TitleHighlight       string   `json:"_title_highlight,omitempty"`
	DescriptionHighlight string   `json:"_description_highlight,omitempty"`
	CategoryHighlight    string   `json:"_category_highlight,omitempty"`
	TagsHighlight        []string `json:"_tags_highlight,omitempty"`
}

MeilisearchDocument 搜索文档结构

type MeilisearchManager

type MeilisearchManager struct {
	// contains filtered or unexported fields
}

MeilisearchManager Meilisearch管理器

func NewMeilisearchManager

func NewMeilisearchManager(repoMgr *repo.RepositoryManager) *MeilisearchManager

NewMeilisearchManager 创建Meilisearch管理器

func (*MeilisearchManager) ClearIndex

func (m *MeilisearchManager) ClearIndex() error

ClearIndex 清空索引

func (*MeilisearchManager) DebugGetAllDocuments

func (m *MeilisearchManager) DebugGetAllDocuments() error

DebugGetAllDocuments 调试:获取所有文档

func (*MeilisearchManager) GetAllResources

func (m *MeilisearchManager) GetAllResources(page, pageSize int) ([]entity.Resource, int64, error)

GetAllResources 获取所有资源

func (*MeilisearchManager) GetService

func (m *MeilisearchManager) GetService() *MeilisearchService

GetService 获取Meilisearch服务

func (*MeilisearchManager) GetStatus

func (m *MeilisearchManager) GetStatus() (MeilisearchStatus, error)

GetStatus 获取状态

func (*MeilisearchManager) GetStatusWithHealthCheck

func (m *MeilisearchManager) GetStatusWithHealthCheck() (MeilisearchStatus, error)

GetStatusWithHealthCheck 获取状态并同时进行健康检查

func (*MeilisearchManager) GetSyncProgress

func (m *MeilisearchManager) GetSyncProgress() SyncProgress

GetSyncProgress 获取同步进度

func (*MeilisearchManager) GetSyncedResources

func (m *MeilisearchManager) GetSyncedResources(page, pageSize int) ([]entity.Resource, int64, error)

GetSyncedResources 获取已同步的资源

func (*MeilisearchManager) GetUnsyncedCount

func (m *MeilisearchManager) GetUnsyncedCount() (int64, error)

GetUnsyncedCount 获取未同步资源数量

func (*MeilisearchManager) GetUnsyncedResources

func (m *MeilisearchManager) GetUnsyncedResources(page, pageSize int) ([]entity.Resource, int64, error)

GetUnsyncedResources 获取未同步的资源

func (*MeilisearchManager) Initialize

func (m *MeilisearchManager) Initialize() error

Initialize 初始化Meilisearch服务

func (*MeilisearchManager) IsEnabled

func (m *MeilisearchManager) IsEnabled() bool

IsEnabled 检查是否启用

func (*MeilisearchManager) ReloadConfig

func (m *MeilisearchManager) ReloadConfig() error

ReloadConfig 重新加载配置

func (*MeilisearchManager) Stop

func (m *MeilisearchManager) Stop()

Stop 停止监控

func (*MeilisearchManager) StopSync

func (m *MeilisearchManager) StopSync()

StopSync 停止同步

func (*MeilisearchManager) SyncAllResources

func (m *MeilisearchManager) SyncAllResources() (int, error)

SyncAllResources 同步所有资源

func (*MeilisearchManager) SyncResourceToMeilisearch

func (m *MeilisearchManager) SyncResourceToMeilisearch(resource *entity.Resource) error

SyncResourceToMeilisearch 同步资源到Meilisearch

type MeilisearchService

type MeilisearchService struct {
	// contains filtered or unexported fields
}

MeilisearchService Meilisearch服务

func NewMeilisearchService

func NewMeilisearchService(host, port, masterKey, indexName string, enabled bool) *MeilisearchService

NewMeilisearchService 创建Meilisearch服务

func (*MeilisearchService) BatchAddDocuments

func (m *MeilisearchService) BatchAddDocuments(docs []MeilisearchDocument) error

BatchAddDocuments 批量添加文档

func (*MeilisearchService) ClearIndex

func (m *MeilisearchService) ClearIndex() error

ClearIndex 清空索引

func (*MeilisearchService) CreateIndex

func (m *MeilisearchService) CreateIndex() error

CreateIndex 创建索引

func (*MeilisearchService) GetAllDocuments

func (m *MeilisearchService) GetAllDocuments() ([]MeilisearchDocument, error)

GetAllDocuments 获取所有文档(用于调试)

func (*MeilisearchService) GetIndexStats

func (m *MeilisearchService) GetIndexStats() (map[string]interface{}, error)

GetIndexStats 获取索引统计信息

func (*MeilisearchService) HealthCheck

func (m *MeilisearchService) HealthCheck() error

HealthCheck 健康检查

func (*MeilisearchService) IsEnabled

func (m *MeilisearchService) IsEnabled() bool

IsEnabled 检查是否启用

func (*MeilisearchService) Search

func (m *MeilisearchService) Search(query string, filters map[string]interface{}, page, pageSize int) ([]MeilisearchDocument, int64, error)

Search 搜索文档

func (*MeilisearchService) UpdateIndexSettings

func (m *MeilisearchService) UpdateIndexSettings() error

UpdateIndexSettings 更新索引设置

type MeilisearchStatus

type MeilisearchStatus struct {
	Enabled       bool      `json:"enabled"`
	Healthy       bool      `json:"healthy"`
	LastCheck     time.Time `json:"last_check"`
	ErrorCount    int       `json:"error_count"`
	LastError     string    `json:"last_error"`
	DocumentCount int64     `json:"document_count"`
}

MeilisearchStatus Meilisearch状态

type SyncProgress

type SyncProgress struct {
	IsRunning      bool      `json:"is_running"`
	TotalCount     int64     `json:"total_count"`
	ProcessedCount int64     `json:"processed_count"`
	SyncedCount    int64     `json:"synced_count"`
	FailedCount    int64     `json:"failed_count"`
	StartTime      time.Time `json:"start_time"`
	EstimatedTime  string    `json:"estimated_time"`
	CurrentBatch   int       `json:"current_batch"`
	TotalBatches   int       `json:"total_batches"`
	ErrorMessage   string    `json:"error_message"`
}

SyncProgress 同步进度

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL