service

package

Go to main page

Versions in this module

v0

v0.12.0

Jul 16, 2026

Changes in this version

+ func APIKeyCreatedEventFromModel(k *model.APIKey) *model.APIKeyCreatedEvent

+ func BackfillAPIKeysToGateway(apiKeyRepo repository.APIKeyRepository, ...)

type APIService

+ func (s *APIService) SetSecretService(ss *SecretService)

type LLMProxyService

+ func (s *LLMProxyService) SetSecretService(ss *SecretService)

type OrganizationService

+ func (s *OrganizationService) ListOrganizationsForUser(userUUID, resolvedOrgUUID string, limit, offset int) ([]api.Organization, int, error)

v0.11.2

Jul 10, 2026

Changes in this version

type SubscriptionPlanService

+ func (s *SubscriptionPlanService) CountPlans(orgUUID string) (int, error)

v0.11.1

Jul 8, 2026

Changes in this version

+ const EventTypeAPIDeleted

+ const EventTypeAPIDeployed

+ const EventTypeAPIKeyCreated

+ const EventTypeAPIKeyRevoked

+ const EventTypeAPIKeyUpdated

+ const EventTypeAPIUndeployed

+ const EventTypeLLMProviderDeleted

+ const EventTypeLLMProviderDeployed

+ const EventTypeLLMProviderUndeployed

+ const EventTypeLLMProxyDeleted

+ const EventTypeLLMProxyDeployed

+ const EventTypeLLMProxyUndeployed

+ const EventTypeMCPProxyDeleted

+ const EventTypeMCPProxyDeployed

+ const EventTypeMCPProxyUndeployed

+ const EventTypeSubscriptionCreated

+ const EventTypeSubscriptionDeleted

+ const EventTypeSubscriptionPlanCreated

+ const EventTypeSubscriptionPlanDeleted

+ const EventTypeSubscriptionPlanUpdated

+ const EventTypeSubscriptionUpdated

+ const EventTypeWebBrokerAPIDeleted

+ const EventTypeWebBrokerAPIDeployed

+ const EventTypeWebBrokerAPIUndeployed

+ const EventTypeWebSubAPIDeleted

+ const EventTypeWebSubAPIDeployed

+ const EventTypeWebSubAPIHmacSecretCreated

+ const EventTypeWebSubAPIHmacSecretDeleted

+ const EventTypeWebSubAPIHmacSecretUpdated

+ const EventTypeWebSubAPIUndeployed

+ const MaxEventPayloadSize

+ type APIKeyService struct

+ func NewAPIKeyService(apiRepo repository.APIRepository, artifactRepo repository.ArtifactRepository, ...) *APIKeyService

+ func (s *APIKeyService) CreateAPIKey(ctx context.Context, apiHandle, kind, orgId, userId string, ...) error

+ func (s *APIKeyService) RevokeAPIKey(ctx context.Context, apiHandle, kind, orgId, keyName, userId string) error

+ func (s *APIKeyService) UpdateAPIKey(ctx context.Context, apiHandle, kind, orgId, keyName, userId string, ...) error

+ type APIKeyUserService struct

+ func NewAPIKeyUserService(apiKeyRepo repository.APIKeyRepository, identity *IdentityService, ...) *APIKeyUserService

+ func (s *APIKeyUserService) ListAPIKeysByUser(ctx context.Context, orgID, username string, types []string) (*api.UserAPIKeyListResponse, error)

+ type APIService struct

+ func NewAPIService(apiRepo repository.APIRepository, projectRepo repository.ProjectRepository, ...) *APIService

+ func (s *APIService) AddGatewaysToAPI(apiUUID string, gatewayIds []string, orgUUID string) (*api.RESTAPIGatewayListResponse, error)

+ func (s *APIService) AddGatewaysToAPIByHandle(handle string, gatewayIds []string, orgId string) (*api.RESTAPIGatewayListResponse, error)

+ func (s *APIService) CreateAPI(req *api.CreateRESTAPIRequest, orgUUID, createdBy string) (*api.RESTAPI, error)

+ func (s *APIService) DeleteAPI(apiUUID, orgUUID, deletedBy string) error

+ func (s *APIService) DeleteAPIByHandle(handle, orgId, deletedBy string) error

+ func (s *APIService) GetAPIByHandle(handle, orgId string) (*api.RESTAPI, error)

+ func (s *APIService) GetAPIByUUID(apiUUID, orgUUID string) (*api.RESTAPI, error)

+ func (s *APIService) GetAPIGateways(apiUUID, orgUUID string) (*api.RESTAPIGatewayListResponse, error)

+ func (s *APIService) GetAPIGatewaysByHandle(handle, orgId string) (*api.RESTAPIGatewayListResponse, error)

+ func (s *APIService) GetAPIsByOrganization(orgUUID string, projectHandle string) ([]api.RESTAPI, error)

+ func (s *APIService) HandleExistsCheck(orgUUID string) func(string) bool

+ func (s *APIService) UpdateAPI(apiUUID string, req *api.RESTAPI, orgUUID, updatedBy string) (*api.RESTAPI, error)

+ func (s *APIService) UpdateAPIByHandle(handle string, req *api.RESTAPI, orgId, updatedBy string) (*api.RESTAPI, error)

+ type AddApplicationAssociationsRequest struct

+ Associations []ApplicationAssociationSelector

+ type ApplicationAssociation struct

+ CreatedAt *time.Time

+ DisplayName string

+ Id string

+ Kind string

+ UpdatedAt *time.Time

+ Version string

+ type ApplicationAssociationListResponse struct

+ Count int

+ List []ApplicationAssociation

+ Pagination api.Pagination

+ type ApplicationAssociationSelector struct

+ Id string

+ Kind string

+ type ApplicationService struct

+ func NewApplicationService(appRepo repository.ApplicationRepository, ...) *ApplicationService

+ func (s *ApplicationService) AddApplicationAssociations(appIDOrHandle string, req *AddApplicationAssociationsRequest, orgID string) (*ApplicationAssociationListResponse, error)

+ func (s *ApplicationService) AddMappedAPIKeys(appIDOrHandle string, req *api.AddApplicationAPIKeysRequest, ...) (*api.MappedAPIKeyListResponse, error)

+ func (s *ApplicationService) CreateApplication(req *api.CreateApplicationRequest, orgID, createdBy string) (*api.Application, error)

+ func (s *ApplicationService) CreateApplicationFromWebhook(handle, name, description, appType, orgID string) (*api.Application, error)

+ func (s *ApplicationService) DeleteApplication(appIDOrHandle, orgID, actor string) error

+ func (s *ApplicationService) GetApplicationByID(appIDOrHandle, orgID string) (*api.Application, error)

+ func (s *ApplicationService) GetApplicationsByOrganization(orgID, projectHandle string, limit, offset int) (*api.ApplicationListResponse, error)

+ func (s *ApplicationService) HandleExistsCheck(orgID string) func(string) bool

+ func (s *ApplicationService) ListApplicationAssociations(appIDOrHandle, orgID string, limit, offset int) (*ApplicationAssociationListResponse, error)

+ func (s *ApplicationService) ListMappedAPIKeys(appIDOrHandle, orgID string, limit, offset int) (*api.MappedAPIKeyListResponse, error)

+ func (s *ApplicationService) ListMappedAPIKeysForAssociation(appIDOrHandle, associationIDOrHandle, orgID string, limit, offset int) (*api.MappedAPIKeyListResponse, error)

+ func (s *ApplicationService) RemoveApplicationAssociation(appIDOrHandle, associationIDOrHandle, orgID string) error

+ func (s *ApplicationService) RemoveMappedAPIKey(appIDOrHandle, keyID, entityID, orgID, userID string) error

+ func (s *ApplicationService) SetAPIKeyApplication(keyName, artifactRef, kind, appIDOrHandle, orgID, userID string) error

+ func (s *ApplicationService) UpdateApplication(appIDOrHandle string, req *api.Application, orgID, userID string) (*api.Application, error)

+ type ArtifactImportService struct

+ func NewArtifactImportService(apiRepo repository.APIRepository, ...) *ArtifactImportService

+ func (s *ArtifactImportService) Import(orgID, gatewayID string, req dto.ImportGatewayArtifactRequest) (*dto.ImportGatewayArtifactResponse, error)

+ func (s *ArtifactImportService) ImportArtifacts(orgID, gatewayID string, reqs []dto.ImportGatewayArtifactRequest) *dto.ImportGatewayArtifactsResponse

+ type DeploymentService struct

+ func NewDeploymentService(apiRepo repository.APIRepository, artifactRepo repository.ArtifactRepository, ...) *DeploymentService

+ func (s *DeploymentService) DeleteDeployment(apiUUID, deploymentID, orgUUID, actor string) error

+ func (s *DeploymentService) DeleteDeploymentByHandle(apiHandle, deploymentID, orgUUID, actor string) error

+ func (s *DeploymentService) DeployAPI(apiUUID string, req *api.DeployRequest, orgUUID, createdBy string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) DeployAPIByHandle(apiHandle string, req *api.DeployRequest, orgUUID, createdBy string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) GetDeployment(apiUUID, deploymentID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) GetDeploymentByHandle(apiHandle, deploymentID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) GetDeploymentContent(apiUUID, deploymentID, orgUUID string) ([]byte, error)

+ func (s *DeploymentService) GetDeploymentContentByHandle(apiHandle, deploymentID, orgUUID string) ([]byte, error)

+ func (s *DeploymentService) GetDeployments(apiUUID, orgUUID string, gatewayID *string, status *string) (*api.DeploymentListResponse, error)

+ func (s *DeploymentService) GetDeploymentsByHandle(apiHandle, gatewayID, status, orgUUID string) (*api.DeploymentListResponse, error)

+ func (s *DeploymentService) HandleDeploymentAck(gatewayID, orgID string, ack *model.DeploymentAckPayload) error

+ func (s *DeploymentService) RestoreDeployment(apiUUID, deploymentID, gatewayID, orgUUID, actor string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) RestoreDeploymentByHandle(apiHandle, deploymentID, gatewayHandle, orgUUID, actor string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) UndeployDeployment(apiUUID, deploymentID, gatewayID, orgUUID, actor string) (*api.DeploymentResponse, error)

+ func (s *DeploymentService) UndeployDeploymentByHandle(apiHandle, deploymentID, gatewayHandle, orgUUID, actor string) (*api.DeploymentResponse, error)

+ type DeploymentTimeoutConfig struct

+ Enabled bool

+ Interval time.Duration

+ Timeout time.Duration

+ type DeploymentTimeoutService struct

+ func NewDeploymentTimeoutService(deploymentRepo repository.DeploymentRepository, config DeploymentTimeoutConfig, ...) *DeploymentTimeoutService

+ func (s *DeploymentTimeoutService) Start(ctx context.Context)

+ type EventDispatcher struct

+ func NewEventDispatcher(hub eventhub.EventHub, manager *ws.Manager, logger *slog.Logger) *EventDispatcher

+ func (d *EventDispatcher) OnGatewayConnected(gatewayID string) error

+ func (d *EventDispatcher) OnGatewayDisconnected(gatewayID string) error

+ func (d *EventDispatcher) Shutdown()

+ type GatewayArtifactImporter interface

+ Import func(ctx *ImportContext) (*ImportResult, error)

+ Kind func() string

+ RequiresProject func() bool

+ type GatewayEventsService struct

+ func NewGatewayEventsService(hub eventhub.EventHub, identity *IdentityService, slogger *slog.Logger) *GatewayEventsService

+ func (s *GatewayEventsService) BroadcastAPIDeletionEvent(gatewayID string, deletion *model.APIDeletionEvent) error

+ func (s *GatewayEventsService) BroadcastAPIKeyCreatedEvent(gatewayID, userId string, event *model.APIKeyCreatedEvent) error

+ func (s *GatewayEventsService) BroadcastAPIKeyRevokedEvent(gatewayID, userId string, event *model.APIKeyRevokedEvent) error

+ func (s *GatewayEventsService) BroadcastAPIKeyUpdatedEvent(gatewayID, userId string, event *model.APIKeyUpdatedEvent) error

+ func (s *GatewayEventsService) BroadcastApplicationUpdatedEvent(gatewayID, userId string, event *model.ApplicationUpdatedEvent) error

+ func (s *GatewayEventsService) BroadcastDeploymentEvent(gatewayID string, deployment *model.DeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastLLMProviderDeletionEvent(gatewayID string, deletion *model.LLMProviderDeletionEvent) error

+ func (s *GatewayEventsService) BroadcastLLMProviderDeploymentEvent(gatewayID string, deployment *model.LLMProviderDeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastLLMProviderUndeploymentEvent(gatewayID string, undeployment *model.LLMProviderUndeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastLLMProxyDeletionEvent(gatewayID string, deletion *model.LLMProxyDeletionEvent) error

+ func (s *GatewayEventsService) BroadcastLLMProxyDeploymentEvent(gatewayID string, deployment *model.LLMProxyDeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastLLMProxyUndeploymentEvent(gatewayID string, undeployment *model.LLMProxyUndeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastMCPProxyDeletionEvent(gatewayID string, deletion *model.MCPProxyDeletionEvent) error

+ func (s *GatewayEventsService) BroadcastMCPProxyDeploymentEvent(gatewayID string, deployment *model.MCPProxyDeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastMCPProxyUndeploymentEvent(gatewayID string, undeployment *model.MCPProxyUndeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastSubscriptionCreatedEvent(gatewayID string, event *model.SubscriptionCreatedEvent) error

+ func (s *GatewayEventsService) BroadcastSubscriptionDeletedEvent(gatewayID string, event *model.SubscriptionDeletedEvent) error

+ func (s *GatewayEventsService) BroadcastSubscriptionPlanCreatedEvent(gatewayID string, event *model.SubscriptionPlanCreatedEvent) error

+ func (s *GatewayEventsService) BroadcastSubscriptionPlanDeletedEvent(gatewayID string, event *model.SubscriptionPlanDeletedEvent) error

+ func (s *GatewayEventsService) BroadcastSubscriptionPlanUpdatedEvent(gatewayID string, event *model.SubscriptionPlanUpdatedEvent) error

+ func (s *GatewayEventsService) BroadcastSubscriptionUpdatedEvent(gatewayID string, event *model.SubscriptionUpdatedEvent) error

+ func (s *GatewayEventsService) BroadcastUndeploymentEvent(gatewayID string, undeployment *model.APIUndeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastWebBrokerAPIDeletionEvent(gatewayID string, deletion *model.WebBrokerAPIDeletionEvent) error

+ func (s *GatewayEventsService) BroadcastWebBrokerAPIDeploymentEvent(gatewayID string, deployment *model.WebBrokerAPIDeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastWebBrokerAPIUndeploymentEvent(gatewayID string, undeployment *model.WebBrokerAPIUndeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastWebSubAPIDeletionEvent(gatewayID string, deletion *model.WebSubAPIDeletionEvent) error

+ func (s *GatewayEventsService) BroadcastWebSubAPIDeploymentEvent(gatewayID string, deployment *model.WebSubAPIDeploymentEvent) error

+ func (s *GatewayEventsService) BroadcastWebSubAPIHmacSecretEvent(gatewayID, action string, event *model.WebSubAPIHmacSecretEvent) error

+ func (s *GatewayEventsService) BroadcastWebSubAPIUndeploymentEvent(gatewayID string, undeployment *model.WebSubAPIUndeploymentEvent) error

+ type GatewayInternalAPIService struct

+ func NewGatewayInternalAPIService(apiRepo repository.APIRepository, ...) *GatewayInternalAPIService

+ func (s *GatewayInternalAPIService) CheckArtifactsExist(orgID string, artifactIDs []string) ([]string, error)

+ func (s *GatewayInternalAPIService) GetAPIByUUID(apiId, orgId string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetAPIKeysByKind(gatewayID, orgID, kind, issuer string) ([]model.InternalAPIKeyItem, error)

+ func (s *GatewayInternalAPIService) GetActiveDeploymentByGateway(apiID, orgID, gatewayID string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetActiveLLMProviderDeploymentByGateway(providerID, orgID, gatewayID string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetActiveLLMProxyDeploymentByGateway(proxyID, orgID, gatewayID string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetActiveMCPProxyDeploymentByGateway(proxyID, orgID, gatewayID string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetActiveWebBrokerAPIDeploymentByGateway(apiID, orgID, gatewayID string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetActiveWebSubAPIDeploymentByGateway(apiID, orgID, gatewayID string) (map[string]string, error)

+ func (s *GatewayInternalAPIService) GetDeploymentContentBatch(orgID, gatewayID string, deploymentIDs []string) (map[string]*model.DeploymentContent, error)

+ func (s *GatewayInternalAPIService) GetDeploymentsByGateway(orgID, gatewayID string, since *time.Time) (*dto.GatewayDeploymentsResponse, error)

+ func (s *GatewayInternalAPIService) GetSecretsByGateway(orgID, gatewayID string, updatedAfter *time.Time) ([]*model.Secret, error)

+ func (s *GatewayInternalAPIService) IsAPIDeployedOnGateway(apiID, gatewayID, orgID string) error

+ func (s *GatewayInternalAPIService) IsSecretDeployedOnGateway(orgID, gatewayID, handle string) (bool, error)

+ func (s *GatewayInternalAPIService) ListSubscriptionPlansForOrg(orgID string) ([]dto.GatewaySubscriptionPlanInfo, error)

+ func (s *GatewayInternalAPIService) ListSubscriptionsForAPI(apiID, orgID string) ([]dto.GatewaySubscriptionInfo, error)

+ func (s *GatewayInternalAPIService) SetEventArtifactRepos(websubRepo repository.WebSubAPIRepository, ...)

+ type GatewayPolicyDefinition struct

+ Description *string

+ DisplayName string

+ ManagedBy string

+ Name string

+ PolicyDefinition map[string]interface{}

+ Version string

+ type GatewayPolicyInput struct

+ Description *string

+ DisplayName string

+ ManagedBy string

+ Name string

+ Parameters map[string]interface{}

+ SystemParameters map[string]interface{}

+ Version string

+ type GatewayService struct

+ func NewGatewayService(gatewayRepo repository.GatewayRepository, ...) *GatewayService

+ func (s *GatewayService) DeleteCustomPolicyByUUID(orgID, policyUUID, version string) error

+ func (s *GatewayService) DeleteGateway(gatewayID, orgID, deletedBy string) error

+ func (s *GatewayService) GetCustomPolicyByUUID(orgID, policyUUID, version string) (*model.CustomPolicy, error)

+ func (s *GatewayService) GetGateway(gatewayId, orgId string) (*api.GatewayResponse, error)

+ func (s *GatewayService) GetGatewayStatus(orgID string, gatewayId *string) (*api.GatewayStatusListResponse, error)

+ func (s *GatewayService) GetStoredManifest(gatewayID, orgID string) (*Manifest, error)

+ func (s *GatewayService) ListCustomPolicies(orgID string) ([]*model.CustomPolicy, error)

+ func (s *GatewayService) ListGateways(orgID *string) (*api.GatewayListResponse, error)

+ func (s *GatewayService) ListTokens(gatewayId, orgId string) ([]api.TokenInfoResponse, error)

+ func (s *GatewayService) ReceiveGatewayManifest(orgID, gatewayID, gatewayVersion, functionalityType string, ...) error

+ func (s *GatewayService) RegisterGateway(orgID string, id *string, displayName, description string, endpoints []string, ...) (*api.GatewayResponse, error)

+ func (s *GatewayService) RevokeToken(gatewayId, tokenId, orgId, revokedBy string) error

+ func (s *GatewayService) RotateToken(gatewayId, orgId, createdBy string) (*api.TokenRotationResponse, error)

+ func (s *GatewayService) SyncCustomPolicy(gatewayID, orgID, policyName, version string) (*model.CustomPolicy, error)

+ func (s *GatewayService) UpdateGateway(gatewayId, orgId, updatedBy string, req *api.GatewayResponse) (*api.GatewayResponse, error)

+ func (s *GatewayService) UpdateGatewayActiveStatus(gatewayId string, isActive bool) error

+ func (s *GatewayService) VerifyToken(plainToken string) (*model.Gateway, error)

+ type IdentityService struct

+ func NewIdentityService(repo repository.UserIdentityMappingRepository) *IdentityService

+ func (s *IdentityService) InternalUserID(r *http.Request) (string, error)

+ func (s *IdentityService) ResolveIdentityField(field **string) error

+ func (s *IdentityService) ResolveIdentityFields(fields []**string) error

+ func (s *IdentityService) SubForUUID(uuid string) (string, error)

+ func (s *IdentityService) SubsForUUIDs(uuids []string) (map[string]string, error)

+ func (s *IdentityService) ToInternalUUID(identity string) (string, error)

+ type ImportContext struct

+ Configuration dto.ArtifactImportConfig

+ CreatedAt time.Time

+ DPID string

+ DeployedAt *time.Time

+ Existing *model.Artifact

+ GatewayID string

+ ID string

+ MetadataMode utils.MetadataWriteMode

+ OrgID string

+ ProjectID string

+ ProjectName string

+ Properties map[string]interface{}

+ Status string

+ UpdatedAt time.Time

+ type ImportResult struct

+ Deployable bool

+ DeployedVersion string

+ ID string

+ type LLMProviderAPIKeyService struct

+ func NewLLMProviderAPIKeyService(llmProviderRepo repository.LLMProviderRepository, ...) *LLMProviderAPIKeyService

+ func (s *LLMProviderAPIKeyService) CreateLLMProviderAPIKey(ctx context.Context, providerID, orgID, userID string, ...) (*api.CreateLLMProviderAPIKeyResponse, error)

+ func (s *LLMProviderAPIKeyService) DeleteLLMProviderAPIKey(ctx context.Context, providerID, orgID, userID, keyName string) error

+ func (s *LLMProviderAPIKeyService) ListLLMProviderAPIKeys(ctx context.Context, providerID, orgID, userID string) (*api.LLMProviderAPIKeyListResponse, error)

+ type LLMProviderDeploymentService struct

+ func NewLLMProviderDeploymentService(providerRepo repository.LLMProviderRepository, ...) *LLMProviderDeploymentService

+ func (s *LLMProviderDeploymentService) DeleteLLMProviderDeployment(providerID, deploymentID, orgUUID string) error

+ func (s *LLMProviderDeploymentService) DeployLLMProvider(providerID string, req *api.DeployRequest, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *LLMProviderDeploymentService) GetLLMProviderDeployment(providerID, deploymentID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *LLMProviderDeploymentService) GetLLMProviderDeployments(providerID, orgUUID string, gatewayID *string, status *string) (*api.DeploymentListResponse, error)

+ func (s *LLMProviderDeploymentService) RestoreLLMProviderDeployment(providerID, deploymentID, gatewayID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *LLMProviderDeploymentService) UndeployLLMProviderDeployment(providerID, deploymentID, gatewayID, orgUUID string) (*api.DeploymentResponse, error)

+ type LLMProviderService struct

+ func NewLLMProviderService(repo repository.LLMProviderRepository, ...) *LLMProviderService

+ func (s *LLMProviderService) Create(orgUUID, createdBy string, req *api.LLMProvider) (*api.LLMProvider, error)

+ func (s *LLMProviderService) Delete(orgUUID, handle, deletedBy string) error

+ func (s *LLMProviderService) Get(orgUUID, handle string) (*api.LLMProvider, error)

+ func (s *LLMProviderService) List(orgUUID string, limit, offset int) (*api.LLMProviderListResponse, error)

+ func (s *LLMProviderService) SetSecretService(ss *SecretService)

+ func (s *LLMProviderService) Update(orgUUID, handle, updatedBy string, req *api.LLMProvider) (*api.LLMProvider, error)

+ type LLMProviderTemplateService struct

+ func NewLLMProviderTemplateService(repo repository.LLMProviderTemplateRepository, ...) *LLMProviderTemplateService

+ func (s *LLMProviderTemplateService) CopyVersion(orgUUID, fromTemplateID, toTemplateID, toVersion, createdBy string, ...) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) Create(orgUUID, createdBy string, req *api.LLMProviderTemplate) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) CreateVersion(orgUUID, groupID, createdBy string, ...) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) DeleteByHandle(orgUUID, handle string) error

+ func (s *LLMProviderTemplateService) DeleteVersion(orgUUID, groupID, version string) error

+ func (s *LLMProviderTemplateService) Get(orgUUID, handle string) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) GetVersion(orgUUID, groupID, version string) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) List(orgUUID string, limit, offset int, latestOnly bool) (*api.LLMProviderTemplateListResponse, error)

+ func (s *LLMProviderTemplateService) ListVersions(orgUUID, groupID string, limit, offset int) (*api.LLMProviderTemplateListResponse, error)

+ func (s *LLMProviderTemplateService) SetEnabledByHandle(orgUUID, handle string, enabled bool) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) SetVersionEnabled(orgUUID, groupID, version string, enabled bool) (*api.LLMProviderTemplate, error)

+ func (s *LLMProviderTemplateService) Update(orgUUID, handle, updatedBy string, req *api.LLMProviderTemplate) (*api.LLMProviderTemplate, error)

+ type LLMProxyAPIKeyService struct

+ func NewLLMProxyAPIKeyService(llmProxyRepo repository.LLMProxyRepository, ...) *LLMProxyAPIKeyService

+ func (s *LLMProxyAPIKeyService) CreateLLMProxyAPIKey(ctx context.Context, proxyID, orgID, userID string, ...) (*api.CreateLLMProxyAPIKeyResponse, error)

+ func (s *LLMProxyAPIKeyService) DeleteLLMProxyAPIKey(ctx context.Context, proxyID, orgID, userID, keyName string) error

+ func (s *LLMProxyAPIKeyService) ListLLMProxyAPIKeys(ctx context.Context, proxyID, orgID, userID string) (*api.LLMProxyAPIKeyListResponse, error)

+ type LLMProxyDeploymentService struct

+ func NewLLMProxyDeploymentService(proxyRepo repository.LLMProxyRepository, ...) *LLMProxyDeploymentService

+ func (s *LLMProxyDeploymentService) DeleteLLMProxyDeployment(proxyID, deploymentID, orgUUID string) error

+ func (s *LLMProxyDeploymentService) DeployLLMProxy(proxyID string, req *api.DeployRequest, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *LLMProxyDeploymentService) GetLLMProxyDeployment(proxyID, deploymentID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *LLMProxyDeploymentService) GetLLMProxyDeployments(proxyID, orgUUID string, gatewayID *string, status *string) (*api.DeploymentListResponse, error)

+ func (s *LLMProxyDeploymentService) RestoreLLMProxyDeployment(proxyID, deploymentID, gatewayID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *LLMProxyDeploymentService) UndeployLLMProxyDeployment(proxyID, deploymentID, gatewayID, orgUUID string) (*api.DeploymentResponse, error)

+ type LLMProxyService struct

+ func NewLLMProxyService(repo repository.LLMProxyRepository, ...) *LLMProxyService

+ func (s *LLMProxyService) Create(orgUUID, createdBy string, req *api.LLMProxy) (*api.LLMProxy, error)

+ func (s *LLMProxyService) Delete(orgUUID, handle, deletedBy string) error

+ func (s *LLMProxyService) Get(orgUUID, handle string) (*api.LLMProxy, error)

+ func (s *LLMProxyService) List(orgUUID string, projectHandle *string, limit, offset int) (*api.LLMProxyListResponse, error)

+ func (s *LLMProxyService) ListByProvider(orgUUID, providerID string, limit, offset int) (*api.LLMProxyListResponse, error)

+ func (s *LLMProxyService) Update(orgUUID, handle, updatedBy string, req *api.LLMProxy) (*api.LLMProxy, error)

+ type LLMTemplateSeeder struct

+ func NewLLMTemplateSeeder(repo repository.LLMProviderTemplateRepository, ...) *LLMTemplateSeeder

+ func (s *LLMTemplateSeeder) SeedForOrg(orgUUID string) error

+ type MCPDeploymentService struct

+ func NewMCPDeploymentService(mcpRepo repository.MCPProxyRepository, ...) *MCPDeploymentService

+ func (s *MCPDeploymentService) DeleteDeploymentByHandle(proxyHandle, deploymentID, orgUUID string) error

+ func (s *MCPDeploymentService) DeployMCPProxyByHandle(proxyHandle string, req *api.DeployRequest, orgUUID, createdBy string) (*api.DeploymentResponse, error)

+ func (s *MCPDeploymentService) GetDeploymentByHandle(proxyHandle, deploymentID, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *MCPDeploymentService) GetDeploymentsByHandle(proxyHandle, gatewayID, status, orgUUID string) (*api.DeploymentListResponse, error)

+ func (s *MCPDeploymentService) RestoreMCPDeploymentByHandle(proxyHandle, deploymentID, gatewayHandle, orgUUID string) (*api.DeploymentResponse, error)

+ func (s *MCPDeploymentService) UndeployDeploymentByHandle(proxyHandle, deploymentID, gatewayHandle, orgUUID string) (*api.DeploymentResponse, error)

+ type MCPProxyService struct

+ func NewMCPProxyService(repo repository.MCPProxyRepository, projectRepo repository.ProjectRepository, ...) *MCPProxyService

+ func (s *MCPProxyService) Create(orgUUID, createdBy string, req *api.MCPProxy) (*api.MCPProxy, error)

+ func (s *MCPProxyService) Delete(orgUUID, handle, deletedBy string) error

+ func (s *MCPProxyService) FetchServerInfo(orgUUID string, req *api.MCPServerInfoFetchRequest) (*api.MCPServerInfoFetchResponse, error)

+ func (s *MCPProxyService) Get(orgUUID, handle string) (*api.MCPProxy, error)

+ func (s *MCPProxyService) List(orgUUID string, limit, offset int) (*api.MCPProxyListResponse, error)

+ func (s *MCPProxyService) ListByProject(orgUUID, projectHandle string, limit, offset int) (*api.MCPProxyListResponse, error)

+ func (s *MCPProxyService) Update(orgUUID, handle, updatedBy string, req *api.MCPProxy) (*api.MCPProxy, error)

+ func (s *MCPProxyService) WithSecretService(ss *SecretService)

+ type MCPServerInfoFetcher interface

+ FetchServerInfo func(orgUUID string, req *api.MCPServerInfoFetchRequest) (*api.MCPServerInfoFetchResponse, error)

+ type Manifest struct

+ Policies json.RawMessage

+ type OrganizationService struct

+ func NewOrganizationService(orgRepo repository.OrganizationRepository, ...) *OrganizationService

+ func (s *OrganizationService) GetOrganizationByHandle(handle string) (*api.Organization, error)

+ func (s *OrganizationService) GetOrganizationByUUID(orgId string) (*api.Organization, error)

+ func (s *OrganizationService) ListOrganizations(limit, offset int) ([]api.Organization, int, error)

+ func (s *OrganizationService) RegisterOrganization(id string, handle string, name string, region string, idpOrgRefUUID string, ...) (*api.Organization, error)

+ type ProjectDeletionGuard interface

+ CheckProjectDeletion func(orgID, projectID string) error

+ type ProjectService struct

+ func NewProjectService(projectRepo repository.ProjectRepository, ...) *ProjectService

+ func (s *ProjectService) CreateProject(req *api.CreateProjectRequest, organizationID, actor string) (*api.Project, error)

+ func (s *ProjectService) DeleteProject(handle, orgId, actor string) error

+ func (s *ProjectService) GetProjectByHandle(handle, orgId string) (*api.Project, error)

+ func (s *ProjectService) GetProjectsByOrganization(organizationID string) ([]api.Project, error)

+ func (s *ProjectService) RegisterDeletionGuard(guard ProjectDeletionGuard)

+ func (s *ProjectService) UpdateProject(handle string, req *api.Project, orgId, actor string) (*api.Project, error)

+ type SecretInUseError struct

+ References []model.SecretReference

+ func (e *SecretInUseError) Error() string

+ type SecretService struct

+ func NewSecretService(repo repository.SecretRepository, v vault.SecretVault, ...) *SecretService

+ func (s *SecretService) Create(orgID, createdBy string, req *dto.CreateSecretRequest) (*dto.SecretResponse, error)

+ func (s *SecretService) Decrypt(orgID, handle string) (string, error)

+ func (s *SecretService) DecryptCiphertext(ciphertext []byte) (string, error)

+ func (s *SecretService) Delete(orgID, handle, updatedBy string) error

+ func (s *SecretService) Get(orgID, handle string) (*dto.SecretSummary, error)

+ func (s *SecretService) List(orgID string, limit, offset int, updatedAfter *time.Time) (*dto.SecretListResponse, error)

+ func (s *SecretService) Update(orgID, handle, updatedBy string, req *dto.UpdateSecretRequest) (*dto.SecretResponse, error)

+ func (s *SecretService) ValidateSecretRefs(orgID, configText string) error

+ type SubscriptionPlanService struct

+ func NewSubscriptionPlanService(planRepo repository.SubscriptionPlanRepository, ...) *SubscriptionPlanService

+ func (s *SubscriptionPlanService) CreatePlan(orgUUID, actor string, plan *model.SubscriptionPlan) (*model.SubscriptionPlan, error)

+ func (s *SubscriptionPlanService) DeletePlan(handle, orgUUID, actor string) error

+ func (s *SubscriptionPlanService) GetPlan(handle, orgUUID string) (*model.SubscriptionPlan, error)

+ func (s *SubscriptionPlanService) GetPlanNameMap(planIDs []string, orgUUID string) (map[string]string, error)

+ func (s *SubscriptionPlanService) ListPlans(orgUUID string, limit, offset int) ([]*model.SubscriptionPlan, error)

+ func (s *SubscriptionPlanService) ResolveOrgHandle(orgUUID string) string

+ func (s *SubscriptionPlanService) UpdatePlan(handle, orgUUID, actor string, update *model.SubscriptionPlanUpdate) (*model.SubscriptionPlan, error)

+ type SubscriptionService struct

+ func NewSubscriptionService(apiRepo repository.APIRepository, artifactRepo repository.ArtifactRepository, ...) *SubscriptionService

+ func (s *SubscriptionService) ChangePlan(subscriptionId, orgUUID, subscriberID, planHandle string) (*model.Subscription, error)

+ func (s *SubscriptionService) CreateSubscription(apiId, kind, orgUUID string, subscriberID string, applicationId *string, ...) (*model.Subscription, error)

+ func (s *SubscriptionService) DeleteSubscription(subscriptionId, orgUUID, subscriberID, actor string) error

+ func (s *SubscriptionService) FindByArtifactKindAndSubscriber(orgUUID, apiHandle, kind, subscriberID string) (*model.Subscription, error)

+ func (s *SubscriptionService) GetArtifactMetadataMap(uuids []string, orgUUID string) (map[string]*model.APIMetadata, error)

+ func (s *SubscriptionService) GetSubscription(subscriptionId, orgUUID string) (*model.Subscription, error)

+ func (s *SubscriptionService) ListSubscriptionsByFilters(orgUUID string, apiId *string, subscriberID *string, applicationID *string, ...) ([]*model.Subscription, int, error)

+ func (s *SubscriptionService) RegenerateToken(subscriptionId, orgUUID, subscriberID, newToken string) (*model.Subscription, error)

+ func (s *SubscriptionService) ResolveArtifactHandleAndKind(artifactUUID, orgUUID string) (handle, kind string)

+ func (s *SubscriptionService) ResolveOrgHandle(orgUUID string) string

+ func (s *SubscriptionService) UpdateSubscription(subscriptionId, orgUUID, subscriberID, status, actor string) (*model.Subscription, error)

v0.11.0-cloud1

Jul 8, 2026

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