service

type Aggregator interface {
	Append(score float64)
	Result() map[entity.AggregatorType]*entity.AggregateData
}

type AggregatorGroup struct {
	Aggregators []Aggregator
}

type BasicAggregator struct {
	Max float64
	Min float64
	Sum float64

	Count int // Number of aggregated data
}

type BucketScoreDistributionAggregator struct {
	Scores     []float64 // Store all scores for bucket calculation in Result()
	Min        float64   // Minimum score value
	Max        float64   // Maximum score value
	Total      int64     // Total number of scores
	NumBuckets int       // Number of buckets
}

type CategoricalAggregator interface {
	Append(option string)
	Result() map[entity.AggregatorType]*entity.AggregateData
}

type CategoricalAggregatorGroup struct {
	Aggregators         []CategoricalAggregator
	AggregatorResultMap map[entity.AggregatorType]*entity.AggregateData
}

type CodeBuilderFactory interface {
	// CreateBuilder 根据语言类型创建代码构建器
	CreateBuilder(languageType entity.LanguageType) (UserCodeBuilder, error)
	// GetSupportedLanguages 获取支持的语言类型列表
	GetSupportedLanguages() []entity.LanguageType
	// SetRuntimeManager 设置运行时管理器（用于依赖注入runtime）
	SetRuntimeManager(manager component.IRuntimeManager)
}

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

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

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

type DefaultURLProcessor struct{}

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

type EvaluationSetItemService interface {
	BatchCreateEvaluationSetItems(ctx context.Context, param *entity.BatchCreateEvaluationSetItemsParam) (idMap map[int64]int64, errors []*entity.ItemErrorGroup, itemOutputs []*entity.DatasetItemOutput, err error)
	UpdateEvaluationSetItem(ctx context.Context, spaceID, evaluationSetID, itemID int64, turns []*entity.Turn) (err error)
	BatchUpdateEvaluationSetItems(ctx context.Context, param *entity.BatchUpdateEvaluationSetItemsParam) (errors []*entity.ItemErrorGroup, itemOutputs []*entity.DatasetItemOutput, err error)
	BatchDeleteEvaluationSetItems(ctx context.Context, spaceID, evaluationSetID int64, itemIDs []int64) (err error)
	ListEvaluationSetItems(ctx context.Context, param *entity.ListEvaluationSetItemsParam) (items []*entity.EvaluationSetItem, total *int64, filterTotal *int64, nextPageToken *string, err error)
	BatchGetEvaluationSetItems(ctx context.Context, param *entity.BatchGetEvaluationSetItemsParam) (items []*entity.EvaluationSetItem, err error)
	ClearEvaluationSetDraftItem(ctx context.Context, spaceID, evaluationSetID int64) (err error)
	GetEvaluationSetItemField(ctx context.Context, param *entity.GetEvaluationSetItemFieldParam) (fieldData *entity.FieldData, err error)
}

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

type EvaluationSetSchemaService interface {
	UpdateEvaluationSetSchema(ctx context.Context, spaceID, evaluationSetID int64, fieldSchema []*entity.FieldSchema) (err error)
}

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

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

type EvaluationSetVersionService interface {
	CreateEvaluationSetVersion(ctx context.Context, param *entity.CreateEvaluationSetVersionParam) (id int64, err error)
	GetEvaluationSetVersion(ctx context.Context, spaceID, versionID int64, deletedAt *bool) (version *entity.EvaluationSetVersion, set *entity.EvaluationSet, err error)
	ListEvaluationSetVersions(ctx context.Context, param *entity.ListEvaluationSetVersionsParam) (sets []*entity.EvaluationSetVersion, total *int64, nextCursor *string, err error)
	BatchGetEvaluationSetVersions(ctx context.Context, spaceID *int64, evaluationSetIDs []int64, deletedAt *bool) (sets []*entity.BatchGetEvaluationSetVersionsResult, err error)
}

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

type EvaluatorRecordService interface {
	// CorrectEvaluatorRecord 创建 evaluator_version 运行结果
	CorrectEvaluatorRecord(ctx context.Context, evaluatorRecordDO *entity.EvaluatorRecord, correctionDO *entity.Correction) error
	// GetEvaluatorRecord 按 id 查询单个 evaluator_version 运行结果
	GetEvaluatorRecord(ctx context.Context, evaluatorRecordID int64, includeDeleted bool) (*entity.EvaluatorRecord, error)
	// BatchGetEvaluatorRecord 按 id 批量查询 evaluator_version 运行结果
	BatchGetEvaluatorRecord(ctx context.Context, evaluatorRecordIDs []int64, includeDeleted bool) ([]*entity.EvaluatorRecord, error)
}

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

type EvaluatorService interface {
	// ListEvaluator 按查询条件查询 evaluator_version
	ListEvaluator(ctx context.Context, request *entity.ListEvaluatorRequest) ([]*entity.Evaluator, int64, error)
	// ListBuiltinEvaluator 查询内置评估器
	ListBuiltinEvaluator(ctx context.Context, request *entity.ListBuiltinEvaluatorRequest) ([]*entity.Evaluator, int64, error)
	// BatchGetEvaluator 按 id 批量查询 evaluator_version
	BatchGetEvaluator(ctx context.Context, spaceID int64, evaluatorIDs []int64, includeDeleted bool) ([]*entity.Evaluator, error)
	// GetEvaluator 按 id 单个查询 evaluator_version
	GetEvaluator(ctx context.Context, spaceID, evaluatorID int64, includeDeleted bool) (*entity.Evaluator, error)
	// CreateEvaluator 创建 evaluator_version
	CreateEvaluator(ctx context.Context, evaluator *entity.Evaluator, cid string) (int64, error)
	// UpdateEvaluatorMeta 修改评估器元信息（支持 builtin/benchmark/vendor 可选更新）
	UpdateEvaluatorMeta(ctx context.Context, req *entity.UpdateEvaluatorMetaRequest) error
	// UpdateBuiltinEvaluatorTags 更新内置评估器的标签（按 evaluator_id 全量对齐）
	UpdateBuiltinEvaluatorTags(ctx context.Context, evaluatorID int64, tags map[entity.EvaluatorTagLangType]map[entity.EvaluatorTagKey][]string) error
	// UpdateEvaluatorDraft 修改 evaluator_version draft
	UpdateEvaluatorDraft(ctx context.Context, versionDO *entity.Evaluator) error
	// DeleteEvaluator 删除 evaluator_version
	DeleteEvaluator(ctx context.Context, evaluatorIDs []int64, userID string) error
	// RunEvaluator evaluator_version 运行
	RunEvaluator(ctx context.Context, request *entity.RunEvaluatorRequest) (*entity.EvaluatorRecord, error)
	// DebugEvaluator 调试 evaluator_version；新增 exptSpaceID 作为实验空间ID
	DebugEvaluator(ctx context.Context, evaluatorDO *entity.Evaluator, inputData *entity.EvaluatorInputData, evaluatorRunConf *entity.EvaluatorRunConfig, exptSpaceID int64) (*entity.EvaluatorOutputData, error)
	// GetBuiltinEvaluator 根据 evaluatorID 查询元信息，若为预置评估器则按 builtin_visible_version 组装返回
	// 非预置评估器则返回nil
	GetBuiltinEvaluator(ctx context.Context, evaluatorID int64) (*entity.Evaluator, error)
	// BatchGetBuiltinEvaluator 批量获取预置评估器（按 visible 版本）
	BatchGetBuiltinEvaluator(ctx context.Context, evaluatorIDs []int64) ([]*entity.Evaluator, error)
	// BatchGetEvaluatorByIDAndVersion 批量根据 (evaluator_id, version) 查询具体版本
	BatchGetEvaluatorByIDAndVersion(ctx context.Context, pairs [][2]interface{}) ([]*entity.Evaluator, error)
	// GetEvaluatorVersion 按 version id 单个查询 evaluator_version version
	// withTags=true 时查询并回填标签（用于内置评估器），需传入 spaceID；否则查询普通评估器
	GetEvaluatorVersion(ctx context.Context, spaceID *int64, evaluatorVersionID int64, includeDeleted bool, withTags bool) (*entity.Evaluator, error)
	// BatchGetEvaluatorVersion 按 version id 批量查询 evaluator_version version
	BatchGetEvaluatorVersion(ctx context.Context, spaceID *int64, evaluatorVersionIDs []int64, includeDeleted bool) ([]*entity.Evaluator, error)
	// ListEvaluatorVersion 按条件查询 evaluator_version version
	ListEvaluatorVersion(ctx context.Context, request *entity.ListEvaluatorVersionRequest) (evaluatorVersions []*entity.Evaluator, total int64, err error)
	// SubmitEvaluatorVersion 提交 evaluator_version 版本
	SubmitEvaluatorVersion(ctx context.Context, evaluatorVersionDO *entity.Evaluator, version, description, cid string) (*entity.Evaluator, error)
	// CheckNameExist
	CheckNameExist(ctx context.Context, spaceID, evaluatorID int64, name string) (bool, error)
	// ListEvaluatorTags 根据 tagType 聚合标签，并按字母序返回
	ListEvaluatorTags(ctx context.Context, tagType entity.EvaluatorTagKeyType) (map[entity.EvaluatorTagKey][]string, error)
}

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

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

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

type EvaluatorSourceService interface {
	EvaluatorType() entity.EvaluatorType
	Run(ctx context.Context, evaluator *entity.Evaluator, input *entity.EvaluatorInputData, evaluatorRunConf *entity.EvaluatorRunConfig, exptSpaceID int64, disableTracing bool) (output *entity.EvaluatorOutputData, runStatus entity.EvaluatorRunStatus, traceID string)
	Debug(ctx context.Context, evaluator *entity.Evaluator, input *entity.EvaluatorInputData, evaluatorRunConf *entity.EvaluatorRunConfig, exptSpaceID int64) (output *entity.EvaluatorOutputData, err error)
	PreHandle(ctx context.Context, evaluator *entity.Evaluator) error
	// Validate 验证评估器
	Validate(ctx context.Context, evaluator *entity.Evaluator) error
}

type EvaluatorTemplateService interface {
	// CreateEvaluatorTemplate 创建评估器模板
	CreateEvaluatorTemplate(ctx context.Context, req *entity.CreateEvaluatorTemplateRequest) (*entity.CreateEvaluatorTemplateResponse, error)

	// UpdateEvaluatorTemplate 更新评估器模板
	UpdateEvaluatorTemplate(ctx context.Context, req *entity.UpdateEvaluatorTemplateRequest) (*entity.UpdateEvaluatorTemplateResponse, error)

	// DeleteEvaluatorTemplate 删除评估器模板
	DeleteEvaluatorTemplate(ctx context.Context, req *entity.DeleteEvaluatorTemplateRequest) (*entity.DeleteEvaluatorTemplateResponse, error)

	// GetEvaluatorTemplate 获取评估器模板详情
	GetEvaluatorTemplate(ctx context.Context, req *entity.GetEvaluatorTemplateRequest) (*entity.GetEvaluatorTemplateResponse, error)

	// ListEvaluatorTemplate 查询评估器模板列表
	ListEvaluatorTemplate(ctx context.Context, req *entity.ListEvaluatorTemplateRequest) (*entity.ListEvaluatorTemplateResponse, error)
}

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

type ExptAggrResultService interface {
	BatchGetExptAggrResultByExperimentIDs(ctx context.Context, spaceID int64, experimentIDs []int64) ([]*entity.ExptAggregateResult, error)
	// Calculate and persist aggregate results upon experiment completion.
	// Note: consider timing issues when updating scores.
	CreateExptAggrResult(ctx context.Context, spaceID, experimentID int64) error
	// Update aggregate results upon manual score correction.
	UpdateExptAggrResult(ctx context.Context, param *entity.UpdateExptAggrResultParam) error
	CreateAnnotationAggrResult(ctx context.Context, param *entity.CreateSpecificFieldAggrResultParam) error
	UpdateAnnotationAggrResult(ctx context.Context, param *entity.UpdateExptAggrResultParam) (err error)
	PublishExptAggrResultEvent(ctx context.Context, event *entity.AggrCalculateEvent, duration *time.Duration) error
}

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

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

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

type ExptCheckFn = func(ctx context.Context, expt *entity.Experiment, session *entity.Session) error

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

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

type ExptItemEvalCtxExecutor struct {
	TurnResultRepo repo.IExptTurnResultRepo
	ItemResultRepo repo.IExptItemResultRepo
	Configer       component.IConfiger
	Metric         metrics.ExptMetric
	// contains filtered or unexported fields
}

type ExptItemEvalEvent interface {
	Eval(ctx context.Context, event *entity.ExptItemEvalEvent) error
}

type ExptItemEvaluation interface {
	Eval(ctx context.Context, eiec *entity.ExptItemEvalCtx) error
}

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

type ExptItemTurnEvaluation interface {
	Eval(ctx context.Context, etec *entity.ExptTurnEvalCtx) *entity.ExptTurnRunResult
}

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

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

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

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

type ExptResultBuilder struct {
	ExptID                    int64
	BaselineExptID            int64
	SpaceID                   int64
	ItemIDs                   []int64        // 基准实验的itemID, 未匹配的不展示
	TurnIDMap                 map[int64]bool // 由于是itemID查询，对于多轮需要用turnID过滤. 对于单轮长度为0
	ItemIDTurnID2TurnResultID map[int64]map[int64]int64

	// 错误信息
	Err error

	ExperimentRepo     repo.IExperimentRepo
	ExptTurnResultRepo repo.IExptTurnResultRepo
	ExptAnnotateRepo   repo.IExptAnnotateRepo

	// 控制是否保留 trajectory 字段
	FullTrajectory bool
	// contains filtered or unexported fields
}

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

type ExptResultService interface {
	MGetExperimentResult(ctx context.Context, param *entity.MGetExperimentResultParam) (*entity.MGetExperimentReportResult, error)
	// RecordItemRunLogs sync results from run_log table to result table
	RecordItemRunLogs(ctx context.Context, exptID, exptRunID, itemID, spaceID int64) ([]*entity.ExptTurnEvaluatorResultRef, error)
	GetExptItemTurnResults(ctx context.Context, exptID, itemID, spaceID int64, session *entity.Session) ([]*entity.ExptTurnResult, error)

	CreateStats(ctx context.Context, exptStats *entity.ExptStats, session *entity.Session) error
	GetStats(ctx context.Context, exptID, spaceID int64, session *entity.Session) (*entity.ExptStats, error)
	MGetStats(ctx context.Context, exptIDs []int64, spaceID int64, session *entity.Session) ([]*entity.ExptStats, error)
	CalculateStats(ctx context.Context, exptID, spaceID int64, session *entity.Session) (*entity.ExptCalculateStats, error)
	GetIncompleteTurns(ctx context.Context, exptID, spaceID int64, session *entity.Session) ([]*entity.ItemTurnID, error)

	ManualUpsertExptTurnResultFilter(ctx context.Context, spaceID, exptID int64, itemIDs []int64) error
	UpsertExptTurnResultFilter(ctx context.Context, spaceID, exptID int64, itemID []int64) error
	InsertExptTurnResultFilterKeyMappings(ctx context.Context, mappings []*entity.ExptTurnResultFilterKeyMapping) error
	CompareExptTurnResultFilters(ctx context.Context, spaceID, exptID int64, itemIDs []int64, retryTimes int32) error
	// RecalculateWeightedScore 重新计算指定轮次的加权得分并更新到 expt_turn_result
	RecalculateWeightedScore(ctx context.Context, spaceID, exptID, itemID, turnID int64) error
}

type ExptResultServiceImpl struct {
	ExptItemResultRepo repo.IExptItemResultRepo
	ExptTurnResultRepo repo.IExptTurnResultRepo
	ExptStatsRepo      repo.IExptStatsRepo
	ExperimentRepo     repo.IExperimentRepo
	Metric             metrics.ExptMetric

	ExptAnnotateRepo repo.IExptAnnotateRepo
	// contains filtered or unexported fields
}

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

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

type ExptSchedulerEvent interface {
	Schedule(ctx context.Context, event *entity.ExptScheduleEvent) error
}

type ExptSchedulerImpl struct {
	Manager            IExptManager
	ExptRepo           repo.IExperimentRepo
	Publisher          events.ExptEventPublisher
	ExptItemResultRepo repo.IExptItemResultRepo
	ExptTurnResultRepo repo.IExptTurnResultRepo
	ExptStatsRepo      repo.IExptStatsRepo
	ExptRunLogRepo     repo.IExptRunLogRepo
	Idem               idem.IdempotentService
	Configer           component.IConfiger
	QuotaRepo          repo.QuotaRepo
	Mutex              lock.ILocker
	AuditClient        audit.IAuditService
	Metric             metrics.ExptMetric
	Endpoints          SchedulerEndPoint
	ResultSvc          ExptResultService
	IDGen              idgen.IIDGenerator
	// contains filtered or unexported fields
}

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

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

type IEvalTargetService interface {
	CreateEvalTarget(ctx context.Context, spaceID int64, sourceTargetID, sourceTargetVersion string, targetType entity.EvalTargetType, opts ...entity.Option) (id, versionID int64, err error)
	GetEvalTarget(ctx context.Context, targetID int64) (do *entity.EvalTarget, err error)
	GetEvalTargetVersion(ctx context.Context, spaceID, versionID int64, needSourceInfo bool) (do *entity.EvalTarget, err error)
	GetEvalTargetVersionBySource(ctx context.Context, spaceID, targetID int64, sourceVersion string, needSourceInfo bool) (do *entity.EvalTarget, err error)
	GetEvalTargetVersionByTarget(ctx context.Context, spaceID, targetID int64, sourceTargetVersion string, needSourceInfo bool) (do *entity.EvalTarget, err error)
	GetEvalTargetVersionBySourceTarget(ctx context.Context, spaceID int64, sourceTargetID, sourceTargetVersion string, targetType entity.EvalTargetType, needSourceInfo bool) (do *entity.EvalTarget, err error)
	BatchGetEvalTargetBySource(ctx context.Context, param *entity.BatchGetEvalTargetBySourceParam) (dos []*entity.EvalTarget, err error)
	BatchGetEvalTargetVersion(ctx context.Context, spaceID int64, versionIDs []int64, needSourceInfo bool) (dos []*entity.EvalTarget, err error)

	ExecuteTarget(ctx context.Context, spaceID int64, targetID int64, targetVersionID int64, param *entity.ExecuteTargetCtx, inputData *entity.EvalTargetInputData) (*entity.EvalTargetRecord, error)
	AsyncExecuteTarget(ctx context.Context, spaceID int64, targetID int64, targetVersionID int64, param *entity.ExecuteTargetCtx, inputData *entity.EvalTargetInputData) (record *entity.EvalTargetRecord, callee string, err error)
	DebugTarget(ctx context.Context, param *entity.DebugTargetParam) (record *entity.EvalTargetRecord, err error)
	AsyncDebugTarget(ctx context.Context, param *entity.DebugTargetParam) (record *entity.EvalTargetRecord, callee string, err error)
	GetRecordByID(ctx context.Context, spaceID int64, recordID int64) (*entity.EvalTargetRecord, error)
	CreateRecord(ctx context.Context, record *entity.EvalTargetRecord) error
	BatchGetRecordByIDs(ctx context.Context, spaceID int64, recordIDs []int64) ([]*entity.EvalTargetRecord, error)
	ReportInvokeRecords(ctx context.Context, recordID2Params *entity.ReportTargetRecordParam) error
	ValidateRuntimeParam(ctx context.Context, targetType entity.EvalTargetType, runtimeParam string) error
	GenerateMockOutputData(outputSchemas []*entity.ArgsSchema) (map[string]string, error)
	ExtractTrajectory(ctx context.Context, spaceID int64, traceID string, startTimeMS *int64) (*entity.Trajectory, error)
}

type IEvaluationAnalysisService interface {
	GetAnalysisRecord(ctx context.Context, id, spaceID int64) (record *entity.AnalysisRecord, err error)
	BatchGetAnalysisRecordByUniqueKeys(ctx context.Context, uniqueKey []string) (record map[string]*entity.AnalysisRecord, err error) // 批量获取
	TrajectoryAnalysis(ctx context.Context, param TrajectoryAnalysisParam) (recordID int64, err error)
}

type IEvaluationSetService interface {
	CreateEvaluationSet(ctx context.Context, param *entity.CreateEvaluationSetParam) (id int64, err error)
	CreateEvaluationSetWithImport(ctx context.Context, param *entity.CreateEvaluationSetWithImportParam) (id int64, jobID int64, err error)
	ParseImportSourceFile(ctx context.Context, param *entity.ParseImportSourceFileParam) (*entity.ParseImportSourceFileResult, error)
	UpdateEvaluationSet(ctx context.Context, param *entity.UpdateEvaluationSetParam) (err error)
	DeleteEvaluationSet(ctx context.Context, spaceID, evaluationSetID int64) (err error)
	GetEvaluationSet(ctx context.Context, spaceID *int64, evaluationSetID int64, deletedAt *bool) (set *entity.EvaluationSet, err error)
	BatchGetEvaluationSets(ctx context.Context, spaceID *int64, evaluationSetID []int64, deletedAt *bool) (set []*entity.EvaluationSet, err error)
	ListEvaluationSets(ctx context.Context, param *entity.ListEvaluationSetsParam) (sets []*entity.EvaluationSet, total *int64, nextPageToken *string, err error)
	QueryItemSnapshotMappings(ctx context.Context, spaceID, datasetID int64, versionID *int64) (fieldMappings []*entity.ItemSnapshotFieldMapping, syncCkDate string, err error)
}

type IExptAnnotateService interface {
	CreateExptTurnResultTagRefs(ctx context.Context, refs []*entity.ExptTurnResultTagRef) error
	GetExptTurnResultTagRefs(ctx context.Context, exptID, spaceID int64) ([]*entity.ExptTurnResultTagRef, error)
	SaveAnnotateRecord(ctx context.Context, exptID, itemID, turnID int64, record *entity.AnnotateRecord) error
	UpdateAnnotateRecord(ctx context.Context, itemID, turnID int64, record *entity.AnnotateRecord) error
	GetAnnotateRecordsByIDs(ctx context.Context, spaceID int64, recordIDs []int64) ([]*entity.AnnotateRecord, error)
	DeleteExptTurnResultTagRef(ctx context.Context, exptID, spaceID, tagKeyID int64) error
}

type IExptConfigManager interface {
	CheckName(ctx context.Context, name string, spaceID int64, session *entity.Session) (bool, error)

	CreateExpt(ctx context.Context, req *entity.CreateExptParam, session *entity.Session) (*entity.Experiment, error)

	Update(ctx context.Context, expt *entity.Experiment, session *entity.Session) error
	Delete(ctx context.Context, exptID, spaceID int64, session *entity.Session) error
	MDelete(ctx context.Context, exptIDs []int64, spaceID int64, session *entity.Session) error

	List(ctx context.Context, page, pageSize int32, spaceID int64, filter *entity.ExptListFilter, orders []*entity.OrderBy, session *entity.Session) ([]*entity.Experiment, int64, error)
	ListExptRaw(ctx context.Context, page, pageSize int32, spaceID int64, filter *entity.ExptListFilter) ([]*entity.Experiment, int64, error)
	GetDetail(ctx context.Context, exptID, spaceID int64, session *entity.Session, opts ...entity.GetExptTupleOptionFn) (*entity.Experiment, error)
	MGetDetail(ctx context.Context, exptIDs []int64, spaceID int64, session *entity.Session) ([]*entity.Experiment, error)

	Get(ctx context.Context, exptID, spaceID int64, session *entity.Session) (*entity.Experiment, error)
	MGet(ctx context.Context, exptIDs []int64, spaceID int64, session *entity.Session) ([]*entity.Experiment, error)

	Clone(ctx context.Context, exptID, spaceID int64, session *entity.Session) (*entity.Experiment, error)
}

type IExptExecutionManager interface {
	CheckRun(ctx context.Context, expt *entity.Experiment, spaceID int64, session *entity.Session, opts ...entity.ExptRunCheckOptionFn) error
	Run(ctx context.Context, exptID, runID, spaceID int64, itemRetryNum int, session *entity.Session, runMode entity.ExptRunMode, ext map[string]string) error
	RetryItems(ctx context.Context, exptID, runID, spaceID int64, itemRetryNum int, itemIDs []int64, session *entity.Session, ext map[string]string) error

	Invoke(ctx context.Context, invokeExptReq *entity.InvokeExptReq) error
	Finish(ctx context.Context, exptID *entity.Experiment, exptRunID int64, session *entity.Session) error

	PendRun(ctx context.Context, exptID, exptRunID, spaceID int64, session *entity.Session) error
	PendExpt(ctx context.Context, exptID, spaceID int64, session *entity.Session, opts ...entity.CompleteExptOptionFn) error

	// IsCompletingRun returns true if the given run is currently in the completing phase.
	IsCompletingRun(ctx context.Context, exptID, exptRunID, spaceID int64) (bool, error)
	CompleteRun(ctx context.Context, exptID, exptRunID int64, spaceID int64, session *entity.Session, opts ...entity.CompleteExptOptionFn) error
	CompleteExpt(ctx context.Context, exptID, spaceID int64, session *entity.Session, opts ...entity.CompleteExptOptionFn) error
	// SetExptTerminating Set experiment/run_log status to "terminating".
	SetExptTerminating(ctx context.Context, exptID, exptRunID, spaceID int64, session *entity.Session) error

	LogRun(ctx context.Context, exptID, exptRunID int64, mode entity.ExptRunMode, spaceID int64, itemIDs []int64, session *entity.Session) error
	LogRetryItemsRun(ctx context.Context, exptID int64, mode entity.ExptRunMode, spaceID int64, itemIDs []int64, session *entity.Session) (int64, bool, error)
	GetRunLog(ctx context.Context, exptID, exptRunID, spaceID int64, session *entity.Session) (*entity.ExptRunLog, error)
}

type IExptInsightAnalysisService interface {
	CreateAnalysisRecord(ctx context.Context, record *entity.ExptInsightAnalysisRecord, session *entity.Session) (int64, error)
	GenAnalysisReport(ctx context.Context, spaceID, exptID, recordID, CreateAt int64) error
	GetAnalysisRecordByID(ctx context.Context, spaceID, exptID, recordID int64, session *entity.Session) (*entity.ExptInsightAnalysisRecord, error)
	ListAnalysisRecord(ctx context.Context, spaceID, exptID int64, page entity.Page, session *entity.Session) ([]*entity.ExptInsightAnalysisRecord, int64, error)
	DeleteAnalysisRecord(ctx context.Context, spaceID, exptID, recordID int64) error
	FeedbackExptInsightAnalysis(ctx context.Context, param *entity.ExptInsightAnalysisFeedbackParam) error
	ListExptInsightAnalysisFeedbackComment(ctx context.Context, spaceID, exptID, recordID int64, page entity.Page) ([]*entity.ExptInsightAnalysisFeedbackComment, int64, error)
	GetAnalysisRecordFeedbackVoteByUser(ctx context.Context, spaceID, exptID, recordID int64, session *entity.Session) (*entity.ExptInsightAnalysisFeedbackVote, error)
}

type IExptManager interface {
	IExptConfigManager
	IExptExecutionManager
}

type IExptResultExportService interface {
	ExportCSV(ctx context.Context, spaceID, exptID int64, session *entity.Session) (int64, error)
	DoExportCSV(ctx context.Context, spaceID, exptID int64, fileName string, withLogID bool) error
	HandleExportEvent(ctx context.Context, spaceID, exptID, exportID int64) (err error)
	UpdateExportRecord(ctx context.Context, exportRecord *entity.ExptResultExportRecord) error
	ListExportRecord(ctx context.Context, spaceID, exptID int64, page entity.Page) ([]*entity.ExptResultExportRecord, int64, error)
	GetExptExportRecord(ctx context.Context, spaceID, exportID int64) (*entity.ExptResultExportRecord, error)
}

type IExptTemplateManager interface {
	CheckName(ctx context.Context, name string, spaceID int64, session *entity.Session) (bool, error)
	Create(ctx context.Context, param *entity.CreateExptTemplateParam, session *entity.Session) (*entity.ExptTemplate, error)
	Get(ctx context.Context, templateID, spaceID int64, session *entity.Session) (*entity.ExptTemplate, error)
	MGet(ctx context.Context, templateIDs []int64, spaceID int64, session *entity.Session) ([]*entity.ExptTemplate, error)
	Update(ctx context.Context, param *entity.UpdateExptTemplateParam, session *entity.Session) (*entity.ExptTemplate, error)
	UpdateMeta(ctx context.Context, param *entity.UpdateExptTemplateMetaParam, session *entity.Session) (*entity.ExptTemplate, error)
	// adjustCount: 实验数量的增量（创建实验时为 +1，删除实验时为 -1，状态变更时为 0）
	UpdateExptInfo(ctx context.Context, templateID, spaceID int64, exptID int64, exptStatus entity.ExptStatus, adjustCount int64) error
	Delete(ctx context.Context, templateID, spaceID int64, session *entity.Session) error
	List(ctx context.Context, page, pageSize int32, spaceID int64, filter *entity.ExptTemplateListFilter, orderBys []*entity.OrderBy, session *entity.Session) ([]*entity.ExptTemplate, int64, error)
}

type ISourceEvalTargetOperateService interface {
	EvalType() entity.EvalTargetType
	// BuildBySource 根据source target构建eval target实体
	BuildBySource(ctx context.Context, spaceID int64, sourceTargetID, sourceTargetVersion string, opts ...entity.Option) (*entity.EvalTarget, error)
	// ListSource 查询source target列表
	ListSource(ctx context.Context, param *entity.ListSourceParam) (targets []*entity.EvalTarget, nextCursor string, hasMore bool, err error)
	// BatchGetSource 查询source target列表
	BatchGetSource(ctx context.Context, spaceID int64, ids []string) (targets []*entity.EvalTarget, err error)
	// ListSourceVersion 查询source target版本列表
	ListSourceVersion(ctx context.Context, param *entity.ListSourceVersionParam) (versions []*entity.EvalTargetVersion, nextCursor string, hasMore bool, err error)
	// PackSourceInfo 拼装源信息
	PackSourceInfo(ctx context.Context, spaceID int64, dos []*entity.EvalTarget) (err error)
	// PackSourceVersionInfo 拼装源版本信息
	PackSourceVersionInfo(ctx context.Context, spaceID int64, dos []*entity.EvalTarget) (err error)
	// ValidateInput
	ValidateInput(ctx context.Context, spaceID int64, inputSchema []*entity.ArgsSchema, input *entity.EvalTargetInputData) error
	// Execute
	Execute(ctx context.Context, spaceID int64, param *entity.ExecuteEvalTargetParam) (outputData *entity.EvalTargetOutputData, status entity.EvalTargetRunStatus, err error)
	AsyncExecute(ctx context.Context, spaceID int64, param *entity.ExecuteEvalTargetParam) (invokeID int64, callee string, err error)
	RuntimeParam() entity.IRuntimeParam
	// 搜索自定义评测对象
	SearchCustomEvalTarget(ctx context.Context, param *entity.SearchCustomEvalTargetParam) (targets []*entity.CustomEvalTarget, nextCursor string, hasMore bool, err error)
}

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