generated

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewExecutableSchema 

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type AddDataProcessInput 

type AddDataProcessInput struct {
	Name                  string                   `json:"name"`
	FileType              string                   `json:"file_type"`
	PreDataSetName        string                   `json:"pre_data_set_name"`
	PreDataSetVersion     string                   `json:"pre_data_set_version"`
	FileNames             []*FileItem              `json:"file_names,omitempty"`
	PostDataSetName       string                   `json:"post_data_set_name"`
	PostDataSetVersion    string                   `json:"post_data_set_version"`
	DataProcessConfigInfo []*DataProcessConfigItem `json:"data_process_config_info,omitempty"`
	VersionDataSetName    string                   `json:"version_data_set_name"`
	Namespace             string                   `json:"namespace"`
	Creator               string                   `json:"creator"`
}

type AllDataProcessListByCountInput 

type AllDataProcessListByCountInput struct {
	Keyword   string `json:"keyword"`
	Namespace string `json:"namespace"`
}

type AllDataProcessListByPageInput 

type AllDataProcessListByPageInput struct {
	PageIndex int    `json:"pageIndex"`
	PageSize  int    `json:"pageSize"`
	Keyword   string `json:"keyword"`
	Namespace string `json:"namespace"`
}

type Application 

type Application struct {
	Metadata *ApplicationMetadata `json:"metadata,omitempty"`
	// 对话开场白
	Prologue *string `json:"prologue,omitempty"`
	// model 指具体使用的模型名称，比如 gpt-3.5-turbo 或者 chatglm_turbo
	Model *string `json:"model,omitempty"`
	// llm 指当前知识库应用使用的模型服务，即 Kind 为 LLM 的 CR 的名称
	Llm string `json:"llm"`
	// temperature 温度
	Temperature *float64 `json:"temperature,omitempty"`
	// maxLength 最大响应长度
	MaxLength *int `json:"maxLength,omitempty"`
	// maxTokens 最大输出token
	MaxTokens *int `json:"maxTokens,omitempty"`
	// conversionWindowSize 对话轮次
	ConversionWindowSize *int `json:"conversionWindowSize,omitempty"`
	// knowledgebase 指当前知识库应用使用的知识库，即 Kind 为 KnowledgeBase 的 CR 的名称，目前一个应用只支持0或1个知识库
	Knowledgebase *string `json:"knowledgebase,omitempty"`
	// scoreThreshold 最终返回结果的最低相似度
	ScoreThreshold *float64 `json:"scoreThreshold,omitempty"`
	// numDocuments  最终返回结果的引用上限
	NumDocuments *int `json:"numDocuments,omitempty"`
	// docNullReturn 空搜索回复
	DocNullReturn *string `json:"docNullReturn,omitempty"`
	// userPrompt 用户级别的 Prompt
	UserPrompt *string `json:"userPrompt,omitempty"`
	// systemPrompt 系统级别的 Prompt
	SystemPrompt *string `json:"systemPrompt,omitempty"`
	// showRespInfo 查看关联信息配置，即是否在chat界面显示关联信息
	ShowRespInfo *bool `json:"showRespInfo,omitempty"`
	// showRetrievalInfo 查看引用配置，即是否在chat界面显示引用信息
	ShowRetrievalInfo *bool `json:"showRetrievalInfo,omitempty"`
	// showNextGuide 下一步引导，即是否在chat界面显示下一步引导
	ShowNextGuide *bool `json:"showNextGuide,omitempty"`
	// tools 要使用的工具列表
	Tools []*Tool `json:"tools,omitempty"`
	// enableRerank 是否启用 rerank
	EnableRerank *bool `json:"enableRerank,omitempty"`
	// rerankModel rerank 模型，enableRerank 为 true 时起效，为空时使用默认 rerank 模型
	RerankModel *string `json:"rerankModel,omitempty"`
	// enableMultiQuery 是否启用多查询
	EnableMultiQuery *bool `json:"enableMultiQuery,omitempty"`
	// chatTimeout 对话超时，单位秒，不填为默认 60s
	ChatTimeout *float64 `json:"chatTimeout,omitempty"`
	// enableUploadFile 是否开启对话上传文档功能
	EnableUploadFile *bool `json:"enableUploadFile,omitempty"`
	// chunkSize 上传文档做文档拆分时的块大小
	ChunkSize *int `json:"chunkSize,omitempty"`
	// chunkOverlap 上传文档作文档拆分时相邻块的交集
	ChunkOverlap *int `json:"chunkOverlap,omitempty"`
	// batchSize 上传文档做批量处理时的批次大小
	BatchSize *int `json:"batchSize,omitempty"`
}

Application 应用完整信息

type ApplicationMetadata 

type ApplicationMetadata struct {
	// 应用名称
	// 规则: 遵循 k8s 命名
	Name string `json:"name"`
	// 应用所在的 namespace
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 应用id，为CR资源中的metadata.uid
	ID *string `json:"id,omitempty"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 展示名，别名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// Icon，应用头像， base64格式的图片
	Icon *string `json:"icon,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 更新时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
	// IsPublic, 是否发布，即是否公开提供服务
	IsPublic *bool `json:"isPublic,omitempty"`
	// isRecommended, 是否推荐
	IsRecommended *bool `json:"isRecommended,omitempty"`
	// 应用状态
	Status *string `json:"status,omitempty"`
	// category：所属分类
	Category []*string `json:"category,omitempty"`
	// notReadyReasonCode: 用于指明当前应用状态不正常的原因。状态码要和gpts中同字段保持一致。
	// 可选值:
	// - 空：就绪，应用 可以使用
	// - VectorStoreIsNotReady: 向量数据库没有就绪
	// - EmbedderIsNotReady: embedder服务没有就绪
	// - KnowledgeBaseNotReady: 知识库未就绪，指向量数据库和embedder出错之外的其他情况
	// - LLMNotReady: 模型服务没有就绪
	// - ConfigError: 应用配置错误，比如写了多个Output节点，比如节点名称重复等其他错误
	NotReadyReasonCode *string `json:"notReadyReasonCode,omitempty"`
}

Application 应用 Metadata

func (ApplicationMetadata) IsPageNode 

func (ApplicationMetadata) IsPageNode()

type ApplicationMutation 

type ApplicationMutation struct {
	CreateApplication       ApplicationMetadata `json:"createApplication"`
	UpdateApplication       ApplicationMetadata `json:"updateApplication"`
	DeleteApplication       *string             `json:"deleteApplication,omitempty"`
	UpdateApplicationConfig Application         `json:"updateApplicationConfig"`
}

type ApplicationMutationResolver 

type ApplicationMutationResolver interface {
	CreateApplication(ctx context.Context, obj *ApplicationMutation, input CreateApplicationMetadataInput) (*ApplicationMetadata, error)
	UpdateApplication(ctx context.Context, obj *ApplicationMutation, input UpdateApplicationMetadataInput) (*ApplicationMetadata, error)
	DeleteApplication(ctx context.Context, obj *ApplicationMutation, input DeleteCommonInput) (*string, error)
	UpdateApplicationConfig(ctx context.Context, obj *ApplicationMutation, input UpdateApplicationConfigInput) (*Application, error)
}

type ApplicationQuery 

type ApplicationQuery struct {
	GetApplication          Application     `json:"getApplication"`
	ListApplicationMetadata PaginatedResult `json:"listApplicationMetadata"`
}

type ApplicationQueryResolver 

type ApplicationQueryResolver interface {
	GetApplication(ctx context.Context, obj *ApplicationQuery, name string, namespace string) (*Application, error)
	ListApplicationMetadata(ctx context.Context, obj *ApplicationQuery, input ListCommonInput) (*PaginatedResult, error)
}

type CheckDataProcessTaskNameInput 

type CheckDataProcessTaskNameInput struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
}

type ComplexityRoot 

type ComplexityRoot struct {
	Application struct {
		BatchSize            func(childComplexity int) int
		ChatTimeout          func(childComplexity int) int
		ChunkOverlap         func(childComplexity int) int
		ChunkSize            func(childComplexity int) int
		ConversionWindowSize func(childComplexity int) int
		DocNullReturn        func(childComplexity int) int
		EnableMultiQuery     func(childComplexity int) int
		EnableRerank         func(childComplexity int) int
		EnableUploadFile     func(childComplexity int) int
		Knowledgebase        func(childComplexity int) int
		Llm                  func(childComplexity int) int
		MaxLength            func(childComplexity int) int
		MaxTokens            func(childComplexity int) int
		Metadata             func(childComplexity int) int
		Model                func(childComplexity int) int
		NumDocuments         func(childComplexity int) int
		Prologue             func(childComplexity int) int
		RerankModel          func(childComplexity int) int
		ScoreThreshold       func(childComplexity int) int
		ShowNextGuide        func(childComplexity int) int
		ShowRespInfo         func(childComplexity int) int
		ShowRetrievalInfo    func(childComplexity int) int
		SystemPrompt         func(childComplexity int) int
		Temperature          func(childComplexity int) int
		Tools                func(childComplexity int) int
		UserPrompt           func(childComplexity int) int
	}

	ApplicationMetadata struct {
		Annotations        func(childComplexity int) int
		Category           func(childComplexity int) int
		CreationTimestamp  func(childComplexity int) int
		Creator            func(childComplexity int) int
		Description        func(childComplexity int) int
		DisplayName        func(childComplexity int) int
		ID                 func(childComplexity int) int
		Icon               func(childComplexity int) int
		IsPublic           func(childComplexity int) int
		IsRecommended      func(childComplexity int) int
		Labels             func(childComplexity int) int
		Name               func(childComplexity int) int
		Namespace          func(childComplexity int) int
		NotReadyReasonCode func(childComplexity int) int
		Status             func(childComplexity int) int
		UpdateTimestamp    func(childComplexity int) int
	}

	ApplicationMutation struct {
		CreateApplication       func(childComplexity int, input CreateApplicationMetadataInput) int
		DeleteApplication       func(childComplexity int, input DeleteCommonInput) int
		UpdateApplication       func(childComplexity int, input UpdateApplicationMetadataInput) int
		UpdateApplicationConfig func(childComplexity int, input UpdateApplicationConfigInput) int
	}

	ApplicationQuery struct {
		GetApplication          func(childComplexity int, name string, namespace string) int
		ListApplicationMetadata func(childComplexity int, input ListCommonInput) int
	}

	CountDataProcessItem struct {
		Data    func(childComplexity int) int
		Message func(childComplexity int) int
		Status  func(childComplexity int) int
	}

	DataProcessConfig struct {
		Children    func(childComplexity int) int
		Description func(childComplexity int) int
		FileNum     func(childComplexity int) int
		Name        func(childComplexity int) int
		Status      func(childComplexity int) int
	}

	DataProcessConfigChildren struct {
		ChunkOverlap func(childComplexity int) int
		ChunkSize    func(childComplexity int) int
		Description  func(childComplexity int) int
		Enable       func(childComplexity int) int
		FileProgress func(childComplexity int) int
		LlmConfig    func(childComplexity int) int
		Name         func(childComplexity int) int
		Preview      func(childComplexity int) int
		ZhName       func(childComplexity int) int
	}

	DataProcessConfigInfo struct {
		LlmConfig             func(childComplexity int) int
		RemoveDuplicateConfig func(childComplexity int) int
		Type                  func(childComplexity int) int
	}

	DataProcessConfigpreFileProgress struct {
		EndTime   func(childComplexity int) int
		FileName  func(childComplexity int) int
		ID        func(childComplexity int) int
		Progress  func(childComplexity int) int
		StartTime func(childComplexity int) int
		Status    func(childComplexity int) int
	}

	DataProcessConfigpreView struct {
		Content  func(childComplexity int) int
		FileName func(childComplexity int) int
	}

	DataProcessConfigpreViewContent struct {
		Post func(childComplexity int) int
		Pre  func(childComplexity int) int
	}

	DataProcessDetails struct {
		Data    func(childComplexity int) int
		Message func(childComplexity int) int
		Status  func(childComplexity int) int
	}

	DataProcessDetailsItem struct {
		Config                func(childComplexity int) int
		Creator               func(childComplexity int) int
		DataProcessConfigInfo func(childComplexity int) int
		EndTime               func(childComplexity int) int
		ErrorMsg              func(childComplexity int) int
		FileDetails           func(childComplexity int) int
		FileNum               func(childComplexity int) int
		FileType              func(childComplexity int) int
		ID                    func(childComplexity int) int
		Name                  func(childComplexity int) int
		PostDatasetName       func(childComplexity int) int
		PostDatasetVersion    func(childComplexity int) int
		PreDatasetName        func(childComplexity int) int
		PreDatasetVersion     func(childComplexity int) int
		StartTime             func(childComplexity int) int
		Status                func(childComplexity int) int
	}

	DataProcessItem struct {
		EndDatetime        func(childComplexity int) int
		ErrorMsg           func(childComplexity int) int
		ID                 func(childComplexity int) int
		Name               func(childComplexity int) int
		PostDataSetName    func(childComplexity int) int
		PostDataSetVersion func(childComplexity int) int
		PreDataSetName     func(childComplexity int) int
		PreDataSetVersion  func(childComplexity int) int
		StartDatetime      func(childComplexity int) int
		Status             func(childComplexity int) int
	}

	DataProcessMutation struct {
		CreateDataProcessTask func(childComplexity int, input *AddDataProcessInput) int
		DeleteDataProcessTask func(childComplexity int, input *DeleteDataProcessInput) int
	}

	DataProcessQuery struct {
		AllDataProcessListByCount    func(childComplexity int, input *AllDataProcessListByCountInput) int
		AllDataProcessListByPage     func(childComplexity int, input *AllDataProcessListByPageInput) int
		CheckDataProcessTaskName     func(childComplexity int, input *CheckDataProcessTaskNameInput) int
		DataProcessDetails           func(childComplexity int, input *DataProcessDetailsInput) int
		DataProcessLogInfoByFileName func(childComplexity int, input *DataProcessFileLogInput) int
		DataProcessRetry             func(childComplexity int, input *DataProcessRetryInput) int
		DataProcessSupportType       func(childComplexity int) int
		GetLogInfo                   func(childComplexity int, input *DataProcessDetailsInput) int
	}

	DataProcessResponse struct {
		Data    func(childComplexity int) int
		Message func(childComplexity int) int
		Status  func(childComplexity int) int
	}

	DataProcessSupportType struct {
		Data    func(childComplexity int) int
		Message func(childComplexity int) int
		Status  func(childComplexity int) int
	}

	DataProcessSupportTypeChildren struct {
		Description func(childComplexity int) int
		Enable      func(childComplexity int) int
		Name        func(childComplexity int) int
		ZhName      func(childComplexity int) int
	}

	DataProcessSupportTypeItem struct {
		Children    func(childComplexity int) int
		Description func(childComplexity int) int
		Name        func(childComplexity int) int
	}

	Dataset struct {
		Annotations       func(childComplexity int) int
		ContentType       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		Field             func(childComplexity int) int
		Labels            func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
		Versions          func(childComplexity int, input ListVersionedDatasetInput) int
	}

	DatasetMutation struct {
		CreateDataset  func(childComplexity int, input *CreateDatasetInput) int
		DeleteDatasets func(childComplexity int, input *DeleteCommonInput) int
		UpdateDataset  func(childComplexity int, input *UpdateDatasetInput) int
	}

	DatasetQuery struct {
		GetDataset   func(childComplexity int, name string, namespace string) int
		ListDatasets func(childComplexity int, input *ListDatasetInput) int
	}

	Datasource struct {
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		Endpoint          func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		Message           func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Oss               func(childComplexity int) int
		Pg                func(childComplexity int) int
		Status            func(childComplexity int) int
		Type              func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
		Web               func(childComplexity int) int
	}

	DatasourceMutation struct {
		CreateDatasource  func(childComplexity int, input CreateDatasourceInput) int
		DeleteDatasources func(childComplexity int, input *DeleteCommonInput) int
		UpdateDatasource  func(childComplexity int, input *UpdateDatasourceInput) int
	}

	DatasourceQuery struct {
		CheckDatasource func(childComplexity int, input CreateDatasourceInput) int
		GetDatasource   func(childComplexity int, name string, namespace string) int
		ListDatasources func(childComplexity int, input ListCommonInput) int
	}

	Embedder struct {
		Annotations       func(childComplexity int) int
		BaseURL           func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		Message           func(childComplexity int) int
		Models            func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Provider          func(childComplexity int) int
		Status            func(childComplexity int) int
		Type              func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
	}

	EmbedderMutation struct {
		CreateEmbedder  func(childComplexity int, input CreateEmbedderInput) int
		DeleteEmbedders func(childComplexity int, input *DeleteCommonInput) int
		UpdateEmbedder  func(childComplexity int, input *UpdateEmbedderInput) int
	}

	EmbedderQuery struct {
		GetEmbedder   func(childComplexity int, name string, namespace string) int
		ListEmbedders func(childComplexity int, input ListCommonInput) int
	}

	Endpoint struct {
		AuthSecret func(childComplexity int) int
		Insecure   func(childComplexity int) int
		URL        func(childComplexity int) int
	}

	F struct {
		Count             func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		FileType          func(childComplexity int) int
		LatestVersion     func(childComplexity int) int
		Path              func(childComplexity int) int
		Size              func(childComplexity int) int
		Time              func(childComplexity int) int
		Versions          func(childComplexity int) int
	}

	FileDetails struct {
		EndTime   func(childComplexity int) int
		FileName  func(childComplexity int) int
		FileSize  func(childComplexity int) int
		StartTime func(childComplexity int) int
		Status    func(childComplexity int) int
	}

	FileWithVersion struct {
		Path    func(childComplexity int) int
		Version func(childComplexity int) int
	}

	GPT struct {
		Category           func(childComplexity int) int
		Creator            func(childComplexity int) int
		Description        func(childComplexity int) int
		DisplayName        func(childComplexity int) int
		EnableUploadFile   func(childComplexity int) int
		Hot                func(childComplexity int) int
		Icon               func(childComplexity int) int
		IsRecommended      func(childComplexity int) int
		Name               func(childComplexity int) int
		NotReadyReasonCode func(childComplexity int) int
		Prologue           func(childComplexity int) int
		ShowNextGuide      func(childComplexity int) int
		ShowRespInfo       func(childComplexity int) int
		ShowRetrievalInfo  func(childComplexity int) int
	}

	GPTCategory struct {
		ID     func(childComplexity int) int
		Name   func(childComplexity int) int
		NameEn func(childComplexity int) int
	}

	GPTQuery struct {
		GetGPTStore     func(childComplexity int) int
		GetGpt          func(childComplexity int, name string) int
		ListGPTCategory func(childComplexity int) int
		ListGpt         func(childComplexity int, input ListGPTInput) int
	}

	GPTStore struct {
		PublicNamespace func(childComplexity int) int
		URL             func(childComplexity int) int
	}

	KnowledgeBase struct {
		Annotations       func(childComplexity int) int
		BatchSize         func(childComplexity int) int
		ChunkOverlap      func(childComplexity int) int
		ChunkSize         func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		Embedder          func(childComplexity int) int
		EmbedderType      func(childComplexity int) int
		FileGroupDetails  func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		Message           func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Reason            func(childComplexity int) int
		Status            func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
		VectorStore       func(childComplexity int) int
	}

	KnowledgeBaseMutation struct {
		CreateKnowledgeBase func(childComplexity int, input CreateKnowledgeBaseInput) int
		DeleteKnowledgeBase func(childComplexity int, input *DeleteCommonInput) int
		UpdateKnowledgeBase func(childComplexity int, input *UpdateKnowledgeBaseInput) int
	}

	KnowledgeBaseQuery struct {
		GetKnowledgeBase   func(childComplexity int, name string, namespace string) int
		ListKnowledgeBases func(childComplexity int, input ListKnowledgeBaseInput) int
	}

	LLM struct {
		Annotations       func(childComplexity int) int
		BaseURL           func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		Message           func(childComplexity int) int
		Models            func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Provider          func(childComplexity int) int
		Status            func(childComplexity int) int
		Type              func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
	}

	LLMConfig struct {
		MaxTokens      func(childComplexity int) int
		Model          func(childComplexity int) int
		Name           func(childComplexity int) int
		Namespace      func(childComplexity int) int
		PromptTemplate func(childComplexity int) int
		Provider       func(childComplexity int) int
		Temperature    func(childComplexity int) int
		TopP           func(childComplexity int) int
	}

	LLMQuery struct {
		GetLlm   func(childComplexity int, name string, namespace string) int
		ListLLMs func(childComplexity int, input ListCommonInput) int
	}

	LabelSelectorRequirement struct {
		Key      func(childComplexity int) int
		Operator func(childComplexity int) int
		Values   func(childComplexity int) int
	}

	Model struct {
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		Files             func(childComplexity int, input *FileFilter) int
		HuggingFaceRepo   func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		Message           func(childComplexity int) int
		ModelScopeRepo    func(childComplexity int) int
		ModelSource       func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Revision          func(childComplexity int) int
		Status            func(childComplexity int) int
		SystemModel       func(childComplexity int) int
		Types             func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
	}

	ModelMutation struct {
		CreateModel  func(childComplexity int, input CreateModelInput) int
		DeleteModels func(childComplexity int, input *DeleteCommonInput) int
		UpdateModel  func(childComplexity int, input *UpdateModelInput) int
	}

	ModelQuery struct {
		GetModel   func(childComplexity int, name string, namespace string) int
		ListModels func(childComplexity int, input ListModelInput) int
	}

	ModelService struct {
		APIType           func(childComplexity int) int
		Annotations       func(childComplexity int) int
		BaseURL           func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		EmbeddingModels   func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		LlmModels         func(childComplexity int) int
		Message           func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		ProviderType      func(childComplexity int) int
		Status            func(childComplexity int) int
		Types             func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
	}

	ModelServiceMutation struct {
		CreateModelService func(childComplexity int, input CreateModelServiceInput) int
		DeleteModelService func(childComplexity int, input *DeleteCommonInput) int
		UpdateModelService func(childComplexity int, input *UpdateModelServiceInput) int
	}

	ModelServiceQuery struct {
		CheckModelService func(childComplexity int, input CreateModelServiceInput) int
		GetModelService   func(childComplexity int, name string, namespace string) int
		ListModelServices func(childComplexity int, input *ListModelServiceInput) int
	}

	Mutation struct {
		Application      func(childComplexity int) int
		DataProcess      func(childComplexity int) int
		Dataset          func(childComplexity int) int
		Datasource       func(childComplexity int) int
		Embedder         func(childComplexity int) int
		Hello            func(childComplexity int, name string) int
		KnowledgeBase    func(childComplexity int) int
		Model            func(childComplexity int) int
		ModelService     func(childComplexity int) int
		Rag              func(childComplexity int) int
		VersionedDataset func(childComplexity int) int
		Worker           func(childComplexity int) int
	}

	Node struct {
		Labels func(childComplexity int) int
		Name   func(childComplexity int) int
	}

	NodeQuery struct {
		ListNodes func(childComplexity int, input *ListNodeInput) int
	}

	NodeSelectorRequirement struct {
		Key      func(childComplexity int) int
		Operator func(childComplexity int) int
		Values   func(childComplexity int) int
	}

	Oss struct {
		Bucket func(childComplexity int) int
		Object func(childComplexity int) int
	}

	PaginatedDataProcessItem struct {
		Data    func(childComplexity int) int
		Message func(childComplexity int) int
		Status  func(childComplexity int) int
	}

	PaginatedResult struct {
		HasNextPage func(childComplexity int) int
		Nodes       func(childComplexity int) int
		Page        func(childComplexity int) int
		PageSize    func(childComplexity int) int
		TotalCount  func(childComplexity int) int
	}

	Parameter struct {
		Key   func(childComplexity int) int
		Value func(childComplexity int) int
	}

	PersistentVolumeClaimSpec struct {
		AccessModes      func(childComplexity int) int
		DataSourceRef    func(childComplexity int) int
		Datasource       func(childComplexity int) int
		Resources        func(childComplexity int) int
		Selector         func(childComplexity int) int
		StorageClassName func(childComplexity int) int
		VolumeMode       func(childComplexity int) int
		VolumeName       func(childComplexity int) int
	}

	Pg struct {
		Database func(childComplexity int) int
	}

	Query struct {
		Application      func(childComplexity int) int
		DataProcess      func(childComplexity int) int
		Dataset          func(childComplexity int) int
		Datasource       func(childComplexity int) int
		Embedder         func(childComplexity int) int
		Gpt              func(childComplexity int) int
		Hello            func(childComplexity int, name string) int
		KnowledgeBase    func(childComplexity int) int
		Llm              func(childComplexity int) int
		Model            func(childComplexity int) int
		ModelService     func(childComplexity int) int
		Node             func(childComplexity int) int
		Rag              func(childComplexity int) int
		RayCluster       func(childComplexity int) int
		VersionedDataset func(childComplexity int) int
		Worker           func(childComplexity int) int
	}

	RAG struct {
		Annotations        func(childComplexity int) int
		Application        func(childComplexity int) int
		CompleteTimestamp  func(childComplexity int) int
		CreationTimestamp  func(childComplexity int) int
		Creator            func(childComplexity int) int
		Datasets           func(childComplexity int) int
		Description        func(childComplexity int) int
		DisplayName        func(childComplexity int) int
		JudgeLlm           func(childComplexity int) int
		Labels             func(childComplexity int) int
		Metrics            func(childComplexity int) int
		Name               func(childComplexity int) int
		Namespace          func(childComplexity int) int
		Phase              func(childComplexity int) int
		PhaseMessage       func(childComplexity int) int
		ServiceAccountName func(childComplexity int) int
		Status             func(childComplexity int) int
		Storage            func(childComplexity int) int
		Suspend            func(childComplexity int) int
	}

	RAGDataset struct {
		Files  func(childComplexity int) int
		Source func(childComplexity int) int
	}

	RAGMetric struct {
		MetricKind          func(childComplexity int) int
		Parameters          func(childComplexity int) int
		ToleranceThreshbold func(childComplexity int) int
	}

	RAGMutation struct {
		CreateRag    func(childComplexity int, input CreateRAGInput) int
		DeleteRag    func(childComplexity int, input DeleteRAGInput) int
		DuplicateRag func(childComplexity int, input DuplicateRAGInput) int
		UpdateRag    func(childComplexity int, input UpdateRAGInput) int
	}

	RAGQuery struct {
		GetRag  func(childComplexity int, name string, namespace string) int
		ListRag func(childComplexity int, input ListRAGInput) int
	}

	RayCluster struct {
		DashboardHost func(childComplexity int) int
		HeadAddress   func(childComplexity int) int
		Index         func(childComplexity int) int
		Name          func(childComplexity int) int
		PythonVersion func(childComplexity int) int
	}

	RayClusterQuery struct {
		ListRayClusters func(childComplexity int, input ListCommonInput) int
	}

	RemoveDuplicateConfigItem struct {
		EmbeddingModel     func(childComplexity int) int
		EmbeddingName      func(childComplexity int) int
		EmbeddingNamespace func(childComplexity int) int
		EmbeddingProvider  func(childComplexity int) int
		Similarity         func(childComplexity int) int
	}

	Resource struct {
		Limits   func(childComplexity int) int
		Requests func(childComplexity int) int
	}

	Resources struct {
		CPU       func(childComplexity int) int
		Memory    func(childComplexity int) int
		NvidiaGpu func(childComplexity int) int
	}

	Selector struct {
		MatchExpressions func(childComplexity int) int
		MatchLabels      func(childComplexity int) int
	}

	Tool struct {
		Name   func(childComplexity int) int
		Params func(childComplexity int) int
	}

	TypedObjectReference struct {
		APIGroup    func(childComplexity int) int
		DisplayName func(childComplexity int) int
		Kind        func(childComplexity int) int
		Name        func(childComplexity int) int
		Namespace   func(childComplexity int) int
	}

	VersionedDataset struct {
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		DataProcessMsg    func(childComplexity int) int
		DataProcessStatus func(childComplexity int) int
		Dataset           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		Files             func(childComplexity int, input *FileFilter) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Released          func(childComplexity int) int
		SyncMsg           func(childComplexity int) int
		SyncStatus        func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
		Version           func(childComplexity int) int
	}

	VersionedDatasetMutation struct {
		CreateVersionedDataset  func(childComplexity int, input CreateVersionedDatasetInput) int
		DeleteVersionedDatasets func(childComplexity int, input DeleteVersionedDatasetInput) int
		UpdateVersionedDataset  func(childComplexity int, input UpdateVersionedDatasetInput) int
	}

	VersionedDatasetQuery struct {
		GetVersionedDataset   func(childComplexity int, name string, namespace string) int
		ListVersionedDatasets func(childComplexity int, input ListVersionedDatasetInput) int
	}

	Web struct {
		RecommendIntervalTime func(childComplexity int) int
	}

	Worker struct {
		API               func(childComplexity int) int
		AdditionalEnvs    func(childComplexity int) int
		Annotations       func(childComplexity int) int
		CreationTimestamp func(childComplexity int) int
		Creator           func(childComplexity int) int
		Description       func(childComplexity int) int
		DisplayName       func(childComplexity int) int
		ID                func(childComplexity int) int
		Labels            func(childComplexity int) int
		MatchExpressions  func(childComplexity int) int
		Message           func(childComplexity int) int
		Model             func(childComplexity int) int
		ModelTypes        func(childComplexity int) int
		Name              func(childComplexity int) int
		Namespace         func(childComplexity int) int
		Replicas          func(childComplexity int) int
		Resources         func(childComplexity int) int
		Status            func(childComplexity int) int
		Type              func(childComplexity int) int
		UpdateTimestamp   func(childComplexity int) int
	}

	WorkerMutation struct {
		CreateWorker  func(childComplexity int, input CreateWorkerInput) int
		DeleteWorkers func(childComplexity int, input *DeleteCommonInput) int
		UpdateWorker  func(childComplexity int, input *UpdateWorkerInput) int
	}

	WorkerQuery struct {
		GetWorker   func(childComplexity int, name string, namespace string) int
		ListWorkers func(childComplexity int, input ListWorkerInput) int
	}

	Filedetail struct {
		Count           func(childComplexity int) int
		FileType        func(childComplexity int) int
		LatestVersion   func(childComplexity int) int
		Path            func(childComplexity int) int
		Phase           func(childComplexity int) int
		Size            func(childComplexity int) int
		TimeCost        func(childComplexity int) int
		UpdateTimestamp func(childComplexity int) int
		Version         func(childComplexity int) int
	}

	Filegroup struct {
		Files  func(childComplexity int) int
		Path   func(childComplexity int) int
		Source func(childComplexity int) int
	}

	Filegroupdetail struct {
		Filedetails func(childComplexity int) int
		Source      func(childComplexity int) int
	}
}

type Config 

type Config struct {
	Schema     *ast.Schema
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type CountDataProcessItem 

type CountDataProcessItem struct {
	Status  int    `json:"status"`
	Data    int    `json:"data"`
	Message string `json:"message"`
}

type CreateApplicationMetadataInput 

type CreateApplicationMetadataInput struct {
	// 应用名称
	// 规则: 遵循 k8s 命名
	Name string `json:"name"`
	// 应用所在的namespace
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 展示名，别名
	DisplayName string `json:"displayName"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// Icon，应用头像， base64格式的图片
	Icon string `json:"icon"`
	// IsPublic, 是否发布，即是否公开提供服务
	IsPublic *bool `json:"isPublic,omitempty"`
	// isRecommended, 是否推荐
	IsRecommended *bool `json:"isRecommended,omitempty"`
	// category：所属分类
	Category []*string `json:"category,omitempty"`
}

type CreateDatasetInput 

type CreateDatasetInput struct {
	// 数据集的名字
	// 规则: k8s的名称规则
	// 规则: 非空
	Name string `json:"name"`
	// 数据集的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些标签选择信息，可以不添加
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 一些备注用的注视信息，或者记录一个简单的配置
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 展示名称
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息，可以不写
	Description *string `json:"description,omitempty"`
	// 数据集里面的数据的类型，文本，视频，图片
	ContentType string `json:"contentType"`
	// 应用场景，可以为空
	// 规则: enum{ xx xx } (非固定字段，以产品为准)
	Filed *string `json:"filed,omitempty"`
}

数据集创建的输入

type CreateDatasourceInput 

type CreateDatasourceInput struct {
	// 名字
	// 规则: k8s的名称规则
	// 规则: 非空
	Name string `json:"name"`
	// 数据源的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 数据源资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 数据源资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 数据源资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 数据源资源描述
	Description *string `json:"description,omitempty"`
	// 数据源的访问信息输入
	Endpointinput EndpointInput `json:"endpointinput"`
	// 数据源为对象存储类型时的输入
	Ossinput *OssInput `json:"ossinput,omitempty"`
	// 数据源为Postgresql时的输入
	Pginput *PgInput `json:"pginput,omitempty"`
	// 数据源为Web数据时的输入
	Webinput *WebInput `json:"webinput,omitempty"`
}

新增数据源时输入条件

type CreateEmbedderInput 

type CreateEmbedderInput struct {
	// 模型服务资源名称（不可同名）
	Name string `json:"name"`
	// 模型服务创建命名空间
	Namespace string `json:"namespace"`
	// 模型服务资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型服务资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型服务资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型服务资源描述
	Description *string `json:"description,omitempty"`
	// 模型服务访问信息(必填)
	Endpointinput EndpointInput `json:"endpointinput"`
	// 向量化模型服务接口类型
	// 规则:  目前支持 zhipuai,openai两种接口类型
	Type *string `json:"type,omitempty"`
	// 此Embedder支持调用的模型列表
	Models []string `json:"models,omitempty"`
}

type CreateKnowledgeBaseInput 

type CreateKnowledgeBaseInput struct {
	// 知识库资源名称（不可同名）
	Name string `json:"name"`
	// 知识库创建命名空间
	Namespace string `json:"namespace"`
	// 知识库资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 知识库资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 知识库资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 知识库资源描述
	Description *string `json:"description,omitempty"`
	// embedder指当前知识库使用的embedding向量化模型
	Embedder string `json:"embedder"`
	// "向量数据库(目前不需要填写，直接使用系统默认的向量数据库)
	VectorStore *TypedObjectReferenceInput `json:"vectorStore,omitempty"`
	// 知识库文件
	FileGroups []*Filegroupinput `json:"fileGroups,omitempty"`
	// chunkSize为知识库做文档拆分时的块大小
	ChunkSize *int `json:"chunkSize,omitempty"`
	// chunkOverlap为知识库作文档拆分时相邻块的交集
	ChunkOverlap *int `json:"chunkOverlap,omitempty"`
	// batchSize为知识库做批量处理时的批次大小
	BatchSize *int `json:"batchSize,omitempty"`
}

创建知识库的输入

type CreateLLMInput 

type CreateLLMInput struct {
	// 模型服务资源名称（不可同名）
	Name string `json:"name"`
	// 模型服务创建命名空间
	Namespace string `json:"namespace"`
	// 模型服务资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型服务资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型服务资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型服务资源描述
	Description *string `json:"description,omitempty"`
	// 模型服务访问信息(必填)
	Endpointinput EndpointInput `json:"endpointinput"`
	// 模型服务接口类型
	// 规则:  目前支持 zhipuai,openai两种接口类型
	Type *string `json:"type,omitempty"`
	// 此LLM支持调用的模型列表
	Models []string `json:"models,omitempty"`
}

type CreateModelInput 

type CreateModelInput struct {
	// 模型资源名称（不可同名）
	Name string `json:"name"`
	// 模型创建命名空间
	Namespace string `json:"namespace"`
	// 模型资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型资源描述
	Description *string `json:"description,omitempty"`
	// 模型类型
	// 规则: 目前支持 llm和embedding两种模型类型
	// 规则: 如果该模型支持多种模型类型，则可多选。多选后组成的字段通过逗号隔开。如 "llm,embedding"
	Types string `json:"types"`
	// 如果设置从modelscope或者hugginface拉取模型文件，这两个字段会返回模型名字。
	HuggingFaceRepo *string `json:"huggingFaceRepo,omitempty"`
	ModelScopeRepo  *string `json:"modelScopeRepo,omitempty"`
	// 返回模型选择的版本
	Revision *string `json:"revision,omitempty"`
	// local: 从本地的minio来。
	// modelscope: 从modelscope来
	// huggingface: 从huggingface来
	ModelSource *string `json:"modelSource,omitempty"`
}

创建模型的输入

type CreateModelServiceInput 

type CreateModelServiceInput struct {
	// 模型服务资源名称（不可同名）
	Name string `json:"name"`
	// 模型服务创建命名空间
	Namespace string `json:"namespace"`
	// 模型资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型资源描述
	Description *string `json:"description,omitempty"`
	// 模型服务能力类型，支持 llm 和 embedding 两种模型类型
	// 规则: 如果该模型支持多种模型类型，则可多选。多选后组成的字段通过逗号隔开。如 "llm,embedding"
	Types *string `json:"types,omitempty"`
	// 模型服务 API 类型
	// 规则：支持 openai, zhipuai 两种类型
	APIType *string `json:"apiType,omitempty"`
	// 模型服务终端输入
	Endpoint EndpointInput `json:"endpoint"`
	// 模型服务的大语言模型列表
	// 规则；如果不填或者为空，则按照模型的API类型获取默认的模型列表
	LlmModels []string `json:"llmModels,omitempty"`
	// 模型服务的Embedding模型列表
	// 规则；如果不填或者为空，则按照模型的API类型获取默认的模型列表
	EmbeddingModels []string `json:"embeddingModels,omitempty"`
}

type CreateRAGInput added in v0.2.0 

type CreateRAGInput struct {
	Name               *string                         `json:"name,omitempty"`
	Namespace          string                          `json:"namespace"`
	Labels             map[string]interface{}          `json:"labels,omitempty"`
	Annotations        map[string]interface{}          `json:"annotations,omitempty"`
	Creator            *string                         `json:"creator,omitempty"`
	DisplayName        *string                         `json:"displayName,omitempty"`
	Description        *string                         `json:"description,omitempty"`
	Application        TypedObjectReferenceInput       `json:"application"`
	Datasets           []*RAGDatasetInput              `json:"datasets"`
	JudgeLlm           TypedObjectReferenceInput       `json:"judgeLLM"`
	Metrics            []*RAGMetricInput               `json:"metrics"`
	Storage            *PersistentVolumeClaimSpecInput `json:"storage,omitempty"`
	ServiceAccountName *string                         `json:"serviceAccountName,omitempty"`
	Suspend            *bool                           `json:"suspend,omitempty"`
}

type CreateVersionedDatasetInput 

type CreateVersionedDatasetInput struct {
	// 数据集的CR名字，要满足k8s的名称规则
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	// dataset的名字，需要根据这个名字，
	//     判断是否最新版本不包含任何文件(产品要求，有一个不包含任何文件的版本，不允许创建新的版本)
	DatasetName string `json:"datasetName"`
	// 一些标签选择信息，可以不添加
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 一些备注用的注视信息，或者记录一个简单的配置
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 展示名称，用于展示在界面上的，必须填写
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息，可以不写
	Description *string `json:"description,omitempty"`
	// 数据集里面的数据的类型，文本，视频，图片
	Version string `json:"version"`
	// 是否发布，0是未发布，1是已经发布，创建一个版本的时候默认传递0就可以
	Released int `json:"released"`
	// 从数据源要上传的文件，目前以及不用了
	FileGrups []*FileGroup `json:"fileGrups,omitempty"`
	// 界面上创建新版本选择从某个版本集成的时候，填写version字段
	InheritedFrom *string `json:"inheritedFrom,omitempty"`
}

type CreateWorkerInput 

type CreateWorkerInput struct {
	// 模型资源名称（不可同名）
	Name string `json:"name"`
	// 模型创建命名空间
	Namespace string `json:"namespace"`
	// 模型资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型资源描述
	Description *string `json:"description,omitempty"`
	// Worker类型
	// 支持两种类型:
	// - "fastchat" : fastchat提供的通用的推理服务模式
	// - "fastchat-vllm" : fastchat提供的采用VLLM推理加速的推理服务模式
	// 规则: 如果为空，则默认为 "fastchat"
	Type *string `json:"type,omitempty"`
	// worker对应的模型
	// 规则: 必须指定模型准确的namespace
	// 规则: 必填
	Model TypedObjectReferenceInput `json:"model"`
	// worker运行所需的资源
	// 规则: 必填
	Resources ResourcesInput `json:"resources"`
	// 模型服务的节点亲合度配置
	MatchExpressions []*NodeSelectorRequirementInput `json:"matchExpressions,omitempty"`
	// worker运行配置的环境变量
	AdditionalEnvs map[string]interface{} `json:"additionalEnvs,omitempty"`
}

创建模型服务worker的输入

type DataProcessConfig 

type DataProcessConfig struct {
	Name        string                       `json:"name"`
	Description string                       `json:"description"`
	FileNum     int                          `json:"file_num"`
	Status      string                       `json:"status"`
	Children    []*DataProcessConfigChildren `json:"children,omitempty"`
}

type DataProcessConfigChildren 

type DataProcessConfigChildren struct {
	Name         *string                             `json:"name,omitempty"`
	Enable       *string                             `json:"enable,omitempty"`
	ZhName       *string                             `json:"zh_name,omitempty"`
	Description  *string                             `json:"description,omitempty"`
	ChunkSize    *int                                `json:"chunk_size,omitempty"`
	ChunkOverlap *int                                `json:"chunk_overlap,omitempty"`
	LlmConfig    *LLMConfig                          `json:"llm_config,omitempty"`
	Preview      []*DataProcessConfigpreView         `json:"preview,omitempty"`
	FileProgress []*DataProcessConfigpreFileProgress `json:"file_progress,omitempty"`
}

type DataProcessConfigInfo added in v0.2.0 

type DataProcessConfigInfo struct {
	Type                  string                     `json:"type"`
	LlmConfig             *LLMConfig                 `json:"llm_config,omitempty"`
	RemoveDuplicateConfig *RemoveDuplicateConfigItem `json:"remove_duplicate_config,omitempty"`
}

type DataProcessConfigItem 

type DataProcessConfigItem struct {
	Type                  string                 `json:"type"`
	ChunkSize             *int                   `json:"chunk_size,omitempty"`
	ChunkOverlap          *int                   `json:"chunk_overlap,omitempty"`
	LlmConfig             *LLMConfigItem         `json:"llm_config,omitempty"`
	RemoveDuplicateConfig *RemoveDuplicateConfig `json:"remove_duplicate_config,omitempty"`
}

type DataProcessConfigpreFileProgress 

type DataProcessConfigpreFileProgress struct {
	ID        *string `json:"id,omitempty"`
	FileName  *string `json:"file_name,omitempty"`
	Status    *string `json:"status,omitempty"`
	StartTime *string `json:"start_time,omitempty"`
	EndTime   *string `json:"end_time,omitempty"`
	Progress  *string `json:"progress,omitempty"`
}

type DataProcessConfigpreView 

type DataProcessConfigpreView struct {
	FileName *string                            `json:"file_name,omitempty"`
	Content  []*DataProcessConfigpreViewContent `json:"content,omitempty"`
}

type DataProcessConfigpreViewContent 

type DataProcessConfigpreViewContent struct {
	Pre  *string `json:"pre,omitempty"`
	Post *string `json:"post,omitempty"`
}

type DataProcessDetails 

type DataProcessDetails struct {
	Status  int                    `json:"status"`
	Data    DataProcessDetailsItem `json:"data"`
	Message string                 `json:"message"`
}

type DataProcessDetailsInput 

type DataProcessDetailsInput struct {
	ID string `json:"id"`
}

type DataProcessDetailsItem 

type DataProcessDetailsItem struct {
	ID                    string                   `json:"id"`
	Status                string                   `json:"status"`
	Name                  string                   `json:"name"`
	FileType              string                   `json:"file_type"`
	PreDatasetName        string                   `json:"pre_dataset_name"`
	PreDatasetVersion     string                   `json:"pre_dataset_version"`
	PostDatasetName       string                   `json:"post_dataset_name"`
	PostDatasetVersion    string                   `json:"post_dataset_version"`
	FileNum               int                      `json:"file_num"`
	StartTime             string                   `json:"start_time"`
	EndTime               string                   `json:"end_time"`
	Creator               string                   `json:"creator"`
	ErrorMsg              *string                  `json:"error_msg,omitempty"`
	DataProcessConfigInfo []*DataProcessConfigInfo `json:"data_process_config_info,omitempty"`
	Config                []*DataProcessConfig     `json:"config,omitempty"`
	FileDetails           []*FileDetails           `json:"file_details,omitempty"`
}

type DataProcessFileLogInput added in v0.2.0 

type DataProcessFileLogInput struct {
	ID       string `json:"id"`
	FileName string `json:"file_name"`
	Type     string `json:"type"`
}

type DataProcessItem 

type DataProcessItem struct {
	ID                 string  `json:"id"`
	Name               string  `json:"name"`
	Status             string  `json:"status"`
	PreDataSetName     string  `json:"pre_data_set_name"`
	PreDataSetVersion  string  `json:"pre_data_set_version"`
	PostDataSetName    string  `json:"post_data_set_name"`
	PostDataSetVersion *string `json:"post_data_set_version,omitempty"`
	StartDatetime      string  `json:"start_datetime"`
	EndDatetime        string  `json:"end_datetime"`
	ErrorMsg           *string `json:"error_msg,omitempty"`
}

type DataProcessMutation 

type DataProcessMutation struct {
	CreateDataProcessTask *DataProcessResponse `json:"createDataProcessTask,omitempty"`
	DeleteDataProcessTask *DataProcessResponse `json:"deleteDataProcessTask,omitempty"`
}

type DataProcessMutationResolver 

type DataProcessMutationResolver interface {
	CreateDataProcessTask(ctx context.Context, obj *DataProcessMutation, input *AddDataProcessInput) (*DataProcessResponse, error)
	DeleteDataProcessTask(ctx context.Context, obj *DataProcessMutation, input *DeleteDataProcessInput) (*DataProcessResponse, error)
}

type DataProcessQuery 

type DataProcessQuery struct {
	AllDataProcessListByPage     *PaginatedDataProcessItem `json:"allDataProcessListByPage,omitempty"`
	AllDataProcessListByCount    *CountDataProcessItem     `json:"allDataProcessListByCount,omitempty"`
	DataProcessSupportType       *DataProcessSupportType   `json:"dataProcessSupportType,omitempty"`
	DataProcessDetails           *DataProcessDetails       `json:"dataProcessDetails,omitempty"`
	CheckDataProcessTaskName     *DataProcessResponse      `json:"checkDataProcessTaskName,omitempty"`
	GetLogInfo                   *DataProcessResponse      `json:"getLogInfo,omitempty"`
	DataProcessLogInfoByFileName *DataProcessResponse      `json:"dataProcessLogInfoByFileName,omitempty"`
	DataProcessRetry             *DataProcessResponse      `json:"dataProcessRetry,omitempty"`
}

type DataProcessQueryResolver 

type DataProcessQueryResolver interface {
	AllDataProcessListByPage(ctx context.Context, obj *DataProcessQuery, input *AllDataProcessListByPageInput) (*PaginatedDataProcessItem, error)
	AllDataProcessListByCount(ctx context.Context, obj *DataProcessQuery, input *AllDataProcessListByCountInput) (*CountDataProcessItem, error)
	DataProcessSupportType(ctx context.Context, obj *DataProcessQuery) (*DataProcessSupportType, error)
	DataProcessDetails(ctx context.Context, obj *DataProcessQuery, input *DataProcessDetailsInput) (*DataProcessDetails, error)
	CheckDataProcessTaskName(ctx context.Context, obj *DataProcessQuery, input *CheckDataProcessTaskNameInput) (*DataProcessResponse, error)
	GetLogInfo(ctx context.Context, obj *DataProcessQuery, input *DataProcessDetailsInput) (*DataProcessResponse, error)
	DataProcessLogInfoByFileName(ctx context.Context, obj *DataProcessQuery, input *DataProcessFileLogInput) (*DataProcessResponse, error)
	DataProcessRetry(ctx context.Context, obj *DataProcessQuery, input *DataProcessRetryInput) (*DataProcessResponse, error)
}

type DataProcessResponse 

type DataProcessResponse struct {
	Status  int    `json:"status"`
	Data    string `json:"data"`
	Message string `json:"message"`
}

type DataProcessRetryInput added in v0.2.0 

type DataProcessRetryInput struct {
	ID      string `json:"id"`
	Creator string `json:"creator"`
}

type DataProcessSupportType 

type DataProcessSupportType struct {
	Status  int                           `json:"status"`
	Data    []*DataProcessSupportTypeItem `json:"data,omitempty"`
	Message string                        `json:"message"`
}

type DataProcessSupportTypeChildren 

type DataProcessSupportTypeChildren struct {
	Name        string `json:"name"`
	ZhName      string `json:"zh_name"`
	Enable      string `json:"enable"`
	Description string `json:"description"`
}

type DataProcessSupportTypeItem 

type DataProcessSupportTypeItem struct {
	Name        string                            `json:"name"`
	Description string                            `json:"description"`
	Children    []*DataProcessSupportTypeChildren `json:"children,omitempty"`
}

type Dataset 

type Dataset struct {
	// 名称
	// 规则: 遵循k8s命名
	Name string `json:"name"`
	// 所在的namespace(文件上传时作为bucket)
	// 规则: 获取当前项目对应的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 更新时间, 这里更新指文件同步，或者数据处理完成后，做的更新操作的时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
	// 数据集类型，文本，图片，视频
	// 规则: enum{ text image video}
	// 规则: 非空
	ContentType string `json:"contentType"`
	// 应用场景
	// 规则: enum{ xx xx } (非固定字段，以产品为准)
	Field *string `json:"field,omitempty"`
	// 数据集下面的版本列表。
	// 规则: 支持对名字，类型的完全匹配过滤。
	// 规则: 支持通过标签(somelabel=abc)，字段(metadata.name=abc)进行过滤
	Versions PaginatedResult `json:"versions"`
}

Dataset 数据集代表用户纳管的一组相似属性的文件，采用相同的方式进行数据处理并用于后续的 1. 模型训练 2. 知识库

支持多种类型数据: - 文本 - 图片 - 视频

单个数据集仅允许包含同一类型文件，不同类型文件将被忽略 数据集允许有多个版本，数据处理针对单个版本进行 数据集某个版本完成数据处理后，数据处理服务需要将处理后的存储回 版本数据集

func (Dataset) IsPageNode 

func (Dataset) IsPageNode()

type DatasetMutation 

type DatasetMutation struct {
	// 创建数据集
	CreateDataset Dataset `json:"createDataset"`
	// 更新数据集
	UpdateDataset Dataset `json:"updateDataset"`
	// 删除数据集
	// 规则: 支持删除一个名称列表中包含的所有数据集
	// 规则: 支持通过标签选择器，将满足标签的dataset全部删除
	// 规则: 如果提供了这两个参数，以名字列表为主。
	DeleteDatasets *string `json:"deleteDatasets,omitempty"`
}

数据集更新

type DatasetMutationResolver 

type DatasetMutationResolver interface {
	CreateDataset(ctx context.Context, obj *DatasetMutation, input *CreateDatasetInput) (*Dataset, error)
	UpdateDataset(ctx context.Context, obj *DatasetMutation, input *UpdateDatasetInput) (*Dataset, error)
	DeleteDatasets(ctx context.Context, obj *DatasetMutation, input *DeleteCommonInput) (*string, error)
}

type DatasetQuery 

type DatasetQuery struct {
	// 根据名字获取某个具体的数据集
	GetDataset Dataset `json:"getDataset"`
	// 获取数据集列表
	// 规则: 支持通过标签和字段进行选择。如下:
	// labelSelector: aa=bbb
	// fieldSelector= metadata.name=somename
	ListDatasets PaginatedResult `json:"listDatasets"`
}

数据集查询

type DatasetQueryResolver 

type DatasetQueryResolver interface {
	GetDataset(ctx context.Context, obj *DatasetQuery, name string, namespace string) (*Dataset, error)
	ListDatasets(ctx context.Context, obj *DatasetQuery, input *ListDatasetInput) (*PaginatedResult, error)
}

type DatasetResolver 

type DatasetResolver interface {
	Versions(ctx context.Context, obj *Dataset, input ListVersionedDatasetInput) (*PaginatedResult, error)
}

type Datasource 

type Datasource struct {
	// 模型id,为CR资源中的metadata.uid
	ID *string `json:"id,omitempty"`
	// 名称
	// 规则: 遵循k8s命名
	// 规则: 非空
	Name string `json:"name"`
	// 命名空间
	// 规则: 非空
	Namespace   string                 `json:"namespace"`
	Labels      map[string]interface{} `json:"labels,omitempty"`
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// 终端访问信息
	Endpoint *Endpoint `json:"endpoint,omitempty"`
	// 数据源类型
	Type string `json:"type"`
	// 对象存储访问信息
	// 规则: 非空代表当前数据源为对象存储数据源
	Oss *Oss `json:"oss,omitempty"`
	// Postgresql访问信息
	// 规则: 非空代表当前数据源为Postgresql数据源
	Pg *Pg `json:"pg,omitempty"`
	// Web数据访问信息
	// 规则: 非空代表当前数据源为web在线数据
	Web *Web `json:"web,omitempty"`
	// 数据源连接状态
	Status  *string `json:"status,omitempty"`
	Message *string `json:"message,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 更新时间, 这里更新指文件同步，或者数据处理完成后，做的更新操作的时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
}

数据源: 定义了对某一个具备数据存储能力服务的访问信息，供后续向该数据源获取数据使用

func (Datasource) IsPageNode 

func (Datasource) IsPageNode()

type DatasourceMutation 

type DatasourceMutation struct {
	CreateDatasource  Datasource `json:"createDatasource"`
	UpdateDatasource  Datasource `json:"updateDatasource"`
	DeleteDatasources *string    `json:"deleteDatasources,omitempty"`
}

type DatasourceMutationResolver 

type DatasourceMutationResolver interface {
	CreateDatasource(ctx context.Context, obj *DatasourceMutation, input CreateDatasourceInput) (*Datasource, error)
	UpdateDatasource(ctx context.Context, obj *DatasourceMutation, input *UpdateDatasourceInput) (*Datasource, error)
	DeleteDatasources(ctx context.Context, obj *DatasourceMutation, input *DeleteCommonInput) (*string, error)
}

type DatasourceQuery 

type DatasourceQuery struct {
	GetDatasource   Datasource      `json:"getDatasource"`
	CheckDatasource Datasource      `json:"checkDatasource"`
	ListDatasources PaginatedResult `json:"listDatasources"`
}

type DatasourceQueryResolver 

type DatasourceQueryResolver interface {
	GetDatasource(ctx context.Context, obj *DatasourceQuery, name string, namespace string) (*Datasource, error)
	CheckDatasource(ctx context.Context, obj *DatasourceQuery, input CreateDatasourceInput) (*Datasource, error)
	ListDatasources(ctx context.Context, obj *DatasourceQuery, input ListCommonInput) (*PaginatedResult, error)
}

type DeleteCommonInput 

type DeleteCommonInput struct {
	Name      *string `json:"name,omitempty"`
	Namespace string  `json:"namespace"`
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 字段选择器
	FieldSelector *string `json:"fieldSelector,omitempty"`
}

type DeleteDataProcessInput 

type DeleteDataProcessInput struct {
	ID string `json:"id"`
}

type DeleteRAGInput added in v0.2.0 

type DeleteRAGInput struct {
	Name          string  `json:"name"`
	Namespace     string  `json:"namespace"`
	LabelSelector *string `json:"labelSelector,omitempty"`
}

type DeleteVersionedDatasetInput 

type DeleteVersionedDatasetInput struct {
	Name          *string `json:"name,omitempty"`
	Namespace     string  `json:"namespace"`
	LabelSelector *string `json:"labelSelector,omitempty"`
	FieldSelector *string `json:"fieldSelector,omitempty"`
}

type DirectiveRoot 

type DirectiveRoot struct {
}

type DuplicateRAGInput added in v0.2.0 

type DuplicateRAGInput struct {
	Name        string  `json:"name"`
	Namespace   string  `json:"namespace"`
	DisplayName *string `json:"displayName,omitempty"`
}

type Embedder 

type Embedder struct {
	ID          *string                `json:"id,omitempty"`
	Name        string                 `json:"name"`
	Namespace   string                 `json:"namespace"`
	Labels      map[string]interface{} `json:"labels,omitempty"`
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	Creator     *string                `json:"creator,omitempty"`
	DisplayName *string                `json:"displayName,omitempty"`
	Description *string                `json:"description,omitempty"`
	// 服务地址
	BaseURL string `json:"baseUrl"`
	// 此Embedder支持调用的模型列表
	Models []string `json:"models,omitempty"`
	// Embedder供应商类型：
	// 规则: 分为两类: worker 或者 3rd_party
	Provider          *string    `json:"provider,omitempty"`
	Type              *string    `json:"type,omitempty"`
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	UpdateTimestamp   *time.Time `json:"updateTimestamp,omitempty"`
	Status            *string    `json:"status,omitempty"`
	Message           *string    `json:"message,omitempty"`
}

func (Embedder) IsPageNode 

func (Embedder) IsPageNode()

type EmbedderMutation 

type EmbedderMutation struct {
	CreateEmbedder  Embedder `json:"createEmbedder"`
	UpdateEmbedder  Embedder `json:"updateEmbedder"`
	DeleteEmbedders *string  `json:"deleteEmbedders,omitempty"`
}

type EmbedderMutationResolver 

type EmbedderMutationResolver interface {
	CreateEmbedder(ctx context.Context, obj *EmbedderMutation, input CreateEmbedderInput) (*Embedder, error)
	UpdateEmbedder(ctx context.Context, obj *EmbedderMutation, input *UpdateEmbedderInput) (*Embedder, error)
	DeleteEmbedders(ctx context.Context, obj *EmbedderMutation, input *DeleteCommonInput) (*string, error)
}

type EmbedderQuery 

type EmbedderQuery struct {
	GetEmbedder   Embedder        `json:"getEmbedder"`
	ListEmbedders PaginatedResult `json:"listEmbedders"`
}

type EmbedderQueryResolver 

type EmbedderQueryResolver interface {
	GetEmbedder(ctx context.Context, obj *EmbedderQuery, name string, namespace string) (*Embedder, error)
	ListEmbedders(ctx context.Context, obj *EmbedderQuery, input ListCommonInput) (*PaginatedResult, error)
}

type Endpoint 

type Endpoint struct {
	// url地址
	URL *string `json:"url,omitempty"`
	// 终端访问的密钥信息，保存在k8s secret中
	AuthSecret *TypedObjectReference `json:"authSecret,omitempty"`
	// 是否通过非安全方式访问，默认为false，即安全模式访问
	Insecure *bool `json:"insecure,omitempty"`
}

终端的访问信息

type EndpointInput 

type EndpointInput struct {
	// 地址(必填)
	URL string `json:"url"`
	// secret验证密码
	Auth map[string]interface{} `json:"auth,omitempty"`
	// 默认true
	Insecure *bool `json:"insecure,omitempty"`
}

对象存储终端输入

type F 

type F struct {
	// 文件在数据源中的路径，a/b/c.txt或者d.txt
	Path string `json:"path"`
	// 文件类型
	FileType string `json:"fileType"`
	// 数据量
	Count *string `json:"count,omitempty"`
	// 文件更新时间，如果没有导入成功，这个字段为空
	Time *time.Time `json:"time,omitempty"`
	// 文件大小
	Size *string `json:"size,omitempty"`
	// 文件创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 文件版本列表
	Versions []string `json:"versions,omitempty"`
	// 文件最新版本
	LatestVersion *string `json:"latestVersion,omitempty"`
}

File 展示某个版本的所有文件。

func (F) IsPageNode 

func (F) IsPageNode()

type FileDetails added in v0.2.1 

type FileDetails struct {
	FileName  string `json:"file_name"`
	Status    string `json:"status"`
	StartTime string `json:"start_time"`
	EndTime   string `json:"end_time"`
	FileSize  string `json:"file_size"`
}

type FileFilter 

type FileFilter struct {
	// 根据关键词搜索文件，strings.Container(fileName, keyword)
	Keyword *string `json:"keyword,omitempty"`
	// 页
	Page *int `json:"page,omitempty"`
	// 页内容数量
	PageSize *int `json:"pageSize,omitempty"`
	// 根据文件名字或者更新时间排序, file, time
	SortBy *string `json:"sortBy,omitempty"`
}

根据条件顾虑版本内的文件，只支持关键词搜索

type FileGroup 

type FileGroup struct {
	// 数据源的基础信息
	Source TypedObjectReferenceInput `json:"source"`
	// 用到的文件路径，注意⚠️ 一定不要加bucket的名字
	Paths []string                `json:"paths,omitempty"`
	Files []*FileWithVersionInput `json:"files,omitempty"`
}

type FileItem 

type FileItem struct {
	Name string  `json:"name"`
	Size *string `json:"size,omitempty"`
}

type FileWithVersion added in v0.2.2 

type FileWithVersion struct {
	Path    string  `json:"path"`
	Version *string `json:"version,omitempty"`
}

type FileWithVersionInput added in v0.2.2 

type FileWithVersionInput struct {
	Path    string  `json:"path"`
	Version *string `json:"version,omitempty"`
}

type Filedetail 

type Filedetail struct {
	// 文件路径
	Path string `json:"path"`
	// 文件类型
	// 规则: enum { QA }
	FileType string `json:"fileType"`
	// 文件中的数据条目总数
	Count string `json:"count"`
	// 文件大小
	Size string `json:"size"`
	// 最新处理时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
	// 最近一次成功的处理耗时
	TimeCost int `json:"timeCost"`
	// 文件处理的阶段
	// 规则: enum { Pending , Processing , Succeeded, Failed, Skipped}
	Phase string `json:"phase"`
	// 文件版本，""或者"null"的情况表示是文件最新版本。
	Version string `json:"version"`
	// 文件最新版本
	LatestVersion string `json:"latestVersion"`
}

文件详情 描述: 文件在知识库中的详细状态

type Filegroup 

type Filegroup struct {
	// 源；目前仅支持版本数据集，即 Kind为 VersionedDataset
	Source *TypedObjectReference `json:"source,omitempty"`
	// 路径数组
	Path  []string           `json:"path,omitempty"`
	Files []*FileWithVersion `json:"files,omitempty"`
}

文件组 规则: 属于同一个源(数据集)的文件要放在同一个filegroup中 规则: path直接读取文件里表中的文件路径即可

type Filegroupdetail 

type Filegroupdetail struct {
	// 源；目前仅支持版本数据集，即 Kind为 VersionedDataset
	Source *TypedObjectReference `json:"source,omitempty"`
	// 文件详情
	// 规则；数组。具体文件详情参考 filedetail描述
	Filedetails []*Filedetail `json:"filedetails,omitempty"`
}

文件组详情 描述: 文件组在知识库中的状态

type Filegroupinput 

type Filegroupinput struct {
	// 数据源字段
	Source TypedObjectReferenceInput `json:"source"`
	// 路径
	Path  []string                `json:"path,omitempty"`
	Files []*FileWithVersionInput `json:"files,omitempty"`
}

源文件输入

type GPTCategory added in v0.2.2 

type GPTCategory struct {
	ID     string `json:"id"`
	Name   string `json:"name"`
	NameEn string `json:"nameEn"`
}

GPTCategory in gpt store

type GPTQuery added in v0.2.0 

type GPTQuery struct {
	GetGpt          Gpt             `json:"getGPT"`
	ListGpt         PaginatedResult `json:"listGPT"`
	ListGPTCategory []*GPTCategory  `json:"listGPTCategory"`
	// get the gpt store info
	GetGPTStore GPTStore `json:"getGPTStore"`
}

type GPTQueryResolver added in v0.2.0 

type GPTQueryResolver interface {
	GetGpt(ctx context.Context, obj *GPTQuery, name string) (*Gpt, error)
	ListGpt(ctx context.Context, obj *GPTQuery, input ListGPTInput) (*PaginatedResult, error)
	ListGPTCategory(ctx context.Context, obj *GPTQuery) ([]*GPTCategory, error)
	GetGPTStore(ctx context.Context, obj *GPTQuery) (*GPTStore, error)
}

type GPTStore added in v0.2.2 

type GPTStore struct {
	URL             string `json:"url"`
	PublicNamespace string `json:"public_namespace"`
}

type Gpt added in v0.2.0 

type Gpt struct {
	// name: 集群内唯一名称，实际是app的 namespace/name
	Name *string `json:"name,omitempty"`
	// displayName: 展示名称
	DisplayName *string `json:"displayName,omitempty"`
	// description: 描述信息
	Description *string `json:"description,omitempty"`
	// hot: 热度
	Hot *int64 `json:"hot,omitempty"`
	// creator: 创造者
	Creator *string `json:"creator,omitempty"`
	// isRecommended, 是否推荐
	IsRecommended *bool `json:"isRecommended,omitempty"`
	// category：gpt所属分类
	Category []*string `json:"category,omitempty"`
	// icon: base64的图标
	Icon *string `json:"icon,omitempty"`
	// 对话开场白
	Prologue *string `json:"prologue,omitempty"`
	// showRespInfo 查看关联信息配置，即是否在chat界面显示关联信息
	ShowRespInfo *bool `json:"showRespInfo,omitempty"`
	// showRetrievalInfo 查看引用配置，即是否在chat界面显示引用信息
	ShowRetrievalInfo *bool `json:"showRetrievalInfo,omitempty"`
	// showNextGuide 下一步引导，即是否在chat界面显示下一步引导
	ShowNextGuide *bool `json:"showNextGuide,omitempty"`
	// enableUploadFile 是否开启对话上传文档功能
	EnableUploadFile *bool `json:"enableUploadFile,omitempty"`
	// notReadyReasonCode: 用于指明当前gpt状态不正常的原因。状态码要和应用中同字段保持一致。
	// 可选值:
	// - 空：就绪，gpt 可以使用
	// - VectorStoreIsNotReady: 向量数据库没有就绪
	// - EmbedderIsNotReady: embedder服务没有就绪
	// - KnowledgeBaseNotReady: 知识库未就绪，指向量数据库和embedder出错之外的其他情况
	// - LLMNotReady: 模型服务没有就绪
	// - ConfigError: 应用配置错误，比如写了多个Output节点，比如节点名称重复等其他错误
	NotReadyReasonCode *string `json:"notReadyReasonCode,omitempty"`
}

GPT GPT应用需要的信息

func (Gpt) IsPageNode added in v0.2.0 

func (Gpt) IsPageNode()

type KnowledgeBase 

type KnowledgeBase struct {
	// 知识库id,为CR资源中的metadata.uid
	ID *string `json:"id,omitempty"`
	// 名称
	// 规则: 遵循k8s命名
	Name string `json:"name"`
	// 所在的namespace(文件上传时作为bucket)
	// 规则: 获取当前项目对应的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 更新时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
	// embedder指当前知识库使用的embedding向量化模型，即 Kind 为 Embedder
	Embedder     *TypedObjectReference `json:"embedder,omitempty"`
	EmbedderType *string               `json:"embedderType,omitempty"`
	// vectorStore指当前知识库使用的向量数据库服务，即 Kind 为 VectorStore
	VectorStore *TypedObjectReference `json:"vectorStore,omitempty"`
	// fileGroupDetails为知识库中所处理的文件组的详细内容和状态
	FileGroupDetails []*Filegroupdetail `json:"fileGroupDetails,omitempty"`
	// chunkSize为知识库做文档拆分时的块大小
	ChunkSize *int `json:"chunkSize,omitempty"`
	// chunkOverlap为知识库作文档拆分时相邻块的交集
	ChunkOverlap *int `json:"chunkOverlap,omitempty"`
	// batchSize为知识库做批量处理时的批次大小
	BatchSize *int `json:"batchSize,omitempty"`
	// 知识库整体连接状态
	// 规则: True 代表正常 False代表异常
	// 规则: Deleting 代表删除中
	Status *string `json:"status,omitempty"`
	// 知识库状态的原因
	Reason *string `json:"reason,omitempty"`
	// 知识库状态的原因的详细内容
	Message *string `json:"message,omitempty"`
}

知识库

func (KnowledgeBase) IsPageNode 

func (KnowledgeBase) IsPageNode()

type KnowledgeBaseMutation 

type KnowledgeBaseMutation struct {
	CreateKnowledgeBase KnowledgeBase `json:"createKnowledgeBase"`
	UpdateKnowledgeBase KnowledgeBase `json:"updateKnowledgeBase"`
	DeleteKnowledgeBase *string       `json:"deleteKnowledgeBase,omitempty"`
}

type KnowledgeBaseMutationResolver 

type KnowledgeBaseMutationResolver interface {
	CreateKnowledgeBase(ctx context.Context, obj *KnowledgeBaseMutation, input CreateKnowledgeBaseInput) (*KnowledgeBase, error)
	UpdateKnowledgeBase(ctx context.Context, obj *KnowledgeBaseMutation, input *UpdateKnowledgeBaseInput) (*KnowledgeBase, error)
	DeleteKnowledgeBase(ctx context.Context, obj *KnowledgeBaseMutation, input *DeleteCommonInput) (*string, error)
}

type KnowledgeBaseQuery 

type KnowledgeBaseQuery struct {
	GetKnowledgeBase   KnowledgeBase   `json:"getKnowledgeBase"`
	ListKnowledgeBases PaginatedResult `json:"listKnowledgeBases"`
}

type KnowledgeBaseQueryResolver 

type KnowledgeBaseQueryResolver interface {
	GetKnowledgeBase(ctx context.Context, obj *KnowledgeBaseQuery, name string, namespace string) (*KnowledgeBase, error)
	ListKnowledgeBases(ctx context.Context, obj *KnowledgeBaseQuery, input ListKnowledgeBaseInput) (*PaginatedResult, error)
}

type LLMConfig 

type LLMConfig struct {
	Name           *string `json:"name,omitempty"`
	Namespace      *string `json:"namespace,omitempty"`
	Model          *string `json:"model,omitempty"`
	Temperature    *string `json:"temperature,omitempty"`
	TopP           *string `json:"top_p,omitempty"`
	MaxTokens      *string `json:"max_tokens,omitempty"`
	PromptTemplate *string `json:"prompt_template,omitempty"`
	Provider       *string `json:"provider,omitempty"`
}

type LLMConfigItem 

type LLMConfigItem struct {
	Name           *string `json:"name,omitempty"`
	Namespace      *string `json:"namespace,omitempty"`
	Model          *string `json:"model,omitempty"`
	Temperature    *string `json:"temperature,omitempty"`
	TopP           *string `json:"top_p,omitempty"`
	MaxTokens      *string `json:"max_tokens,omitempty"`
	PromptTemplate *string `json:"prompt_template,omitempty"`
	Provider       *string `json:"provider,omitempty"`
}

type LLMQuery 

type LLMQuery struct {
	GetLlm   Llm             `json:"getLLM"`
	ListLLMs PaginatedResult `json:"listLLMs"`
}

type LLMQueryResolver 

type LLMQueryResolver interface {
	GetLlm(ctx context.Context, obj *LLMQuery, name string, namespace string) (*Llm, error)
	ListLLMs(ctx context.Context, obj *LLMQuery, input ListCommonInput) (*PaginatedResult, error)
}

type LabelSelectorRequirement added in v0.2.0 

type LabelSelectorRequirement struct {
	Key      *string   `json:"key,omitempty"`
	Values   []*string `json:"values,omitempty"`
	Operator *string   `json:"operator,omitempty"`
}

type LabelSelectorRequirementInput added in v0.2.0 

type LabelSelectorRequirementInput struct {
	Key      *string   `json:"key,omitempty"`
	Values   []*string `json:"values,omitempty"`
	Operator *string   `json:"operator,omitempty"`
}

type ListCommonInput 

type ListCommonInput struct {
	Namespace string `json:"namespace"`
	// 关键词: 模糊匹配
	Keyword *string `json:"keyword,omitempty"`
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 字段选择器
	FieldSelector *string `json:"fieldSelector,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: -1,返回全部
	PageSize *int `json:"pageSize,omitempty"`
}

type ListDatasetInput 

type ListDatasetInput struct {
	// namespace用来确定资源
	// 规则: 必填
	Namespace string `json:"namespace"`
	// name用来唯一确定资源
	Name *string `json:"name,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 字段选择器
	FieldSelector *string `json:"fieldSelector,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: 默认10
	PageSize *int `json:"pageSize,omitempty"`
	// 关键词: 模糊匹配
	// 规则: namespace,name,displayName,contentType,annotations中如果包含该字段则返回
	Keyword *string `json:"keyword,omitempty"`
}

数据集分页列表查询的输入

type ListGPTInput added in v0.2.0 

type ListGPTInput struct {
	// category: gpt所属分类
	// 规则：分类和关键词同时使用时是and的关系；不填时会默认返回推荐分类的结果
	Category *string `json:"category,omitempty"`
	// 关键词: 模糊匹配
	Keyword *string `json:"keyword,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: 默认10，值为-1返回全部
	PageSize *int `json:"pageSize,omitempty"`
}

type ListKnowledgeBaseInput 

type ListKnowledgeBaseInput struct {
	Name        *string `json:"name,omitempty"`
	Namespace   string  `json:"namespace"`
	DisplayName *string `json:"displayName,omitempty"`
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 字段选择器
	FieldSelector *string `json:"fieldSelector,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: 默认10
	PageSize *int `json:"pageSize,omitempty"`
	// 关键词: 模糊匹配
	// 规则: name,displayName中如果包含该字段则返回
	Keyword *string `json:"keyword,omitempty"`
}

知识库分页列表查询的输入

type ListModelInput 

type ListModelInput struct {
	Namespace string `json:"namespace"`
	// 是否包含系统提供的模型
	// 规则: 为true时，代表将同时获取系统提供的模型
	// 规则: 默认为false
	SystemModel *bool `json:"systemModel,omitempty"`
	// 关键词: 模糊匹配
	Keyword *string `json:"keyword,omitempty"`
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 字段选择器
	FieldSelector *string `json:"fieldSelector,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: 默认10
	PageSize *int `json:"pageSize,omitempty"`
}

type ListModelServiceInput 

type ListModelServiceInput struct {
	// 关键词搜索
	Keyword   *string `json:"keyword,omitempty"`
	Namespace string  `json:"namespace"`
	Page      *int    `json:"page,omitempty"`
	PageSize  *int    `json:"pageSize,omitempty"`
	// 模型服务的类型
	// 规则:
	//     - 为空默认不过滤
	//     - llm 则仅返回LLM模型服务
	//     - embedding 则仅返回Embedding模型服务
	//     - llm,embedding 则返回同时提供LLM和Embedding能力的模型服务
	Types *string `json:"types,omitempty"`
	// 模型服务供应商类型
	// 规则:
	//     - 为空默认不过滤
	//     - worker 则仅返回本地模型服务
	//     - 3rd_party 则仅返回第三方模型服务
	ProviderType *string `json:"providerType,omitempty"`
	// 模型服务供应商类型
	// 规则:
	//     - 为空默认不过滤
	//     - openai 则仅返回接口类型类型为openai的模型服务
	//     - zhipuai 则仅返回接口类型类型为zhipuai的模型服务
	APIType *string `json:"apiType,omitempty"`
}

type ListNodeInput added in v0.2.1 

type ListNodeInput struct {
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: -1,返回全部
	PageSize *int `json:"pageSize,omitempty"`
}

type ListRAGInput added in v0.2.0 

type ListRAGInput struct {
	AppName   string `json:"appName"`
	Namespace string `json:"namespace"`
	// 根据状态过滤
	Status *string `json:"status,omitempty"`
	// 根据名字，displayName字段获取
	Keyword *string `json:"keyword,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: 默认10
	PageSize *int `json:"pageSize,omitempty"`
}

type ListVersionedDatasetInput 

type ListVersionedDatasetInput struct {
	Name          *string `json:"name,omitempty"`
	Namespace     *string `json:"namespace,omitempty"`
	DisplayName   *string `json:"displayName,omitempty"`
	LabelSelector *string `json:"labelSelector,omitempty"`
	FieldSelector *string `json:"fieldSelector,omitempty"`
	// 分页页码，从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，默认10
	PageSize *int    `json:"pageSize,omitempty"`
	Keyword  *string `json:"keyword,omitempty"`
}

type ListWorkerInput 

type ListWorkerInput struct {
	Namespace string `json:"namespace"`
	// 关键词: 模糊匹配
	Keyword *string `json:"keyword,omitempty"`
	// 标签选择器
	LabelSelector *string `json:"labelSelector,omitempty"`
	// 字段选择器
	FieldSelector *string `json:"fieldSelector,omitempty"`
	// 分页页码，
	// 规则: 从1开始，默认是1
	Page *int `json:"page,omitempty"`
	// 每页数量，
	// 规则: 默认10
	PageSize *int `json:"pageSize,omitempty"`
	// worker对应的模型类型
	// 规则: 模型分为embedding和llm两大类。如果两者都有，则通过逗号隔开，如: "embedding,llm"
	ModelTypes *string `json:"modelTypes,omitempty"`
}

type Llm 

type Llm struct {
	ID          *string                `json:"id,omitempty"`
	Name        string                 `json:"name"`
	Namespace   string                 `json:"namespace"`
	Labels      map[string]interface{} `json:"labels,omitempty"`
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	Creator     *string                `json:"creator,omitempty"`
	DisplayName *string                `json:"displayName,omitempty"`
	Description *string                `json:"description,omitempty"`
	// 服务地址
	BaseURL string `json:"baseUrl"`
	// 此LLM支持调用的模型列表
	Models []string `json:"models,omitempty"`
	// LLM供应商类型：
	// 规则: 分为两类: worker 或者 3rd_party
	Provider          *string    `json:"provider,omitempty"`
	Type              *string    `json:"type,omitempty"`
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	UpdateTimestamp   *time.Time `json:"updateTimestamp,omitempty"`
	Status            *string    `json:"status,omitempty"`
	Message           *string    `json:"message,omitempty"`
}

func (Llm) IsPageNode 

func (Llm) IsPageNode()

type Model 

type Model struct {
	// 模型id,为CR资源中的metadata.uid
	ID *string `json:"id,omitempty"`
	// 名称
	// 规则: 遵循k8s命名
	Name string `json:"name"`
	// 所在的namespace(文件上传时作为bucket)
	// 规则: 获取当前项目对应的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 模型是否是由系统提供
	// 规则: 如果为true，则是系统系统的。
	// 规则: 如果是系统提供的模型，不允许修改
	SystemModel *bool `json:"systemModel,omitempty"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 更新时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
	// 模型类型
	// 规则: 目前支持 llm和embedding两种模型类型
	// 规则: 如果该模型支持多种模型类型，则可多选。多选后组成的字段通过逗号隔开。如 "llm,embedding"
	Types string `json:"types"`
	// 状态
	Status *string `json:"status,omitempty"`
	// 详细信息
	Message *string `json:"message,omitempty"`
	// 模型包含文件列表
	Files PaginatedResult `json:"files"`
	// 如果设置从modelscope或者hugginface拉取模型文件，这两个字段会返回模型名字。
	HuggingFaceRepo *string `json:"huggingFaceRepo,omitempty"`
	ModelScopeRepo  *string `json:"modelScopeRepo,omitempty"`
	// 返回模型选择的版本
	Revision *string `json:"revision,omitempty"`
	// local: 从本地的minio来。
	// modelscope: 从modelscope来
	// huggingface: 从huggingface来
	ModelSource *string `json:"modelSource,omitempty"`
}

模型

func (Model) IsPageNode 

func (Model) IsPageNode()

type ModelMutation 

type ModelMutation struct {
	CreateModel  Model   `json:"createModel"`
	UpdateModel  Model   `json:"updateModel"`
	DeleteModels *string `json:"deleteModels,omitempty"`
}

type ModelMutationResolver 

type ModelMutationResolver interface {
	CreateModel(ctx context.Context, obj *ModelMutation, input CreateModelInput) (*Model, error)
	UpdateModel(ctx context.Context, obj *ModelMutation, input *UpdateModelInput) (*Model, error)
	DeleteModels(ctx context.Context, obj *ModelMutation, input *DeleteCommonInput) (*string, error)
}

type ModelQuery 

type ModelQuery struct {
	GetModel   Model           `json:"getModel"`
	ListModels PaginatedResult `json:"listModels"`
}

type ModelQueryResolver 

type ModelQueryResolver interface {
	GetModel(ctx context.Context, obj *ModelQuery, name string, namespace string) (*Model, error)
	ListModels(ctx context.Context, obj *ModelQuery, input ListModelInput) (*PaginatedResult, error)
}

type ModelResolver 

type ModelResolver interface {
	Files(ctx context.Context, obj *Model, input *FileFilter) (*PaginatedResult, error)
}

type ModelService 

type ModelService struct {
	ID          *string                `json:"id,omitempty"`
	Name        string                 `json:"name"`
	Namespace   string                 `json:"namespace"`
	Labels      map[string]interface{} `json:"labels,omitempty"`
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	Creator     *string                `json:"creator,omitempty"`
	DisplayName *string                `json:"displayName,omitempty"`
	Description *string                `json:"description,omitempty"`
	// 模型服务的创建和更新时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	UpdateTimestamp   *time.Time `json:"updateTimestamp,omitempty"`
	// 模型服务供应商的类型
	// 规则: 3rd_party 第三方
	// 规则: worker 本地
	ProviderType *string `json:"providerType,omitempty"`
	// 模型服务能力类型，支持 llm 和 embedding 两种模型类型
	// 规则: 如果该模型支持多种模型类型，则可多选。多选后组成的字段通过逗号隔开。如 "llm,embedding"
	Types *string `json:"types,omitempty"`
	// 模型服务 API 类型
	// 规则：支持 openai, zhipuai 两种类型
	APIType *string `json:"apiType,omitempty"`
	// 模型服务的大语言模型列表
	// 规则；如果不填或者为空，则按照模型的API类型获取默认的模型列表
	LlmModels []string `json:"llmModels,omitempty"`
	// 模型服务的Embedding模型列表
	// 规则；如果不填或者为空，则按照模型的API类型获取默认的模型列表
	EmbeddingModels []string `json:"embeddingModels,omitempty"`
	// 服务地址: 仅针对第三方模型服务
	BaseURL string `json:"baseUrl"`
	// 状态
	// 规则: 目前分为六种状态
	//   - True: 正常 (第三方模型服务)
	//   - False: 异常 (第三方模型服务)
	//   - Unknown: 未知 (本地模型服务)
	//   - Pending: 发布中 (本地模型服务)
	//   - Running: 已发布 (本地模型服务)
	//   - Error: 异常 (本地模型服务)
	Status *string `json:"status,omitempty"`
	// 详细的状态消息描述
	Message *string `json:"message,omitempty"`
}

func (ModelService) IsPageNode 

func (ModelService) IsPageNode()

type ModelServiceMutation 

type ModelServiceMutation struct {
	CreateModelService ModelService `json:"createModelService"`
	UpdateModelService ModelService `json:"updateModelService"`
	DeleteModelService *string      `json:"deleteModelService,omitempty"`
}

type ModelServiceMutationResolver 

type ModelServiceMutationResolver interface {
	CreateModelService(ctx context.Context, obj *ModelServiceMutation, input CreateModelServiceInput) (*ModelService, error)
	UpdateModelService(ctx context.Context, obj *ModelServiceMutation, input *UpdateModelServiceInput) (*ModelService, error)
	DeleteModelService(ctx context.Context, obj *ModelServiceMutation, input *DeleteCommonInput) (*string, error)
}

type ModelServiceQuery 

type ModelServiceQuery struct {
	GetModelService   ModelService    `json:"getModelService"`
	ListModelServices PaginatedResult `json:"listModelServices"`
	CheckModelService ModelService    `json:"checkModelService"`
}

type ModelServiceQueryResolver 

type ModelServiceQueryResolver interface {
	GetModelService(ctx context.Context, obj *ModelServiceQuery, name string, namespace string) (*ModelService, error)
	ListModelServices(ctx context.Context, obj *ModelServiceQuery, input *ListModelServiceInput) (*PaginatedResult, error)
	CheckModelService(ctx context.Context, obj *ModelServiceQuery, input CreateModelServiceInput) (*ModelService, error)
}

type Mutation added in v0.2.0 

type Mutation struct {
}

type MutationResolver 

type MutationResolver interface {
	Hello(ctx context.Context, name string) (string, error)
	Application(ctx context.Context) (*ApplicationMutation, error)
	DataProcess(ctx context.Context) (*DataProcessMutation, error)
	Dataset(ctx context.Context) (*DatasetMutation, error)
	Datasource(ctx context.Context) (*DatasourceMutation, error)
	Embedder(ctx context.Context) (*EmbedderMutation, error)
	KnowledgeBase(ctx context.Context) (*KnowledgeBaseMutation, error)
	Model(ctx context.Context) (*ModelMutation, error)
	ModelService(ctx context.Context) (*ModelServiceMutation, error)
	Rag(ctx context.Context) (*RAGMutation, error)
	VersionedDataset(ctx context.Context) (*VersionedDatasetMutation, error)
	Worker(ctx context.Context) (*WorkerMutation, error)
}

type Node added in v0.2.1 

type Node struct {
	Name   string                 `json:"name"`
	Labels map[string]interface{} `json:"labels,omitempty"`
}

func (Node) IsPageNode added in v0.2.1 

func (Node) IsPageNode()

type NodeQuery added in v0.2.1 

type NodeQuery struct {
	ListNodes PaginatedResult `json:"listNodes"`
}

type NodeQueryResolver added in v0.2.1 

type NodeQueryResolver interface {
	ListNodes(ctx context.Context, obj *NodeQuery, input *ListNodeInput) (*PaginatedResult, error)
}

type NodeSelectorRequirement added in v0.2.0 

type NodeSelectorRequirement struct {
	Key      string   `json:"key"`
	Operator string   `json:"operator"`
	Values   []string `json:"values"`
}

type NodeSelectorRequirementInput added in v0.2.0 

type NodeSelectorRequirementInput struct {
	Key      string   `json:"key"`
	Operator string   `json:"operator"`
	Values   []string `json:"values"`
}

type Oss 

type Oss struct {
	// 所用的bucket名称
	Bucket *string `json:"bucket,omitempty"`
	// 所用的object路径(可为前缀)
	Object *string `json:"object,omitempty"`
}

对象存储的使用信息

type OssInput 

type OssInput struct {
	Bucket string  `json:"bucket"`
	Object *string `json:"object,omitempty"`
}

文件输入

type PageNode 

type PageNode interface {
	IsPageNode()
}

type PaginatedDataProcessItem 

type PaginatedDataProcessItem struct {
	Status  int                `json:"status"`
	Data    []*DataProcessItem `json:"data,omitempty"`
	Message string             `json:"message"`
}

type PaginatedResult 

type PaginatedResult struct {
	HasNextPage bool       `json:"hasNextPage"`
	Nodes       []PageNode `json:"nodes,omitempty"`
	Page        *int       `json:"page,omitempty"`
	PageSize    *int       `json:"pageSize,omitempty"`
	TotalCount  int        `json:"totalCount"`
}

type Parameter added in v0.2.0 

type Parameter struct {
	Key   *string `json:"key,omitempty"`
	Value *string `json:"value,omitempty"`
}

type ParameterInput added in v0.2.0 

type ParameterInput struct {
	Key   *string `json:"key,omitempty"`
	Value *string `json:"value,omitempty"`
}

type PersistentVolumeClaimSpec added in v0.2.0 

type PersistentVolumeClaimSpec struct {
	AccessModes      []string              `json:"accessModes"`
	Selector         *Selector             `json:"selector,omitempty"`
	Resources        *Resource             `json:"resources,omitempty"`
	VolumeName       *string               `json:"volumeName,omitempty"`
	StorageClassName *string               `json:"storageClassName,omitempty"`
	VolumeMode       *string               `json:"volumeMode,omitempty"`
	Datasource       *TypedObjectReference `json:"datasource,omitempty"`
	DataSourceRef    *TypedObjectReference `json:"dataSourceRef,omitempty"`
}

type PersistentVolumeClaimSpecInput added in v0.2.0 

type PersistentVolumeClaimSpecInput struct {
	AccessModes      []string                   `json:"accessModes"`
	Selector         *SelectorInput             `json:"selector,omitempty"`
	Resources        *ResourceInput             `json:"resources,omitempty"`
	VolumeName       *string                    `json:"volumeName,omitempty"`
	StorageClassName *string                    `json:"storageClassName,omitempty"`
	VolumeMode       *string                    `json:"volumeMode,omitempty"`
	Datasource       *TypedObjectReferenceInput `json:"datasource,omitempty"`
	DataSourceRef    *TypedObjectReferenceInput `json:"dataSourceRef,omitempty"`
}

type Pg added in v0.2.2 

type Pg struct {
	// 所用的数据库名称
	Database *string `json:"database,omitempty"`
}

Postgresql的使用信息

type PgInput added in v0.2.2 

type PgInput struct {
	Database string `json:"database"`
}

type Query added in v0.2.0 

type Query struct {
}

type QueryResolver 

type QueryResolver interface {
	Hello(ctx context.Context, name string) (string, error)
	Application(ctx context.Context) (*ApplicationQuery, error)
	DataProcess(ctx context.Context) (*DataProcessQuery, error)
	Dataset(ctx context.Context) (*DatasetQuery, error)
	Datasource(ctx context.Context) (*DatasourceQuery, error)
	Embedder(ctx context.Context) (*EmbedderQuery, error)
	Gpt(ctx context.Context) (*GPTQuery, error)
	KnowledgeBase(ctx context.Context) (*KnowledgeBaseQuery, error)
	Llm(ctx context.Context) (*LLMQuery, error)
	Model(ctx context.Context) (*ModelQuery, error)
	ModelService(ctx context.Context) (*ModelServiceQuery, error)
	Node(ctx context.Context) (*NodeQuery, error)
	Rag(ctx context.Context) (*RAGQuery, error)
	RayCluster(ctx context.Context) (*RayClusterQuery, error)
	VersionedDataset(ctx context.Context) (*VersionedDatasetQuery, error)
	Worker(ctx context.Context) (*WorkerQuery, error)
}

type RAGDataset added in v0.2.0 

type RAGDataset struct {
	Source *TypedObjectReference `json:"source,omitempty"`
	Files  []*F                  `json:"files,omitempty"`
}

type RAGDatasetInput added in v0.2.0 

type RAGDatasetInput struct {
	Source *TypedObjectReferenceInput `json:"source,omitempty"`
	Files  []string                   `json:"files,omitempty"`
}

type RAGMetric added in v0.2.0 

type RAGMetric struct {
	MetricKind          *string      `json:"metricKind,omitempty"`
	Parameters          []*Parameter `json:"parameters,omitempty"`
	ToleranceThreshbold *int         `json:"toleranceThreshbold,omitempty"`
}

type RAGMetricInput added in v0.2.0 

type RAGMetricInput struct {
	MetricKind          *string           `json:"metricKind,omitempty"`
	Parameters          []*ParameterInput `json:"parameters,omitempty"`
	ToleranceThreshbold *int              `json:"toleranceThreshbold,omitempty"`
}

type RAGMutation added in v0.2.0 

type RAGMutation struct {
	CreateRag    Rag     `json:"createRAG"`
	UpdateRag    Rag     `json:"updateRAG"`
	DeleteRag    *string `json:"deleteRAG,omitempty"`
	DuplicateRag Rag     `json:"duplicateRAG"`
}

type RAGMutationResolver added in v0.2.0 

type RAGMutationResolver interface {
	CreateRag(ctx context.Context, obj *RAGMutation, input CreateRAGInput) (*Rag, error)
	UpdateRag(ctx context.Context, obj *RAGMutation, input UpdateRAGInput) (*Rag, error)
	DeleteRag(ctx context.Context, obj *RAGMutation, input DeleteRAGInput) (*string, error)
	DuplicateRag(ctx context.Context, obj *RAGMutation, input DuplicateRAGInput) (*Rag, error)
}

type RAGQuery added in v0.2.0 

type RAGQuery struct {
	GetRag  Rag             `json:"getRAG"`
	ListRag PaginatedResult `json:"listRAG"`
}

type RAGQueryResolver added in v0.2.0 

type RAGQueryResolver interface {
	GetRag(ctx context.Context, obj *RAGQuery, name string, namespace string) (*Rag, error)
	ListRag(ctx context.Context, obj *RAGQuery, input ListRAGInput) (*PaginatedResult, error)
}

type RAGResolver added in v0.2.0 

type RAGResolver interface {
	Application(ctx context.Context, obj *Rag) (*Application, error)
	Datasets(ctx context.Context, obj *Rag) ([]*RAGDataset, error)
	JudgeLlm(ctx context.Context, obj *Rag) (*Llm, error)
	Metrics(ctx context.Context, obj *Rag) ([]*RAGMetric, error)
}

type Rag added in v0.2.0 

type Rag struct {
	// 名称
	// 规则: 遵循k8s命名
	Name string `json:"name"`
	// 规则: 获取当前项目对应的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 评估完成时间, 如果没有完成这，这个字段没有值
	CompleteTimestamp *time.Time `json:"completeTimestamp,omitempty"`
	// 获取评估流程选择的应用
	Application Application `json:"application"`
	// 目前数据只允许来自于数据集版本
	Datasets []*RAGDataset `json:"datasets"`
	// judgeLLM
	// 选用的评测大模型的具体信息
	JudgeLlm Llm `json:"judgeLLM"`
	// 评估个报告的指标
	Metrics []*RAGMetric `json:"metrics"`
	// 评测的多个阶段之间需要通过pvc传递数据
	Storage PersistentVolumeClaimSpec `json:"storage"`
	// 评测过程中用到的serviceAccount, 默认是default
	ServiceAccountName string `json:"serviceAccountName"`
	// 评估过程是否暂停，true表示已经暂停，fals表示没有暂停
	Suspend bool `json:"suspend"`
	// rag的状态有4中
	// complete(评估完成)， failed(评估失败), suspend(任务停止,暂停操作), ing(评估中)
	Status string `json:"status"`
	// 当前评估进行到哪一步了
	// "": 开始
	// "init": 创建pvc中
	// "download": 下载数据集文件
	// "generated": 生成测试数据
	// "judge": 大模型评测中
	// "upload": 上传评测结果
	// "complete": 评测过程结束
	Phase *string `json:"phase,omitempty"`
	// 当前阶段产生的辅助信息
	PhaseMessage *string `json:"phaseMessage,omitempty"`
}

RAG评估结构

func (Rag) IsPageNode added in v0.2.0 

func (Rag) IsPageNode()

type RayCluster added in v0.2.0 

type RayCluster struct {
	// Ray集群的索引
	Index int `json:"index"`
	// 名称
	// 规则: 遵循k8s命名
	Name string `json:"name"`
	// Ray集群head节点的地址
	// 规则: 遵循k8s命名
	HeadAddress *string `json:"headAddress,omitempty"`
	// Ray集群dashboard的地址
	DashboardHost *string `json:"dashboardHost,omitempty"`
	// Ray集群应用要求的python版本
	PythonVersion *string `json:"pythonVersion,omitempty"`
}

RayCluster集群

func (RayCluster) IsPageNode added in v0.2.0 

func (RayCluster) IsPageNode()

type RayClusterQuery added in v0.2.0 

type RayClusterQuery struct {
	ListRayClusters PaginatedResult `json:"listRayClusters"`
}

type RayClusterQueryResolver added in v0.2.0 

type RayClusterQueryResolver interface {
	ListRayClusters(ctx context.Context, obj *RayClusterQuery, input ListCommonInput) (*PaginatedResult, error)
}

type RemoveDuplicateConfig added in v0.2.0 

type RemoveDuplicateConfig struct {
	EmbeddingName      string `json:"embedding_name"`
	EmbeddingNamespace string `json:"embedding_namespace"`
	EmbeddingModel     string `json:"embedding_model"`
	EmbeddingProvider  string `json:"embedding_provider"`
	Similarity         string `json:"similarity"`
}

type RemoveDuplicateConfigItem added in v0.2.0 

type RemoveDuplicateConfigItem struct {
	EmbeddingName      string `json:"embedding_name"`
	EmbeddingNamespace string `json:"embedding_namespace"`
	EmbeddingModel     string `json:"embedding_model"`
	EmbeddingProvider  string `json:"embedding_provider"`
	Similarity         string `json:"similarity"`
}

type ResolverRoot 

type ResolverRoot interface {
	ApplicationMutation() ApplicationMutationResolver
	ApplicationQuery() ApplicationQueryResolver
	DataProcessMutation() DataProcessMutationResolver
	DataProcessQuery() DataProcessQueryResolver
	Dataset() DatasetResolver
	DatasetMutation() DatasetMutationResolver
	DatasetQuery() DatasetQueryResolver
	DatasourceMutation() DatasourceMutationResolver
	DatasourceQuery() DatasourceQueryResolver
	EmbedderMutation() EmbedderMutationResolver
	EmbedderQuery() EmbedderQueryResolver
	GPTQuery() GPTQueryResolver
	KnowledgeBaseMutation() KnowledgeBaseMutationResolver
	KnowledgeBaseQuery() KnowledgeBaseQueryResolver
	LLMQuery() LLMQueryResolver
	Model() ModelResolver
	ModelMutation() ModelMutationResolver
	ModelQuery() ModelQueryResolver
	ModelServiceMutation() ModelServiceMutationResolver
	ModelServiceQuery() ModelServiceQueryResolver
	Mutation() MutationResolver
	NodeQuery() NodeQueryResolver
	Query() QueryResolver
	RAG() RAGResolver
	RAGMutation() RAGMutationResolver
	RAGQuery() RAGQueryResolver
	RayClusterQuery() RayClusterQueryResolver
	VersionedDataset() VersionedDatasetResolver
	VersionedDatasetMutation() VersionedDatasetMutationResolver
	VersionedDatasetQuery() VersionedDatasetQueryResolver
	WorkerMutation() WorkerMutationResolver
	WorkerQuery() WorkerQueryResolver
}

type Resource added in v0.2.0 

type Resource struct {
	Limits   map[string]interface{} `json:"limits,omitempty"`
	Requests map[string]interface{} `json:"requests,omitempty"`
}

type ResourceInput added in v0.2.0 

type ResourceInput struct {
	Limits   map[string]interface{} `json:"limits,omitempty"`
	Requests map[string]interface{} `json:"requests,omitempty"`
}

type Resources 

type Resources struct {
	CPU       *string `json:"cpu,omitempty"`
	Memory    *string `json:"memory,omitempty"`
	NvidiaGpu *string `json:"nvidiaGPU,omitempty"`
}

模型服务worker节点的资源(limits)

type ResourcesInput 

type ResourcesInput struct {
	// cpu配置
	// 规则: 必填
	CPU string `json:"cpu"`
	// memory配置
	// 规则: 必填
	Memory string `json:"memory"`
	// gpu配置
	NvidiaGpu *string `json:"nvidiaGPU,omitempty"`
}

资源配置的输入

type Selector added in v0.2.0 

type Selector struct {
	MatchLabels      map[string]interface{}      `json:"matchLabels,omitempty"`
	MatchExpressions []*LabelSelectorRequirement `json:"matchExpressions,omitempty"`
}

type SelectorInput added in v0.2.0 

type SelectorInput struct {
	MatchLabels      map[string]interface{}           `json:"matchLabels,omitempty"`
	MatchExpressions []*LabelSelectorRequirementInput `json:"matchExpressions,omitempty"`
}

type Tool added in v0.2.0 

type Tool struct {
	// 名称，需要严格大小写一致，可选项为："Bing Search API","calculator","Weather Query API","Web Scraper"
	// - "Bing Search API" bing搜索工具
	// - "calculator" 计算器
	// - "Weather Query API" 天气查询
	// - "Web Scraper" 网页爬取
	Name *string `json:"name,omitempty"`
	// params 参数，需要严格大小写一致
	// "Bing Search API"
	// - apiKey：密钥，默认提供
	// - count：返回数目，默认为5
	// - scraperPage：是否抓取bing搜到的网页的内容，默认为true
	// "calculator" 没有参数
	// "Weather Query API"
	// - apiKey：密钥，默认提供；
	// "Web Scraper"
	// - delay：抓取时间间隔，秒，默认3
	// - async：是否异步抓取，是或者否，默认true
	// - handleLinks：是否从网页内的链接，继续抓取，是或者否，默认false
	// - blacklist：黑名单列表，用逗号隔开的字符串，默认是login,signup,signin,register,logout,download,redirect，表示这些页面都不抓取
	Params map[string]interface{} `json:"params,omitempty"`
}

Tool 应用和Agent中用到的工具

type ToolInput added in v0.2.0 

type ToolInput struct {
	// 名称，需要严格大小写一致，可选项为："Bing Search API","calculator","Weather Query API","Web Scraper"
	// - "Bing Search API" bing搜索工具
	// - "calculator" 计算器
	// - "Weather Query API" 天气查询
	// - "Web Scraper" 网页爬取
	Name string `json:"name"`
	// params 参数，可选，需要严格大小写一致
	// "Bing Search API"
	// - apiKey：密钥，默认提供
	// - count：返回数目，默认为5
	// - scraperPage：是否抓取bing搜到的网页的内容，默认为true
	// "calculator" 没有参数
	// "Weather Query API"
	// - apiKey：密钥，默认提供；
	// "Web Scraper"
	// - delay：抓取时间间隔，秒，默认3
	// - async：是否异步抓取，是或者否，默认true
	// - handleLinks：是否从网页内的链接，继续抓取，是或者否，默认false
	// - blacklist：黑名单列表，用逗号隔开的字符串，默认是login,signup,signin,register,logout,download,redirect，表示这些页面都不抓取
	Params map[string]interface{} `json:"params,omitempty"`
}

ToolInput 应用和Agent中用到的工具

type TypedObjectReference 

type TypedObjectReference struct {
	APIGroup    *string `json:"apiGroup,omitempty"`
	Kind        string  `json:"kind"`
	Name        string  `json:"name"`
	DisplayName *string `json:"displayName,omitempty"`
	Namespace   *string `json:"namespace,omitempty"`
}

type TypedObjectReferenceInput 

type TypedObjectReferenceInput struct {
	APIGroup  *string `json:"apiGroup,omitempty"`
	Kind      string  `json:"kind"`
	Name      string  `json:"name"`
	Namespace *string `json:"namespace,omitempty"`
}

type UpdateApplicationConfigInput 

type UpdateApplicationConfigInput struct {
	// 应用名称, 用于确定要更新哪个应用
	// 规则: 遵循 k8s 命名
	Name string `json:"name"`
	// 应用所在的 namespace, 用于确定要更新哪个应用
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 对话开场白
	Prologue *string `json:"prologue,omitempty"`
	// model 指具体使用的模型名称，比如 gpt-3.5-turbo 或者 chatglm_turbo
	Model *string `json:"model,omitempty"`
	// llm 指当前知识库应用使用的模型服务，即 Kind 为 LLM 的 CR 的名称
	Llm string `json:"llm"`
	// temperature 温度
	Temperature *float64 `json:"temperature,omitempty"`
	// maxLength 最大响应长度
	MaxLength *int `json:"maxLength,omitempty"`
	// maxTokens 最大输出token
	MaxTokens *int `json:"maxTokens,omitempty"`
	// conversionWindowSize 对话轮次
	ConversionWindowSize *int `json:"conversionWindowSize,omitempty"`
	// knowledgebase 指当前知识库应用使用的知识库，即 Kind 为 KnowledgeBase 的 CR 的名称，目前一个应用只支持0或1个知识库
	Knowledgebase *string `json:"knowledgebase,omitempty"`
	// scoreThreshold 最终返回结果的最低相似度
	ScoreThreshold *float64 `json:"scoreThreshold,omitempty"`
	// numDocuments  最终返回结果的引用上限
	NumDocuments *int `json:"numDocuments,omitempty"`
	// docNullReturn 空搜索回复
	DocNullReturn *string `json:"docNullReturn,omitempty"`
	// userPrompt 用户级别的 Prompt
	UserPrompt *string `json:"userPrompt,omitempty"`
	// systemPrompt 系统级别的 Prompt
	SystemPrompt *string `json:"systemPrompt,omitempty"`
	// showRespInfo 查看关联信息配置，即是否在chat界面显示关联信息
	ShowRespInfo *bool `json:"showRespInfo,omitempty"`
	// showRetrievalInfo 查看引用配置，即是否在chat界面显示引用信息
	ShowRetrievalInfo *bool `json:"showRetrievalInfo,omitempty"`
	// showNextGuide 下一步引导，即是否在chat界面显示下一步引导
	ShowNextGuide *bool `json:"showNextGuide,omitempty"`
	// tools 要使用的工具列表
	Tools []*ToolInput `json:"tools,omitempty"`
	// enableRerank 是否启用 rerank
	EnableRerank *bool `json:"enableRerank,omitempty"`
	// rerankModel rerank 模型，enableRerank 为 true 时起效，为空时使用默认 rerank 模型
	RerankModel *string `json:"rerankModel,omitempty"`
	// enableMultiQuery 是否启用多查询
	EnableMultiQuery *bool `json:"enableMultiQuery,omitempty"`
	// chatTimeout 对话超时，单位秒，不填为默认 60s
	ChatTimeout *float64 `json:"chatTimeout,omitempty"`
	// enableUploadFile 是否开启对话上传文档功能
	EnableUploadFile *bool `json:"enableUploadFile,omitempty"`
	// chunkSize 上传文档做文档拆分时的块大小
	ChunkSize *int `json:"chunkSize,omitempty"`
	// chunkOverlap 上传文档作文档拆分时相邻块的交集
	ChunkOverlap *int `json:"chunkOverlap,omitempty"`
	// batchSize 上传文档做批量处理时的批次大小
	BatchSize *int `json:"batchSize,omitempty"`
}

type UpdateApplicationMetadataInput 

type UpdateApplicationMetadataInput struct {
	// 应用名称, 用于确定要更新哪个应用
	// 规则: 遵循 k8s 命名
	Name string `json:"name"`
	// 应用所在的 namespace, 用于确定要更新哪个应用
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签，如果要更新，请传递完整内容
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息，如果要更新，请传递完整内容
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 展示名，别名
	DisplayName string `json:"displayName"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// Icon，应用头像， base64格式的图片
	Icon string `json:"icon"`
	// IsPublic, 是否发布，即是否公开提供服务
	IsPublic *bool `json:"isPublic,omitempty"`
	// isRecommended, 是否推荐
	IsRecommended *bool `json:"isRecommended,omitempty"`
	// category：所属分类
	Category []*string `json:"category,omitempty"`
}

type UpdateDatasetInput 

type UpdateDatasetInput struct {
	// name, namespace用来确定资源
	// 规则: 不允许修改的。将原数据传递回来即可。
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	// 更新的的标签信息，这里涉及到增加或者删除标签，
	// 规则: 不允许修改的。将原数据传递回来即可。
	// 如果标签有任何改动，传递完整的label。
	// 例如之前的标齐是: abc:def 新增一个标签aa:bb, 那么传递 abc:def, aa:bb
	Labels      map[string]interface{} `json:"labels,omitempty"`
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 如不更新，则为空
	DisplayName *string `json:"displayName,omitempty"`
	// 如不更新，则为空
	Description *string `json:"description,omitempty"`
}

数据集更新的输入

type UpdateDatasourceInput 

type UpdateDatasourceInput struct {
	// name, namespace用来确定资源
	// 规则: 不允许修改的。将原数据传递回来即可。
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	// 更新的的标签信息，这里涉及到增加或者删除标签，
	// 规则: 不允许修改的。将原数据传递回来即可。
	// 如果标签有任何改动，传递完整的label。
	// 例如之前的标齐是: abc:def 新增一个标签aa:bb, 那么传递 abc:def, aa:bb
	Labels      map[string]interface{} `json:"labels,omitempty"`
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 如不更新，则为空
	DisplayName *string `json:"displayName,omitempty"`
	// 如不更新，则为空
	Description *string `json:"description,omitempty"`
	// 数据源的访问信息输入
	Endpointinput *EndpointInput `json:"endpointinput,omitempty"`
	// 数据源为对象存储类型时的输入
	Ossinput *OssInput `json:"ossinput,omitempty"`
	// 数据源为Postgresql时的输入
	Pginput *PgInput `json:"pginput,omitempty"`
	// 数据源为Web数据时的输入
	Webinput *WebInput `json:"webinput,omitempty"`
}

更新数据源的输入

type UpdateEmbedderInput 

type UpdateEmbedderInput struct {
	// 待修改模型服务资源名称(必填)
	Name string `json:"name"`
	// 待修改模型服务创建命名空间(必填)
	Namespace string `json:"namespace"`
	// 模型服务资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型服务资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型服务资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型服务资源描述
	Description *string `json:"description,omitempty"`
	// 模型服务访问信息
	Endpointinput *EndpointInput `json:"endpointinput,omitempty"`
	// 向量化模型服务接口类型
	// 规则:  目前支持 zhipuai,openai两种接口类型
	Type *string `json:"type,omitempty"`
	// 此Embedder支持调用的模型列表
	Models []string `json:"models,omitempty"`
}

type UpdateKnowledgeBaseInput 

type UpdateKnowledgeBaseInput struct {
	// 知识库资源名称（不可同名）
	Name string `json:"name"`
	// 知识库创建命名空间
	Namespace string `json:"namespace"`
	// 知识库资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 知识库资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 如不更新，则为空
	DisplayName *string `json:"displayName,omitempty"`
	// 如不更新，则为空
	Description *string `json:"description,omitempty"`
	// 更新知识库文件
	FileGroups []*Filegroupinput `json:"fileGroups,omitempty"`
	// chunkSize为知识库做文档拆分时的块大小
	ChunkSize *int `json:"chunkSize,omitempty"`
	// chunkOverlap为知识库作文档拆分时相邻块的交集
	ChunkOverlap *int `json:"chunkOverlap,omitempty"`
	// batchSize为知识库做批量处理时的批次大小
	BatchSize *int `json:"batchSize,omitempty"`
}

知识库更新的输入

type UpdateLLMInput 

type UpdateLLMInput struct {
	// 待修改模型服务资源名称(必填)
	Name string `json:"name"`
	// 待修改模型服务创建命名空间(必填)
	Namespace string `json:"namespace"`
	// 模型服务资源标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型服务资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型服务资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型服务资源描述
	Description *string `json:"description,omitempty"`
	// 模型服务访问信息
	Endpointinput *EndpointInput `json:"endpointinput,omitempty"`
	// 模型服务接口类型
	// 规则:  目前支持 zhipuai,openai两种接口类型
	Type *string `json:"type,omitempty"`
	// 此LLM支持调用的模型列表
	Models []string `json:"models,omitempty"`
}

type UpdateModelInput 

type UpdateModelInput struct {
	// 模型资源名称（不可同名）
	Name string `json:"name"`
	// 模型创建命名空间
	Namespace string `json:"namespace"`
	// 模型资标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型资源描述
	Description *string `json:"description,omitempty"`
	// 模型类型
	// 规则: 目前支持 llm和embedding两种模型类型
	// 规则: 如果该模型支持多种模型类型，则可多选。多选后组成的字段通过逗号隔开。如 "llm,embedding"
	Types *string `json:"types,omitempty"`
	// 如果设置从modelscope或者hugginface拉取模型文件，这两个字段会返回模型名字。
	HuggingFaceRepo *string `json:"huggingFaceRepo,omitempty"`
	ModelScopeRepo  *string `json:"modelScopeRepo,omitempty"`
	// 返回模型选择的版本
	Revision *string `json:"revision,omitempty"`
	// local: 从本地的minio来。
	// modelscope: 从modelscope来
	// huggingface: 从huggingface来
	ModelSource *string `json:"modelSource,omitempty"`
}

模型更新的输入

type UpdateModelServiceInput 

type UpdateModelServiceInput struct {
	// 模型资源名称（不可同名）
	Name string `json:"name"`
	// 模型创建命名空间
	Namespace string `json:"namespace"`
	// 模型资标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型资源描述
	Description *string `json:"description,omitempty"`
	// 模型服务能力类型，支持 llm 和 embedding 两种模型类型
	// 规则: 如果该模型支持多种模型类型，则可多选。多选后组成的字段通过逗号隔开。如 "llm,embedding"
	Types *string `json:"types,omitempty"`
	// 模型服务 API 类型
	// 规则：支持 openai, zhipuai 两种类型
	APIType *string `json:"apiType,omitempty"`
	// 模型服务终端输入
	Endpoint EndpointInput `json:"endpoint"`
	// 模型服务的大语言模型列表
	// 规则；如果不填或者为空，则按照模型的API类型获取默认的模型列表
	LlmModels []string `json:"llmModels,omitempty"`
	// 模型服务的Embedding模型列表
	// 规则；如果不填或者为空，则按照模型的API类型获取默认的模型列表
	EmbeddingModels []string `json:"embeddingModels,omitempty"`
}

type UpdateRAGInput added in v0.2.0 

type UpdateRAGInput struct {
	Name               string                          `json:"name"`
	Namespace          string                          `json:"namespace"`
	Labels             map[string]interface{}          `json:"labels,omitempty"`
	Annotations        map[string]interface{}          `json:"annotations,omitempty"`
	DisplayName        *string                         `json:"displayName,omitempty"`
	Description        *string                         `json:"description,omitempty"`
	Application        *TypedObjectReferenceInput      `json:"application,omitempty"`
	Datasets           []*RAGDatasetInput              `json:"datasets,omitempty"`
	JudgeLlm           *TypedObjectReferenceInput      `json:"judgeLLM,omitempty"`
	Metrics            []*RAGMetricInput               `json:"metrics,omitempty"`
	Storage            *PersistentVolumeClaimSpecInput `json:"storage,omitempty"`
	ServiceAccountName *string                         `json:"serviceAccountName,omitempty"`
	Suspend            *bool                           `json:"suspend,omitempty"`
}

type UpdateVersionedDatasetInput 

type UpdateVersionedDatasetInput struct {
	// 这个名字就是metadat.name, 根据name和namespace确定资源
	// name，namespac是不可以更新的。
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
	// 更新的的标签信息，这里涉及到增加或者删除标签，
	// 所以，如果标签有任何改动，传递完整的label。
	// 例如之前的标齐是: abc:def 新增一个标签aa:bb, 那么传递 abc:def, aa:bb
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 传递方式同label
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	DisplayName *string                `json:"displayName,omitempty"`
	Description *string                `json:"description,omitempty"`
	// 更新，删除数据集版本中的文件，传递方式于label相同，完全传递。
	// 如果传递一个空的数组过去，认为是删除全部文件。
	FileGroups []*FileGroup `json:"fileGroups,omitempty"`
	// 修改数据集版本发布状态
	Released *int `json:"released,omitempty"`
}

type UpdateWorkerInput 

type UpdateWorkerInput struct {
	// 模型资源名称（不可同名）
	Name string `json:"name"`
	// 模型创建命名空间
	Namespace string `json:"namespace"`
	// 模型资标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 模型资源注释
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 模型资源展示名称作为显示，并提供编辑
	DisplayName *string `json:"displayName,omitempty"`
	// 模型资源描述
	Description *string `json:"description,omitempty"`
	// Worker类型
	// 支持两种类型:
	// - "fastchat" : fastchat提供的通用的推理服务模式
	// - "fastchat-vllm" : fastchat提供的采用VLLM推理加速的推理服务模式
	// 规则: 如果为空，则不更新；如果type类型与当前类型相同，则不更新
	Type     *string `json:"type,omitempty"`
	Replicas *string `json:"replicas,omitempty"`
	// worker运行所需的资源
	Resources *ResourcesInput `json:"resources,omitempty"`
	// 模型服务的节点亲合度配置
	MatchExpressions []*NodeSelectorRequirementInput `json:"matchExpressions,omitempty"`
	// worker运行配置的环境变量
	AdditionalEnvs map[string]interface{} `json:"additionalEnvs,omitempty"`
}

模型更新的输入

type VersionedDataset 

type VersionedDataset struct {
	// 版本数据集id,为CR资源中的metadata.uid
	ID *string `json:"id,omitempty"`
	// 数据集名称, 这个应该是前端随机生成就可以，没有实际用途
	Name string `json:"name"`
	// 数据集所在的namespace，也是后续桶的名字
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，正查给你这个字段是不需要人写的，自动添加
	Creator *string `json:"creator,omitempty"`
	// 展示名字， 与metadat.name不一样，这个展示名字是可以用中文的
	DisplayName *string `json:"displayName,omitempty"`
	// 描述
	Description *string `json:"description,omitempty"`
	// 所属的数据集
	Dataset TypedObjectReference `json:"dataset"`
	// 更新时间, 这里更新指文件同步，或者数据处理完成后，做的更新操作的时间
	UpdateTimestamp   *time.Time `json:"updateTimestamp,omitempty"`
	CreationTimestamp time.Time  `json:"creationTimestamp"`
	// 数据集所包含的文件，对于文件需要支持过滤和分页
	Files PaginatedResult `json:"files"`
	// 版本名称
	Version string `json:"version"`
	// 该版本是否已经发布, 0是未发布，1是已经发布
	Released int `json:"released"`
	// 文件的同步状态, Processing或者” 表示文件正在同步，Succeede 文件同步成功，Failed 存在文件同步失败
	SyncStatus *string `json:"syncStatus,omitempty"`
	// 文件同步状态信息，表示同步的错误信息
	SyncMsg *string `json:"syncMsg,omitempty"`
	// 数据处理状态，如果为空，表示还没有开始，processing 处理中，process_fail处理失败，process_complete处理完成
	DataProcessStatus *string `json:"dataProcessStatus,omitempty"`
	// 数据处理信息，如果版本数据处理状态失败时，显示失败原因
	DataProcessMsg *string `json:"dataProcessMsg,omitempty"`
}

VersionedDataset 数据集的版本信息。 主要记录版本名字，数据的来源，以及文件的同步状态

func (VersionedDataset) IsPageNode 

func (VersionedDataset) IsPageNode()

type VersionedDatasetMutation 

type VersionedDatasetMutation struct {
	CreateVersionedDataset  VersionedDataset `json:"createVersionedDataset"`
	UpdateVersionedDataset  VersionedDataset `json:"updateVersionedDataset"`
	DeleteVersionedDatasets *string          `json:"deleteVersionedDatasets,omitempty"`
}

type VersionedDatasetMutationResolver 

type VersionedDatasetMutationResolver interface {
	CreateVersionedDataset(ctx context.Context, obj *VersionedDatasetMutation, input CreateVersionedDatasetInput) (*VersionedDataset, error)
	UpdateVersionedDataset(ctx context.Context, obj *VersionedDatasetMutation, input UpdateVersionedDatasetInput) (*VersionedDataset, error)
	DeleteVersionedDatasets(ctx context.Context, obj *VersionedDatasetMutation, input DeleteVersionedDatasetInput) (*string, error)
}

type VersionedDatasetQuery 

type VersionedDatasetQuery struct {
	GetVersionedDataset   VersionedDataset `json:"getVersionedDataset"`
	ListVersionedDatasets PaginatedResult  `json:"listVersionedDatasets"`
}

type VersionedDatasetQueryResolver 

type VersionedDatasetQueryResolver interface {
	GetVersionedDataset(ctx context.Context, obj *VersionedDatasetQuery, name string, namespace string) (*VersionedDataset, error)
	ListVersionedDatasets(ctx context.Context, obj *VersionedDatasetQuery, input ListVersionedDatasetInput) (*PaginatedResult, error)
}

type VersionedDatasetResolver 

type VersionedDatasetResolver interface {
	Files(ctx context.Context, obj *VersionedDataset, input *FileFilter) (*PaginatedResult, error)
}

type Web added in v0.2.0 

type Web struct {
	RecommendIntervalTime *int `json:"recommendIntervalTime,omitempty"`
}

type WebInput added in v0.2.0 

type WebInput struct {
	RecommendIntervalTime int `json:"recommendIntervalTime"`
}

type Worker 

type Worker struct {
	// 模型id,为CR资源中的metadata.uid
	ID *string `json:"id,omitempty"`
	// 名称
	// 规则: 遵循k8s命名
	Name string `json:"name"`
	// 所在的namespace(文件上传时作为bucket)
	// 规则: 获取当前项目对应的命名空间
	// 规则: 非空
	Namespace string `json:"namespace"`
	// 一些用于标记，选择的的标签
	Labels map[string]interface{} `json:"labels,omitempty"`
	// 添加一些辅助性记录信息
	Annotations map[string]interface{} `json:"annotations,omitempty"`
	// 创建者，为当前用户的用户名
	// 规则: webhook启用后自动添加，默认为空
	Creator *string `json:"creator,omitempty"`
	// 展示名
	DisplayName *string `json:"displayName,omitempty"`
	// 描述信息
	Description *string `json:"description,omitempty"`
	// 创建时间
	CreationTimestamp *time.Time `json:"creationTimestamp,omitempty"`
	// 更新时间
	UpdateTimestamp *time.Time `json:"updateTimestamp,omitempty"`
	// Worker类型
	// 支持两种类型:
	// - "fastchat" : fastchat提供的通用的推理服务模式
	// - "fastchat-vllm" : fastchat提供的采用VLLM推理加速的推理服务模式
	// 规则: 如果为空，则默认为 "fastchat"
	Type *string `json:"type,omitempty"`
	// worker对应的模型
	// 规则: 相同namespace下的模型名称
	// 规则: 必填
	Model TypedObjectReference `json:"model"`
	// worker对应的模型类型
	ModelTypes string `json:"modelTypes"`
	// worker运行的Pod副本数量
	// 规则: 默认为1，最大值为1
	// 规则: 为0时，即下线
	Replicas *string `json:"replicas,omitempty"`
	// worker运行所需的资源
	// 规则: 必填
	Resources Resources `json:"resources"`
	// 状态
	// 规则: 目前分为四种状态
	//   - Unknown: 未知
	//   - Pending: 发布中
	//   - Running: 已发布
	//   - Error: 异常
	Status *string `json:"status,omitempty"`
	// 详细的状态消息描述
	Message *string `json:"message,omitempty"`
	// 模型服务的api地址
	API *string `json:"api,omitempty"`
	// 模型服务的节点亲合度配置
	MatchExpressions []*NodeSelectorRequirement `json:"matchExpressions,omitempty"`
	// worker运行配置的环境变量
	AdditionalEnvs map[string]interface{} `json:"additionalEnvs,omitempty"`
}

本地模型服务节点

func (Worker) IsPageNode 

func (Worker) IsPageNode()

type WorkerMutation 

type WorkerMutation struct {
	CreateWorker  Worker  `json:"createWorker"`
	UpdateWorker  Worker  `json:"updateWorker"`
	DeleteWorkers *string `json:"deleteWorkers,omitempty"`
}

type WorkerMutationResolver 

type WorkerMutationResolver interface {
	CreateWorker(ctx context.Context, obj *WorkerMutation, input CreateWorkerInput) (*Worker, error)
	UpdateWorker(ctx context.Context, obj *WorkerMutation, input *UpdateWorkerInput) (*Worker, error)
	DeleteWorkers(ctx context.Context, obj *WorkerMutation, input *DeleteCommonInput) (*string, error)
}

type WorkerQuery 

type WorkerQuery struct {
	GetWorker   Worker          `json:"getWorker"`
	ListWorkers PaginatedResult `json:"listWorkers"`
}

type WorkerQueryResolver 

type WorkerQueryResolver interface {
	GetWorker(ctx context.Context, obj *WorkerQuery, name string, namespace string) (*Worker, error)
	ListWorkers(ctx context.Context, obj *WorkerQuery, input ListWorkerInput) (*PaginatedResult, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.