plugin_services

package
v2.2.1 Latest Latest
Warning

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

 Go to latest Published: Oct 2, 2026 License: AGPL-3.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddPluginIDToContext 

func AddPluginIDToContext(ctx context.Context, pluginID uint) context.Context

func GetPluginIDFromContext 

func GetPluginIDFromContext(ctx context.Context) (uint, bool)

Types

type AIStudioServiceProvider 

type AIStudioServiceProvider interface {
	// Plugin Management Operations
	ListPlugins(ctx context.Context, req *pb.ListPluginsRequest) (*pb.ListPluginsResponse, error)
	GetPlugin(ctx context.Context, req *pb.GetPluginRequest) (*pb.GetPluginResponse, error)
	UpdatePluginConfig(ctx context.Context, req *pb.UpdatePluginConfigRequest) (*pb.UpdatePluginConfigResponse, error)

	// LLM Management Operations
	ListLLMs(ctx context.Context, req *pb.ListLLMsRequest) (*pb.ListLLMsResponse, error)
	GetLLM(ctx context.Context, req *pb.GetLLMRequest) (*pb.GetLLMResponse, error)
	GetLLMPlugins(ctx context.Context, req *pb.GetLLMPluginsRequest) (*pb.GetLLMPluginsResponse, error)
	CreateLLM(ctx context.Context, req *pb.CreateLLMRequest) (*pb.CreateLLMResponse, error)
	UpdateLLM(ctx context.Context, req *pb.UpdateLLMRequest) (*pb.UpdateLLMResponse, error)
	DeleteLLM(ctx context.Context, req *pb.DeleteLLMRequest) (*pb.DeleteLLMResponse, error)

	// Analytics Operations
	GetAnalyticsSummary(ctx context.Context, req *pb.GetAnalyticsSummaryRequest) (*pb.GetAnalyticsSummaryResponse, error)
	GetUsageStatistics(ctx context.Context, req *pb.GetUsageStatisticsRequest) (*pb.GetUsageStatisticsResponse, error)
	GetCostAnalysis(ctx context.Context, req *pb.GetCostAnalysisRequest) (*pb.GetCostAnalysisResponse, error)
	GetChatRecordsPerDay(ctx context.Context, req *pb.GetChatRecordsPerDayRequest) (*pb.GetChatRecordsPerDayResponse, error)
	GetModelUsage(ctx context.Context, req *pb.GetModelUsageRequest) (*pb.GetModelUsageResponse, error)
	GetVendorUsage(ctx context.Context, req *pb.GetVendorUsageRequest) (*pb.GetVendorUsageResponse, error)
	GetTokenUsagePerApp(ctx context.Context, req *pb.GetTokenUsagePerAppRequest) (*pb.GetTokenUsagePerAppResponse, error)
	GetToolUsageStatistics(ctx context.Context, req *pb.GetToolUsageStatisticsRequest) (*pb.GetToolUsageStatisticsResponse, error)

	// App Management Operations
	ListApps(ctx context.Context, req *pb.ListAppsRequest) (*pb.ListAppsResponse, error)
	GetApp(ctx context.Context, req *pb.GetAppRequest) (*pb.GetAppResponse, error)
	CreateApp(ctx context.Context, req *pb.CreateAppRequest) (*pb.CreateAppResponse, error)
	UpdateApp(ctx context.Context, req *pb.UpdateAppRequest) (*pb.UpdateAppResponse, error)
	DeleteApp(ctx context.Context, req *pb.DeleteAppRequest) (*pb.DeleteAppResponse, error)

	// Tool Management Operations
	ListTools(ctx context.Context, req *pb.ListToolsRequest) (*pb.ListToolsResponse, error)
	GetTool(ctx context.Context, req *pb.GetToolRequest) (*pb.GetToolResponse, error)
	GetToolOperations(ctx context.Context, req *pb.GetToolOperationsRequest) (*pb.GetToolOperationsResponse, error)
	CallToolOperation(ctx context.Context, req *pb.CallToolOperationRequest) (*pb.CallToolOperationResponse, error)
	CreateTool(ctx context.Context, req *pb.CreateToolRequest) (*pb.CreateToolResponse, error)
	UpdateTool(ctx context.Context, req *pb.UpdateToolRequest) (*pb.UpdateToolResponse, error)
	DeleteTool(ctx context.Context, req *pb.DeleteToolRequest) (*pb.DeleteToolResponse, error)

	// Datasource Management Operations
	ListDatasources(ctx context.Context, req *pb.ListDatasourcesRequest) (*pb.ListDatasourcesResponse, error)
	GetDatasource(ctx context.Context, req *pb.GetDatasourceRequest) (*pb.GetDatasourceResponse, error)
	CreateDatasource(ctx context.Context, req *pb.CreateDatasourceRequest) (*pb.CreateDatasourceResponse, error)
	UpdateDatasource(ctx context.Context, req *pb.UpdateDatasourceRequest) (*pb.UpdateDatasourceResponse, error)
	DeleteDatasource(ctx context.Context, req *pb.DeleteDatasourceRequest) (*pb.DeleteDatasourceResponse, error)
	SearchDatasources(ctx context.Context, req *pb.SearchDatasourcesRequest) (*pb.SearchDatasourcesResponse, error)
	ProcessDatasourceEmbeddings(ctx context.Context, req *pb.ProcessEmbeddingsRequest) (*pb.ProcessEmbeddingsResponse, error)

	// Data Catalogues Management Operations
	ListDataCatalogues(ctx context.Context, req *pb.ListDataCataloguesRequest) (*pb.ListDataCataloguesResponse, error)
	GetDataCatalogue(ctx context.Context, req *pb.GetDataCatalogueRequest) (*pb.GetDataCatalogueResponse, error)
	CreateDataCatalogue(ctx context.Context, req *pb.CreateDataCatalogueRequest) (*pb.CreateDataCatalogueResponse, error)
	UpdateDataCatalogue(ctx context.Context, req *pb.UpdateDataCatalogueRequest) (*pb.UpdateDataCatalogueResponse, error)
	DeleteDataCatalogue(ctx context.Context, req *pb.DeleteDataCatalogueRequest) (*pb.DeleteDataCatalogueResponse, error)

	// Tags Management Operations
	ListTags(ctx context.Context, req *pb.ListTagsRequest) (*pb.ListTagsResponse, error)
	GetTag(ctx context.Context, req *pb.GetTagRequest) (*pb.GetTagResponse, error)
	CreateTag(ctx context.Context, req *pb.CreateTagRequest) (*pb.CreateTagResponse, error)
	UpdateTag(ctx context.Context, req *pb.UpdateTagRequest) (*pb.UpdateTagResponse, error)
	DeleteTag(ctx context.Context, req *pb.DeleteTagRequest) (*pb.DeleteTagResponse, error)
	SearchTags(ctx context.Context, req *pb.SearchTagsRequest) (*pb.SearchTagsResponse, error)

	// Model Price Management Operations (Critical Priority)
	ListModelPrices(ctx context.Context, req *pb.ListModelPricesRequest) (*pb.ListModelPricesResponse, error)
	GetModelPrice(ctx context.Context, req *pb.GetModelPriceRequest) (*pb.GetModelPriceResponse, error)
	CreateModelPrice(ctx context.Context, req *pb.CreateModelPriceRequest) (*pb.CreateModelPriceResponse, error)
	UpdateModelPrice(ctx context.Context, req *pb.UpdateModelPriceRequest) (*pb.UpdateModelPriceResponse, error)
	DeleteModelPrice(ctx context.Context, req *pb.DeleteModelPriceRequest) (*pb.DeleteModelPriceResponse, error)
	GetModelPricesByVendor(ctx context.Context, req *pb.GetModelPricesByVendorRequest) (*pb.GetModelPricesByVendorResponse, error)

	// Filter Management Operations
	ListFilters(ctx context.Context, req *pb.ListFiltersRequest) (*pb.ListFiltersResponse, error)
	GetFilter(ctx context.Context, req *pb.GetFilterRequest) (*pb.GetFilterResponse, error)
	CreateFilter(ctx context.Context, req *pb.CreateFilterRequest) (*pb.CreateFilterResponse, error)
	UpdateFilter(ctx context.Context, req *pb.UpdateFilterRequest) (*pb.UpdateFilterResponse, error)
	DeleteFilter(ctx context.Context, req *pb.DeleteFilterRequest) (*pb.DeleteFilterResponse, error)

	// Vendor Information Operations
	GetAvailableLLMDrivers(ctx context.Context, req *pb.GetAvailableLLMDriversRequest) (*pb.GetAvailableLLMDriversResponse, error)
	GetAvailableEmbedders(ctx context.Context, req *pb.GetAvailableEmbeddersRequest) (*pb.GetAvailableEmbeddersResponse, error)
	GetAvailableVectorStores(ctx context.Context, req *pb.GetAvailableVectorStoresRequest) (*pb.GetAvailableVectorStoresResponse, error)
}

AIStudioServiceProvider defines the interface for AI Studio plugins to access management services This interface is dependency-free and can be implemented by any package

func NewWorkingServiceProviderAdapter 

func NewWorkingServiceProviderAdapter(service interface{}, pluginID uint) AIStudioServiceProvider

NewWorkingServiceProviderAdapter creates a working service provider that actually calls real services

type ServiceProviderInjectable 

type ServiceProviderInjectable interface {
	InjectServiceProvider(provider AIStudioServiceProvider)
}

ServiceProviderInjectable interface for plugins that can receive service providers

type WorkingServiceProviderAdapter 

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

WorkingServiceProviderAdapter implements AIStudioServiceProvider by directly calling service methods This adapter works around the circular import issue by using interface{} and runtime type assertion

func (*WorkingServiceProviderAdapter) CallToolOperation 

func (p *WorkingServiceProviderAdapter) CallToolOperation(ctx context.Context, req *pb.CallToolOperationRequest) (*pb.CallToolOperationResponse, error)

func (*WorkingServiceProviderAdapter) CreateApp 

func (p *WorkingServiceProviderAdapter) CreateApp(ctx context.Context, req *pb.CreateAppRequest) (*pb.CreateAppResponse, error)

func (*WorkingServiceProviderAdapter) CreateDataCatalogue 

func (p *WorkingServiceProviderAdapter) CreateDataCatalogue(ctx context.Context, req *pb.CreateDataCatalogueRequest) (*pb.CreateDataCatalogueResponse, error)

func (*WorkingServiceProviderAdapter) CreateDatasource 

func (p *WorkingServiceProviderAdapter) CreateDatasource(ctx context.Context, req *pb.CreateDatasourceRequest) (*pb.CreateDatasourceResponse, error)

func (*WorkingServiceProviderAdapter) CreateFilter 

func (p *WorkingServiceProviderAdapter) CreateFilter(ctx context.Context, req *pb.CreateFilterRequest) (*pb.CreateFilterResponse, error)

func (*WorkingServiceProviderAdapter) CreateLLM 

func (p *WorkingServiceProviderAdapter) CreateLLM(ctx context.Context, req *pb.CreateLLMRequest) (*pb.CreateLLMResponse, error)

func (*WorkingServiceProviderAdapter) CreateModelPrice 

func (p *WorkingServiceProviderAdapter) CreateModelPrice(ctx context.Context, req *pb.CreateModelPriceRequest) (*pb.CreateModelPriceResponse, error)

func (*WorkingServiceProviderAdapter) CreateTag 

func (p *WorkingServiceProviderAdapter) CreateTag(ctx context.Context, req *pb.CreateTagRequest) (*pb.CreateTagResponse, error)

func (*WorkingServiceProviderAdapter) CreateTool 

func (p *WorkingServiceProviderAdapter) CreateTool(ctx context.Context, req *pb.CreateToolRequest) (*pb.CreateToolResponse, error)

func (*WorkingServiceProviderAdapter) DeleteApp 

func (p *WorkingServiceProviderAdapter) DeleteApp(ctx context.Context, req *pb.DeleteAppRequest) (*pb.DeleteAppResponse, error)

func (*WorkingServiceProviderAdapter) DeleteDataCatalogue 

func (p *WorkingServiceProviderAdapter) DeleteDataCatalogue(ctx context.Context, req *pb.DeleteDataCatalogueRequest) (*pb.DeleteDataCatalogueResponse, error)

func (*WorkingServiceProviderAdapter) DeleteDatasource 

func (p *WorkingServiceProviderAdapter) DeleteDatasource(ctx context.Context, req *pb.DeleteDatasourceRequest) (*pb.DeleteDatasourceResponse, error)

func (*WorkingServiceProviderAdapter) DeleteFilter 

func (p *WorkingServiceProviderAdapter) DeleteFilter(ctx context.Context, req *pb.DeleteFilterRequest) (*pb.DeleteFilterResponse, error)

func (*WorkingServiceProviderAdapter) DeleteLLM 

func (p *WorkingServiceProviderAdapter) DeleteLLM(ctx context.Context, req *pb.DeleteLLMRequest) (*pb.DeleteLLMResponse, error)

func (*WorkingServiceProviderAdapter) DeleteModelPrice 

func (p *WorkingServiceProviderAdapter) DeleteModelPrice(ctx context.Context, req *pb.DeleteModelPriceRequest) (*pb.DeleteModelPriceResponse, error)

func (*WorkingServiceProviderAdapter) DeleteTag 

func (p *WorkingServiceProviderAdapter) DeleteTag(ctx context.Context, req *pb.DeleteTagRequest) (*pb.DeleteTagResponse, error)

func (*WorkingServiceProviderAdapter) DeleteTool 

func (p *WorkingServiceProviderAdapter) DeleteTool(ctx context.Context, req *pb.DeleteToolRequest) (*pb.DeleteToolResponse, error)

func (*WorkingServiceProviderAdapter) GetAnalyticsSummary 

func (p *WorkingServiceProviderAdapter) GetAnalyticsSummary(ctx context.Context, req *pb.GetAnalyticsSummaryRequest) (*pb.GetAnalyticsSummaryResponse, error)

func (*WorkingServiceProviderAdapter) GetApp 

func (p *WorkingServiceProviderAdapter) GetApp(ctx context.Context, req *pb.GetAppRequest) (*pb.GetAppResponse, error)

func (*WorkingServiceProviderAdapter) GetAvailableEmbedders 

func (p *WorkingServiceProviderAdapter) GetAvailableEmbedders(ctx context.Context, req *pb.GetAvailableEmbeddersRequest) (*pb.GetAvailableEmbeddersResponse, error)

func (*WorkingServiceProviderAdapter) GetAvailableLLMDrivers 

func (p *WorkingServiceProviderAdapter) GetAvailableLLMDrivers(ctx context.Context, req *pb.GetAvailableLLMDriversRequest) (*pb.GetAvailableLLMDriversResponse, error)

func (*WorkingServiceProviderAdapter) GetAvailableVectorStores 

func (p *WorkingServiceProviderAdapter) GetAvailableVectorStores(ctx context.Context, req *pb.GetAvailableVectorStoresRequest) (*pb.GetAvailableVectorStoresResponse, error)

func (*WorkingServiceProviderAdapter) GetChatRecordsPerDay 

func (p *WorkingServiceProviderAdapter) GetChatRecordsPerDay(ctx context.Context, req *pb.GetChatRecordsPerDayRequest) (*pb.GetChatRecordsPerDayResponse, error)

Placeholder implementations for other analytics methods

func (*WorkingServiceProviderAdapter) GetCostAnalysis 

func (p *WorkingServiceProviderAdapter) GetCostAnalysis(ctx context.Context, req *pb.GetCostAnalysisRequest) (*pb.GetCostAnalysisResponse, error)

func (*WorkingServiceProviderAdapter) GetDataCatalogue 

func (p *WorkingServiceProviderAdapter) GetDataCatalogue(ctx context.Context, req *pb.GetDataCatalogueRequest) (*pb.GetDataCatalogueResponse, error)

func (*WorkingServiceProviderAdapter) GetDatasource 

func (p *WorkingServiceProviderAdapter) GetDatasource(ctx context.Context, req *pb.GetDatasourceRequest) (*pb.GetDatasourceResponse, error)

func (*WorkingServiceProviderAdapter) GetFilter 

func (p *WorkingServiceProviderAdapter) GetFilter(ctx context.Context, req *pb.GetFilterRequest) (*pb.GetFilterResponse, error)

func (*WorkingServiceProviderAdapter) GetLLM 

func (p *WorkingServiceProviderAdapter) GetLLM(ctx context.Context, req *pb.GetLLMRequest) (*pb.GetLLMResponse, error)

func (*WorkingServiceProviderAdapter) GetLLMPlugins 

func (p *WorkingServiceProviderAdapter) GetLLMPlugins(ctx context.Context, req *pb.GetLLMPluginsRequest) (*pb.GetLLMPluginsResponse, error)

func (*WorkingServiceProviderAdapter) GetModelPrice 

func (p *WorkingServiceProviderAdapter) GetModelPrice(ctx context.Context, req *pb.GetModelPriceRequest) (*pb.GetModelPriceResponse, error)

func (*WorkingServiceProviderAdapter) GetModelPricesByVendor 

func (p *WorkingServiceProviderAdapter) GetModelPricesByVendor(ctx context.Context, req *pb.GetModelPricesByVendorRequest) (*pb.GetModelPricesByVendorResponse, error)

func (*WorkingServiceProviderAdapter) GetModelUsage 

func (p *WorkingServiceProviderAdapter) GetModelUsage(ctx context.Context, req *pb.GetModelUsageRequest) (*pb.GetModelUsageResponse, error)

func (*WorkingServiceProviderAdapter) GetPlugin 

func (p *WorkingServiceProviderAdapter) GetPlugin(ctx context.Context, req *pb.GetPluginRequest) (*pb.GetPluginResponse, error)

func (*WorkingServiceProviderAdapter) GetTag 

func (p *WorkingServiceProviderAdapter) GetTag(ctx context.Context, req *pb.GetTagRequest) (*pb.GetTagResponse, error)

func (*WorkingServiceProviderAdapter) GetTokenUsagePerApp 

func (p *WorkingServiceProviderAdapter) GetTokenUsagePerApp(ctx context.Context, req *pb.GetTokenUsagePerAppRequest) (*pb.GetTokenUsagePerAppResponse, error)

func (*WorkingServiceProviderAdapter) GetTool 

func (p *WorkingServiceProviderAdapter) GetTool(ctx context.Context, req *pb.GetToolRequest) (*pb.GetToolResponse, error)

func (*WorkingServiceProviderAdapter) GetToolOperations 

func (p *WorkingServiceProviderAdapter) GetToolOperations(ctx context.Context, req *pb.GetToolOperationsRequest) (*pb.GetToolOperationsResponse, error)

func (*WorkingServiceProviderAdapter) GetToolUsageStatistics 

func (p *WorkingServiceProviderAdapter) GetToolUsageStatistics(ctx context.Context, req *pb.GetToolUsageStatisticsRequest) (*pb.GetToolUsageStatisticsResponse, error)

func (*WorkingServiceProviderAdapter) GetUsageStatistics 

func (p *WorkingServiceProviderAdapter) GetUsageStatistics(ctx context.Context, req *pb.GetUsageStatisticsRequest) (*pb.GetUsageStatisticsResponse, error)

func (*WorkingServiceProviderAdapter) GetVendorUsage 

func (p *WorkingServiceProviderAdapter) GetVendorUsage(ctx context.Context, req *pb.GetVendorUsageRequest) (*pb.GetVendorUsageResponse, error)

func (*WorkingServiceProviderAdapter) ListApps 

func (p *WorkingServiceProviderAdapter) ListApps(ctx context.Context, req *pb.ListAppsRequest) (*pb.ListAppsResponse, error)

func (*WorkingServiceProviderAdapter) ListDataCatalogues 

func (p *WorkingServiceProviderAdapter) ListDataCatalogues(ctx context.Context, req *pb.ListDataCataloguesRequest) (*pb.ListDataCataloguesResponse, error)

func (*WorkingServiceProviderAdapter) ListDatasources 

func (p *WorkingServiceProviderAdapter) ListDatasources(ctx context.Context, req *pb.ListDatasourcesRequest) (*pb.ListDatasourcesResponse, error)

func (*WorkingServiceProviderAdapter) ListFilters 

func (p *WorkingServiceProviderAdapter) ListFilters(ctx context.Context, req *pb.ListFiltersRequest) (*pb.ListFiltersResponse, error)

func (*WorkingServiceProviderAdapter) ListLLMs 

func (p *WorkingServiceProviderAdapter) ListLLMs(ctx context.Context, req *pb.ListLLMsRequest) (*pb.ListLLMsResponse, error)

func (*WorkingServiceProviderAdapter) ListModelPrices 

func (p *WorkingServiceProviderAdapter) ListModelPrices(ctx context.Context, req *pb.ListModelPricesRequest) (*pb.ListModelPricesResponse, error)

func (*WorkingServiceProviderAdapter) ListPlugins 

func (p *WorkingServiceProviderAdapter) ListPlugins(ctx context.Context, req *pb.ListPluginsRequest) (*pb.ListPluginsResponse, error)

func (*WorkingServiceProviderAdapter) ListTags 

func (p *WorkingServiceProviderAdapter) ListTags(ctx context.Context, req *pb.ListTagsRequest) (*pb.ListTagsResponse, error)

func (*WorkingServiceProviderAdapter) ListTools 

func (p *WorkingServiceProviderAdapter) ListTools(ctx context.Context, req *pb.ListToolsRequest) (*pb.ListToolsResponse, error)

func (*WorkingServiceProviderAdapter) ProcessDatasourceEmbeddings 

func (p *WorkingServiceProviderAdapter) ProcessDatasourceEmbeddings(ctx context.Context, req *pb.ProcessEmbeddingsRequest) (*pb.ProcessEmbeddingsResponse, error)

func (*WorkingServiceProviderAdapter) SearchDatasources 

func (p *WorkingServiceProviderAdapter) SearchDatasources(ctx context.Context, req *pb.SearchDatasourcesRequest) (*pb.SearchDatasourcesResponse, error)

func (*WorkingServiceProviderAdapter) SearchTags 

func (p *WorkingServiceProviderAdapter) SearchTags(ctx context.Context, req *pb.SearchTagsRequest) (*pb.SearchTagsResponse, error)

func (*WorkingServiceProviderAdapter) UpdateApp 

func (p *WorkingServiceProviderAdapter) UpdateApp(ctx context.Context, req *pb.UpdateAppRequest) (*pb.UpdateAppResponse, error)

func (*WorkingServiceProviderAdapter) UpdateDataCatalogue 

func (p *WorkingServiceProviderAdapter) UpdateDataCatalogue(ctx context.Context, req *pb.UpdateDataCatalogueRequest) (*pb.UpdateDataCatalogueResponse, error)

func (*WorkingServiceProviderAdapter) UpdateDatasource 

func (p *WorkingServiceProviderAdapter) UpdateDatasource(ctx context.Context, req *pb.UpdateDatasourceRequest) (*pb.UpdateDatasourceResponse, error)

func (*WorkingServiceProviderAdapter) UpdateFilter 

func (p *WorkingServiceProviderAdapter) UpdateFilter(ctx context.Context, req *pb.UpdateFilterRequest) (*pb.UpdateFilterResponse, error)

func (*WorkingServiceProviderAdapter) UpdateLLM 

func (p *WorkingServiceProviderAdapter) UpdateLLM(ctx context.Context, req *pb.UpdateLLMRequest) (*pb.UpdateLLMResponse, error)

func (*WorkingServiceProviderAdapter) UpdateModelPrice 

func (p *WorkingServiceProviderAdapter) UpdateModelPrice(ctx context.Context, req *pb.UpdateModelPriceRequest) (*pb.UpdateModelPriceResponse, error)

func (*WorkingServiceProviderAdapter) UpdatePluginConfig 

func (p *WorkingServiceProviderAdapter) UpdatePluginConfig(ctx context.Context, req *pb.UpdatePluginConfigRequest) (*pb.UpdatePluginConfigResponse, error)

func (*WorkingServiceProviderAdapter) UpdateTag 

func (p *WorkingServiceProviderAdapter) UpdateTag(ctx context.Context, req *pb.UpdateTagRequest) (*pb.UpdateTagResponse, error)

func (*WorkingServiceProviderAdapter) UpdateTool 

func (p *WorkingServiceProviderAdapter) UpdateTool(ctx context.Context, req *pb.UpdateToolRequest) (*pb.UpdateToolResponse, 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.