repository

package

Go to main page

Versions in this module

v0

v0.12.0

Jul 16, 2026

Changes in this version

type OrganizationRepo

+ func (r *OrganizationRepo) CountOrganizationsForUser(userUUID string) (int, error)

+ func (r *OrganizationRepo) ListOrganizationsForUser(userUUID string, limit, offset int) ([]*model.Organization, error)

type OrganizationRepository

+ CountOrganizationsForUser func(userUUID string) (int, error)

+ ListOrganizationsForUser func(userUUID string, limit, offset int) ([]*model.Organization, error)

v0.11.2

Jul 10, 2026

Changes in this version

+ func IsUniqueViolation(err error) bool

type APIRepo

+ func (r *APIRepo) CountAPIsByOrganizationUUID(orgUUID, projectUUID, search string) (int, error)

+ func (r *APIRepo) GetAPIsByOrganizationUUIDPaginated(orgUUID, projectUUID string, opts ListOptions) ([]*model.API, error)

type APIRepository

+ CountAPIsByOrganizationUUID func(orgUUID, projectUUID, search string) (int, error)

+ GetAPIsByOrganizationUUIDPaginated func(orgUUID, projectUUID string, opts ListOptions) ([]*model.API, error)

type GatewayRepo

+ func (r *GatewayRepo) CountGateways(orgID, search string) (int, error)

+ func (r *GatewayRepo) ListPaginated(orgID string, opts ListOptions) ([]*model.Gateway, error)

type GatewayRepository

+ CountGateways func(orgID, search string) (int, error)

+ ListPaginated func(orgID string, opts ListOptions) ([]*model.Gateway, error)

+ type ListOptions struct

+ Limit int

+ Offset int

+ Search string

+ SortBy string

+ SortOrder string

type ProjectRepo

+ func (r *ProjectRepo) CountProjects(orgID, search string) (int, error)

type ProjectRepository

+ CountProjects func(orgID, search string) (int, error)

type SubscriptionPlanRepo

+ func (r *SubscriptionPlanRepo) CountByOrganization(orgUUID string) (int, error)

type SubscriptionPlanRepository

+ CountByOrganization func(orgUUID string) (int, error)

v0.11.1

Jul 8, 2026

Changes in this version

+ func HashSubscriptionToken(token string) string

+ type APIKeyRepo struct

+ func (r *APIKeyRepo) Create(key *model.APIKey) error

+ func (r *APIKeyRepo) Delete(artifactUUID, name string) error

+ func (r *APIKeyRepo) GetByArtifactAndName(artifactUUID, name string) (*model.APIKey, error)

+ func (r *APIKeyRepo) ListAPIKeysByUser(orgUUID, username string, kinds []string) ([]*model.UserAPIKey, error)

+ func (r *APIKeyRepo) ListByArtifact(artifactUUID string) ([]*model.APIKey, error)

+ func (r *APIKeyRepo) ListByGatewayAndKind(gatewayID, orgID, kind, issuer string) ([]*model.APIKey, error)

+ func (r *APIKeyRepo) Revoke(artifactUUID, name string) error

+ func (r *APIKeyRepo) Update(key *model.APIKey) error

+ type APIKeyRepository interface

+ Create func(key *model.APIKey) error

+ Delete func(artifactUUID, name string) error

+ GetByArtifactAndName func(artifactUUID, name string) (*model.APIKey, error)

+ ListAPIKeysByUser func(orgUUID, username string, kinds []string) ([]*model.UserAPIKey, error)

+ ListByArtifact func(artifactUUID string) ([]*model.APIKey, error)

+ ListByGatewayAndKind func(gatewayID, orgID, kind, issuer string) ([]*model.APIKey, error)

+ Revoke func(artifactUUID, name string) error

+ Update func(key *model.APIKey) error

+ func NewAPIKeyRepo(db *database.DB, reg *ArtifactTableRegistry) APIKeyRepository

+ type APIRepo struct

+ func (r *APIRepo) CheckAPIExistsByHandleInOrganization(handle, orgUUID string) (bool, error)

+ func (r *APIRepo) CheckAPIExistsByNameAndVersionInOrganization(name, version, orgUUID, excludeHandle string) (bool, error)

+ func (r *APIRepo) CreateAPI(api *model.API) error

+ func (r *APIRepo) CreateAPIAssociation(association *model.APIAssociation) error

+ func (r *APIRepo) DeleteAPI(apiUUID, orgUUID string) error

+ func (r *APIRepo) GetAPIAssociations(apiUUID, associationType, orgUUID string) ([]*model.APIAssociation, error)

+ func (r *APIRepo) GetAPIByUUID(apiUUID, orgUUID string) (*model.API, error)

+ func (r *APIRepo) GetAPIGatewaysWithDetails(apiUUID, orgUUID string) ([]*model.APIGatewayWithDetails, error)

+ func (r *APIRepo) GetAPIMetadataByHandle(handle, orgUUID string) (*model.APIMetadata, error)

+ func (r *APIRepo) GetAPIsByGatewayUUID(gatewayUUID, orgUUID string) ([]*model.API, error)

+ func (r *APIRepo) GetAPIsByOrganizationUUID(orgUUID string, projectUUID string) ([]*model.API, error)

+ func (r *APIRepo) GetAPIsByProjectUUID(projectUUID, orgUUID string) ([]*model.API, error)

+ func (r *APIRepo) GetAPIsByUUIDs(uuids []string, orgUUID string) (map[string]string, error)

+ func (r *APIRepo) UpdateAPI(api *model.API) error

+ func (r *APIRepo) UpdateAPIAssociation(apiUUID, resourceId, associationType, orgUUID string) error

+ type APIRepository interface

+ CheckAPIExistsByHandleInOrganization func(handle, orgUUID string) (bool, error)

+ CheckAPIExistsByNameAndVersionInOrganization func(name, version, orgUUID, excludeHandle string) (bool, error)

+ CreateAPI func(api *model.API) error

+ CreateAPIAssociation func(association *model.APIAssociation) error

+ DeleteAPI func(apiUUID, orgUUID string) error

+ GetAPIAssociations func(apiUUID, associationType, orgUUID string) ([]*model.APIAssociation, error)

+ GetAPIByUUID func(apiUUID, orgUUID string) (*model.API, error)

+ GetAPIGatewaysWithDetails func(apiUUID, orgUUID string) ([]*model.APIGatewayWithDetails, error)

+ GetAPIMetadataByHandle func(handle, orgUUID string) (*model.APIMetadata, error)

+ GetAPIsByGatewayUUID func(gatewayUUID, orgUUID string) ([]*model.API, error)

+ GetAPIsByOrganizationUUID func(orgUUID string, projectUUID string) ([]*model.API, error)

+ GetAPIsByProjectUUID func(projectUUID, orgUUID string) ([]*model.API, error)

+ GetAPIsByUUIDs func(uuids []string, orgUUID string) (map[string]string, error)

+ UpdateAPI func(api *model.API) error

+ UpdateAPIAssociation func(apiUUID, resourceId, associationType, orgUUID string) error

+ func NewAPIRepo(db *database.DB) APIRepository

+ type ApplicationRepo struct

+ func (r *ApplicationRepo) AddApplicationAPIKeys(applicationUUID string, apiKeyIDs []string) error

+ func (r *ApplicationRepo) AddApplicationAssociations(applicationUUID string, targetUUIDs []string) error

+ func (r *ApplicationRepo) CheckApplicationHandleExists(handle, orgID string) (bool, error)

+ func (r *ApplicationRepo) CountApplicationsByOrganizationID(orgID string) (int, error)

+ func (r *ApplicationRepo) CountApplicationsByProjectID(projectID, orgID string) (int, error)

+ func (r *ApplicationRepo) CreateApplication(app *model.Application) error

+ func (r *ApplicationRepo) DeleteApplication(appID, orgID string) error

+ func (r *ApplicationRepo) GetAPIKeyByNameAndArtifactHandle(keyName, artifactHandle, orgID string) (*model.ApplicationAPIKey, error)

+ func (r *ApplicationRepo) GetApplicationByIDOrHandle(appIDOrHandle, orgID string) (*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationByNameInProject(name, projectID, orgID string) (*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationByUUID(appID string) (*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationsByAPIKeyID(apiKeyID, orgID string) ([]*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationsByOrganizationID(orgID string) ([]*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationsByOrganizationIDPaginated(orgID string, _, _ int) ([]*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationsByProjectID(projectID, orgID string) ([]*model.Application, error)

+ func (r *ApplicationRepo) GetApplicationsByProjectIDPaginated(projectID, orgID string, _, _ int) ([]*model.Application, error)

+ func (r *ApplicationRepo) GetAssociationTargetByIDOrHandle(targetIDOrHandle, orgID string) (*model.Artifact, error)

+ func (r *ApplicationRepo) GetAssociationTargetByIDOrHandleAndKind(targetIDOrHandle, kind, orgID string) (*model.Artifact, error)

+ func (r *ApplicationRepo) GetAssociationTargetByUUID(targetUUID, orgID string) (*model.Artifact, error)

+ func (r *ApplicationRepo) GetDeployedGatewayIDsByArtifactUUID(artifactUUID, orgID string) ([]string, error)

+ func (r *ApplicationRepo) GetLLMProxyProjectUUID(targetUUID, orgID string) (string, error)

+ func (r *ApplicationRepo) ListApplicationAssociations(applicationUUID string) ([]*model.ApplicationAssociationTarget, error)

+ func (r *ApplicationRepo) ListMappedAPIKeys(applicationUUID string) ([]*model.ApplicationAPIKey, error)

+ func (r *ApplicationRepo) RemoveAPIKeyFromAllApplications(apiKeyID string) error

+ func (r *ApplicationRepo) RemoveApplicationAPIKey(applicationUUID, apiKeyID string) error

+ func (r *ApplicationRepo) RemoveApplicationAssociation(applicationUUID, targetUUID string) error

+ func (r *ApplicationRepo) UpdateApplication(app *model.Application) error

+ type ApplicationRepository interface

+ AddApplicationAPIKeys func(applicationUUID string, apiKeyIDs []string) error

+ AddApplicationAssociations func(applicationUUID string, targetUUIDs []string) error

+ CheckApplicationHandleExists func(handle, orgID string) (bool, error)

+ CountApplicationsByOrganizationID func(orgID string) (int, error)

+ CountApplicationsByProjectID func(projectID, orgID string) (int, error)

+ CreateApplication func(app *model.Application) error

+ DeleteApplication func(appID, orgID string) error

+ GetAPIKeyByNameAndArtifactHandle func(keyName, artifactHandle, orgID string) (*model.ApplicationAPIKey, error)

+ GetApplicationByIDOrHandle func(appIDOrHandle, orgID string) (*model.Application, error)

+ GetApplicationByNameInProject func(name, projectID, orgID string) (*model.Application, error)

+ GetApplicationByUUID func(appID string) (*model.Application, error)

+ GetApplicationsByAPIKeyID func(apiKeyID, orgID string) ([]*model.Application, error)

+ GetApplicationsByOrganizationID func(orgID string) ([]*model.Application, error)

+ GetApplicationsByOrganizationIDPaginated func(orgID string, limit, offset int) ([]*model.Application, error)

+ GetApplicationsByProjectID func(projectID, orgID string) ([]*model.Application, error)

+ GetApplicationsByProjectIDPaginated func(projectID, orgID string, limit, offset int) ([]*model.Application, error)

+ GetAssociationTargetByIDOrHandle func(targetIDOrHandle, orgID string) (*model.Artifact, error)

+ GetAssociationTargetByIDOrHandleAndKind func(targetIDOrHandle, kind, orgID string) (*model.Artifact, error)

+ GetAssociationTargetByUUID func(targetUUID, orgID string) (*model.Artifact, error)

+ GetDeployedGatewayIDsByArtifactUUID func(artifactUUID, orgID string) ([]string, error)

+ GetLLMProxyProjectUUID func(artifactUUID, orgID string) (string, error)

+ ListApplicationAssociations func(applicationUUID string) ([]*model.ApplicationAssociationTarget, error)

+ ListMappedAPIKeys func(applicationUUID string) ([]*model.ApplicationAPIKey, error)

+ RemoveAPIKeyFromAllApplications func(apiKeyID string) error

+ RemoveApplicationAPIKey func(applicationUUID, apiKeyID string) error

+ RemoveApplicationAssociation func(applicationUUID, targetUUID string) error

+ UpdateApplication func(app *model.Application) error

+ func NewApplicationRepo(db *database.DB, reg *ArtifactTableRegistry) ApplicationRepository

+ type ArtifactRepo struct

+ func NewArtifactRepo(db *database.DB, reg ...*ArtifactTableRegistry) *ArtifactRepo

+ func (r *ArtifactRepo) CountByKindAndOrg(kind, orgUUID string) (int, error)

+ func (r *ArtifactRepo) Create(tx *sql.Tx, artifact *model.Artifact) error

+ func (r *ArtifactRepo) Delete(tx *sql.Tx, uuid string) error

+ func (r *ArtifactRepo) Exists(kind, handle, orgUUID string) (bool, error)

+ func (r *ArtifactRepo) ExistsByUUIDs(uuids []string, orgUUID string) ([]string, error)

+ func (r *ArtifactRepo) GetAPIMetadataByHandle(handle, orgUUID string) (*model.APIMetadata, error)

+ func (r *ArtifactRepo) GetAPIMetadataByHandleAndKind(handle, kind, orgUUID string) (*model.APIMetadata, error)

+ func (r *ArtifactRepo) GetByHandle(handle, orgUUID string) (*model.Artifact, error)

+ func (r *ArtifactRepo) GetByUUID(uuid, orgUUID string) (*model.Artifact, error)

+ func (r *ArtifactRepo) GetMetadataByUUIDs(uuids []string, orgUUID string) (map[string]*model.APIMetadata, error)

+ func (r *ArtifactRepo) Update(_ *sql.Tx, _ *model.Artifact) error

+ type ArtifactRepository interface

+ CountByKindAndOrg func(kind, orgUUID string) (int, error)

+ Create func(tx *sql.Tx, artifact *model.Artifact) error

+ Delete func(tx *sql.Tx, uuid string) error

+ Exists func(kind, handle, orgUUID string) (bool, error)

+ ExistsByUUIDs func(uuids []string, orgUUID string) ([]string, error)

+ GetAPIMetadataByHandle func(handle, orgUUID string) (*model.APIMetadata, error)

+ GetAPIMetadataByHandleAndKind func(handle, kind, orgUUID string) (*model.APIMetadata, error)

+ GetByHandle func(handle, orgUUID string) (*model.Artifact, error)

+ GetByUUID func(uuid, orgUUID string) (*model.Artifact, error)

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

+ Update func(tx *sql.Tx, artifact *model.Artifact) error

+ type ArtifactTableEntry struct

+ KindAlias string

+ KindKeys []string

+ Table string

+ type ArtifactTableRegistry struct

+ func NewArtifactTableRegistry() *ArtifactTableRegistry

+ func (r *ArtifactTableRegistry) Entries() []ArtifactTableEntry

+ func (r *ArtifactTableRegistry) IsValidKindAlias(alias string) bool

+ func (r *ArtifactTableRegistry) Register(e ArtifactTableEntry)

+ func (r *ArtifactTableRegistry) TableByKindKey(key string) (ArtifactTableEntry, bool)

+ func (r *ArtifactTableRegistry) UnionAllSelect(cols ...string) string

+ type AuditRepo struct

+ func (r *AuditRepo) Record(action, resourceUUID, resourceType, orgUUID, performedBy string) error

+ type AuditRepository interface

+ Record func(action, resourceUUID, resourceType, orgUUID, performedBy string) error

+ func NewAuditRepo(db *database.DB) AuditRepository

+ type CustomPolicyRepo struct

+ func (r *CustomPolicyRepo) CountCustomPolicyUsages(policyUUID string) (int, error)

+ func (r *CustomPolicyRepo) DeleteCustomPolicy(orgUUID, name, version string) error

+ func (r *CustomPolicyRepo) DeleteCustomPolicyIfUnused(orgUUID, policyUUID string) error

+ func (r *CustomPolicyRepo) DeleteCustomPolicyUsage(policyUUID, apiUUID string) error

+ func (r *CustomPolicyRepo) GetCustomPoliciesByName(orgUUID, name string) ([]*model.CustomPolicy, error)

+ func (r *CustomPolicyRepo) GetCustomPolicyByNameAndVersion(orgUUID, name, version string) (*model.CustomPolicy, error)

+ func (r *CustomPolicyRepo) GetCustomPolicyByUUID(orgUUID, policyUUID string) (*model.CustomPolicy, error)

+ func (r *CustomPolicyRepo) GetCustomPolicyUsagesByAPIUUID(apiUUID string) ([]string, error)

+ func (r *CustomPolicyRepo) InsertCustomPolicy(policy *model.CustomPolicy) error

+ func (r *CustomPolicyRepo) InsertCustomPolicyUsage(policyUUID, apiUUID string) error

+ func (r *CustomPolicyRepo) ListCustomPolicyByOrganization(orgUUID string) ([]*model.CustomPolicy, error)

+ func (r *CustomPolicyRepo) UpdateCustomPolicy(policy *model.CustomPolicy, oldVersion string) error

+ type CustomPolicyRepository interface

+ CountCustomPolicyUsages func(policyUUID string) (int, error)

+ DeleteCustomPolicy func(orgUUID, name, version string) error

+ DeleteCustomPolicyIfUnused func(orgUUID, policyUUID string) error

+ DeleteCustomPolicyUsage func(policyUUID, apiUUID string) error

+ GetCustomPoliciesByName func(orgUUID, name string) ([]*model.CustomPolicy, error)

+ GetCustomPolicyByNameAndVersion func(orgUUID, name, version string) (*model.CustomPolicy, error)

+ GetCustomPolicyByUUID func(orgUUID, policyUUID string) (*model.CustomPolicy, error)

+ GetCustomPolicyUsagesByAPIUUID func(apiUUID string) ([]string, error)

+ InsertCustomPolicy func(policy *model.CustomPolicy) error

+ InsertCustomPolicyUsage func(policyUUID, apiUUID string) error

+ ListCustomPolicyByOrganization func(orgUUID string) ([]*model.CustomPolicy, error)

+ UpdateCustomPolicy func(policy *model.CustomPolicy, oldVersion string) error

+ func NewCustomPolicyRepo(db *database.DB) CustomPolicyRepository

+ type DeploymentRepo struct

+ func (r *DeploymentRepo) CreateWithLimitEnforcement(deployment *model.Deployment, hardLimit int) error

+ func (r *DeploymentRepo) Delete(deploymentID, artifactUUID, orgUUID string) error

+ func (r *DeploymentRepo) DeleteStatus(artifactUUID, orgUUID, gatewayID string) error

+ func (r *DeploymentRepo) GetArtifactUUIDByDeploymentID(deploymentID, orgUUID string) (string, error)

+ func (r *DeploymentRepo) GetControlPlaneDeploymentsByGateway(gatewayID, orgUUID string, since *time.Time) ([]*model.DeploymentInfo, error)

+ func (r *DeploymentRepo) GetCurrentByGateway(artifactUUID, gatewayID, orgUUID string) (*model.Deployment, error)

+ func (r *DeploymentRepo) GetDeployedGatewayIDs(artifactUUID, orgUUID string) ([]string, error)

+ func (r *DeploymentRepo) GetDeploymentContentByIDs(deploymentIDs []string, orgUUID string, gatewayUUID string) (map[string]*model.DeploymentContent, error)

+ func (r *DeploymentRepo) GetDeploymentsWithState(artifactUUID, orgUUID string, gatewayID *string, status *string, ...) ([]*model.Deployment, error)

+ func (r *DeploymentRepo) GetLatestDeploymentTime(artifactUUID, orgUUID string) (*time.Time, error)

+ func (r *DeploymentRepo) GetSecretHandlesByGateway(gatewayID, orgUUID string) ([]string, error)

+ func (r *DeploymentRepo) GetStaleTransitionalStatuses(timeout time.Duration) ([]StaleDeploymentStatus, error)

+ func (r *DeploymentRepo) GetStatus(artifactUUID, orgUUID, gatewayID string) (string, model.DeploymentStatus, *time.Time, error)

+ func (r *DeploymentRepo) GetStatusFull(artifactUUID, orgUUID, gatewayID string) (deploymentID string, status model.DeploymentStatus, performedAt *time.Time, ...)

+ func (r *DeploymentRepo) GetWithContent(deploymentID, artifactUUID, orgUUID string) (*model.Deployment, error)

+ func (r *DeploymentRepo) GetWithState(deploymentID, artifactUUID, orgUUID string) (*model.Deployment, error)

+ func (r *DeploymentRepo) HasActiveDeployment(artifactUUID, orgUUID string) (bool, error)

+ func (r *DeploymentRepo) SetCurrent(artifactUUID, orgUUID, gatewayID, deploymentID string, ...) (time.Time, error)

+ func (r *DeploymentRepo) SetCurrentWithDetails(artifactUUID, orgUUID, gatewayID, deploymentID string, ...) (time.Time, error)

+ func (r *DeploymentRepo) UpdateStatusWithPerformedAtGuard(artifactUUID, orgUUID, gatewayID string, newStatus model.DeploymentStatus, ...) (int64, error)

+ type DeploymentRepository interface

+ CreateWithLimitEnforcement func(deployment *model.Deployment, hardLimit int) error

+ Delete func(deploymentID, artifactUUID, orgUUID string) error

+ DeleteStatus func(artifactUUID, orgUUID, gatewayID string) error

+ GetControlPlaneDeploymentsByGateway func(gatewayID, orgUUID string, since *time.Time) ([]*model.DeploymentInfo, error)

+ GetCurrentByGateway func(artifactUUID, gatewayID, orgUUID string) (*model.Deployment, error)

+ GetDeployedGatewayIDs func(artifactUUID, orgUUID string) ([]string, error)

+ GetDeploymentContentByIDs func(deploymentIDs []string, orgUUID string, gatewayUUID string) (map[string]*model.DeploymentContent, error)

+ GetDeploymentsWithState func(artifactUUID, orgUUID string, gatewayID *string, status *string, ...) ([]*model.Deployment, error)

+ GetLatestDeploymentTime func(artifactUUID, orgUUID string) (*time.Time, error)

+ GetSecretHandlesByGateway func(gatewayID, orgUUID string) ([]string, error)

+ GetStaleTransitionalStatuses func(timeout time.Duration) ([]StaleDeploymentStatus, error)

+ GetStatus func(artifactUUID, orgUUID, gatewayID string) (deploymentID string, status model.DeploymentStatus, updatedAt *time.Time, ...)

+ GetStatusFull func(artifactUUID, orgUUID, gatewayID string) (deploymentID string, status model.DeploymentStatus, performedAt *time.Time, ...)

+ GetWithContent func(deploymentID, artifactUUID, orgUUID string) (*model.Deployment, error)

+ GetWithState func(deploymentID, artifactUUID, orgUUID string) (*model.Deployment, error)

+ HasActiveDeployment func(artifactUUID, orgUUID string) (bool, error)

+ SetCurrent func(artifactUUID, orgUUID, gatewayID, deploymentID string, ...) (updatedAt time.Time, err error)

+ SetCurrentWithDetails func(artifactUUID, orgUUID, gatewayID, deploymentID string, ...) (updatedAt time.Time, err error)

+ UpdateStatusWithPerformedAtGuard func(artifactUUID, orgUUID, gatewayID string, newStatus model.DeploymentStatus, ...) (rowsAffected int64, err error)

+ func NewDeploymentRepo(db *database.DB, reg *ArtifactTableRegistry) DeploymentRepository

+ type GatewayRepo struct

+ func (r *GatewayRepo) CountActiveTokens(gatewayId string) (int, error)

+ func (r *GatewayRepo) Create(gateway *model.Gateway) error

+ func (r *GatewayRepo) CreateToken(token *model.GatewayToken) error

+ func (r *GatewayRepo) Delete(gatewayID, organizationID string) error

+ func (r *GatewayRepo) GetActiveTokenByHash(tokenHash string) (*model.GatewayToken, error)

+ func (r *GatewayRepo) GetActiveTokensByGatewayUUID(gatewayId string) ([]*model.GatewayToken, error)

+ func (r *GatewayRepo) GetByHandleAndOrgID(handle, orgID string) (*model.Gateway, error)

+ func (r *GatewayRepo) GetByOrganizationID(orgID string) ([]*model.Gateway, error)

+ func (r *GatewayRepo) GetByUUID(gatewayId string) (*model.Gateway, error)

+ func (r *GatewayRepo) GetGatewayManifest(gatewayID string) ([]byte, error)

+ func (r *GatewayRepo) GetTokenByUUID(tokenId string) (*model.GatewayToken, error)

+ func (r *GatewayRepo) HasGatewayAssociations(gatewayID, organizationID string) (bool, error)

+ func (r *GatewayRepo) HasGatewayAssociationsOrDeployments(gatewayID, organizationID string) (bool, error)

+ func (r *GatewayRepo) HasGatewayDeployments(gatewayID, organizationID string) (bool, error)

+ func (r *GatewayRepo) List() ([]*model.Gateway, error)

+ func (r *GatewayRepo) RevokeToken(tokenId, revokedBy string) error

+ func (r *GatewayRepo) UpdateActiveStatus(gatewayId string, isActive bool) error

+ func (r *GatewayRepo) UpdateGateway(gateway *model.Gateway) error

+ func (r *GatewayRepo) UpdateGatewayManifest(gatewayID string, manifest []byte) error

+ func (r *GatewayRepo) UpdateGatewayVersion(gatewayID, version string) error

+ type GatewayRepository interface

+ CountActiveTokens func(gatewayId string) (int, error)

+ Create func(gateway *model.Gateway) error

+ CreateToken func(token *model.GatewayToken) error

+ Delete func(gatewayID, organizationID string) error

+ GetActiveTokenByHash func(tokenHash string) (*model.GatewayToken, error)

+ GetActiveTokensByGatewayUUID func(gatewayId string) ([]*model.GatewayToken, error)

+ GetByHandleAndOrgID func(handle, orgID string) (*model.Gateway, error)

+ GetByOrganizationID func(orgID string) ([]*model.Gateway, error)

+ GetByUUID func(gatewayId string) (*model.Gateway, error)

+ GetGatewayManifest func(gatewayID string) ([]byte, error)

+ GetTokenByUUID func(tokenId string) (*model.GatewayToken, error)

+ HasGatewayAssociations func(gatewayID, organizationID string) (bool, error)

+ HasGatewayAssociationsOrDeployments func(gatewayID, organizationID string) (bool, error)

+ HasGatewayDeployments func(gatewayID, organizationID string) (bool, error)

+ List func() ([]*model.Gateway, error)

+ RevokeToken func(tokenId, revokedBy string) error

+ UpdateActiveStatus func(gatewayId string, isActive bool) error

+ UpdateGateway func(gateway *model.Gateway) error

+ UpdateGatewayManifest func(gatewayID string, manifest []byte) error

+ UpdateGatewayVersion func(gatewayID, version string) error

+ func NewGatewayRepo(db *database.DB) GatewayRepository

+ type LLMProviderRepo struct

+ func (r *LLMProviderRepo) Count(orgUUID string) (int, error)

+ func (r *LLMProviderRepo) Create(p *model.LLMProvider) error

+ func (r *LLMProviderRepo) Delete(providerID, orgUUID string) error

+ func (r *LLMProviderRepo) EnsureGatewayAssociation(providerUUID, gatewayUUID, orgUUID, deployMetadata string, ...) (string, error)

+ func (r *LLMProviderRepo) Exists(providerID, orgUUID string) (bool, error)

+ func (r *LLMProviderRepo) GetByID(providerID, orgUUID string) (*model.LLMProvider, error)

+ func (r *LLMProviderRepo) List(orgUUID string, limit, offset int) ([]*model.LLMProvider, error)

+ func (r *LLMProviderRepo) Update(p *model.LLMProvider) error

+ type LLMProviderRepository interface

+ Count func(orgUUID string) (int, error)

+ Create func(p *model.LLMProvider) error

+ Delete func(providerID, orgUUID string) error

+ EnsureGatewayAssociation func(providerUUID, gatewayUUID, orgUUID, deployMetadata string, ...) (string, error)

+ Exists func(providerID, orgUUID string) (bool, error)

+ GetByID func(providerID, orgUUID string) (*model.LLMProvider, error)

+ List func(orgUUID string, limit, offset int) ([]*model.LLMProvider, error)

+ Update func(p *model.LLMProvider) error

+ func NewLLMProviderRepo(db *database.DB) LLMProviderRepository

+ type LLMProviderTemplateRepo struct

+ func (r *LLMProviderTemplateRepo) Count(orgUUID string) (int, error)

+ func (r *LLMProviderTemplateRepo) CountAllVersions(orgUUID string) (int, error)

+ func (r *LLMProviderTemplateRepo) CountProvidersUsingTemplate(groupID, orgUUID, version string) (int, error)

+ func (r *LLMProviderTemplateRepo) CountVersions(groupID, orgUUID string) (int, error)

+ func (r *LLMProviderTemplateRepo) Create(t *model.LLMProviderTemplate) error

+ func (r *LLMProviderTemplateRepo) CreateNewVersion(t *model.LLMProviderTemplate) error

+ func (r *LLMProviderTemplateRepo) DeleteVersion(groupID, orgUUID, version string) error

+ func (r *LLMProviderTemplateRepo) Exists(templateID, orgUUID string) (bool, error)

+ func (r *LLMProviderTemplateRepo) GetByID(templateID, orgUUID string) (*model.LLMProviderTemplate, error)

+ func (r *LLMProviderTemplateRepo) GetByUUID(uuid, orgUUID string) (*model.LLMProviderTemplate, error)

+ func (r *LLMProviderTemplateRepo) GetByVersion(groupID, orgUUID, version string) (*model.LLMProviderTemplate, error)

+ func (r *LLMProviderTemplateRepo) GetGroupID(handle, orgUUID string) (string, error)

+ func (r *LLMProviderTemplateRepo) List(orgUUID string, limit, offset int) ([]*model.LLMProviderTemplate, error)

+ func (r *LLMProviderTemplateRepo) ListAllVersions(orgUUID string, limit, offset int) ([]*model.LLMProviderTemplate, error)

+ func (r *LLMProviderTemplateRepo) ListVersions(groupID, orgUUID string, limit, offset int) ([]*model.LLMProviderTemplate, error)

+ func (r *LLMProviderTemplateRepo) ManagedByForHandle(handle, orgUUID string) (string, error)

+ func (r *LLMProviderTemplateRepo) RenameFamily(baseHandle, orgUUID, name string) error

+ func (r *LLMProviderTemplateRepo) SetEnabled(groupID, orgUUID, version string, enabled bool) error

+ func (r *LLMProviderTemplateRepo) Update(t *model.LLMProviderTemplate) error

+ type LLMProviderTemplateRepository interface

+ Count func(orgUUID string) (int, error)

+ CountAllVersions func(orgUUID string) (int, error)

+ CountProvidersUsingTemplate func(templateID, orgUUID, version string) (int, error)

+ CountVersions func(templateID, orgUUID string) (int, error)

+ Create func(t *model.LLMProviderTemplate) error

+ CreateNewVersion func(t *model.LLMProviderTemplate) error

+ DeleteVersion func(templateID, orgUUID, version string) error

+ Exists func(templateID, orgUUID string) (bool, error)

+ GetByID func(templateID, orgUUID string) (*model.LLMProviderTemplate, error)

+ GetByUUID func(uuid, orgUUID string) (*model.LLMProviderTemplate, error)

+ GetByVersion func(templateID, orgUUID, version string) (*model.LLMProviderTemplate, error)

+ GetGroupID func(handle, orgUUID string) (string, error)

+ List func(orgUUID string, limit, offset int) ([]*model.LLMProviderTemplate, error)

+ ListAllVersions func(orgUUID string, limit, offset int) ([]*model.LLMProviderTemplate, error)

+ ListVersions func(templateID, orgUUID string, limit, offset int) ([]*model.LLMProviderTemplate, error)

+ ManagedByForHandle func(handle, orgUUID string) (string, error)

+ RenameFamily func(baseHandle, orgUUID, name string) error

+ SetEnabled func(templateID, orgUUID, version string, enabled bool) error

+ Update func(t *model.LLMProviderTemplate) error

+ func NewLLMProviderTemplateRepo(db *database.DB) LLMProviderTemplateRepository

+ type LLMProxyRepo struct

+ func (r *LLMProxyRepo) Count(orgUUID string) (int, error)

+ func (r *LLMProxyRepo) CountByProject(orgUUID, projectUUID string) (int, error)

+ func (r *LLMProxyRepo) CountByProvider(orgUUID, providerUUID string) (int, error)

+ func (r *LLMProxyRepo) Create(p *model.LLMProxy) error

+ func (r *LLMProxyRepo) Delete(proxyID, orgUUID string) error

+ func (r *LLMProxyRepo) EnsureGatewayAssociation(proxyUUID, gatewayUUID, orgUUID, deployMetadata string, metadataProvided bool) (string, error)

+ func (r *LLMProxyRepo) Exists(proxyID, orgUUID string) (bool, error)

+ func (r *LLMProxyRepo) GetByID(proxyID, orgUUID string) (*model.LLMProxy, error)

+ func (r *LLMProxyRepo) List(orgUUID string, limit, offset int) ([]*model.LLMProxy, error)

+ func (r *LLMProxyRepo) ListByProject(orgUUID, projectUUID string, limit, offset int) ([]*model.LLMProxy, error)

+ func (r *LLMProxyRepo) ListByProvider(orgUUID, providerUUID string, limit, offset int) ([]*model.LLMProxy, error)

+ func (r *LLMProxyRepo) Update(p *model.LLMProxy) error

+ type LLMProxyRepository interface

+ Count func(orgUUID string) (int, error)

+ CountByProject func(orgUUID, projectUUID string) (int, error)

+ CountByProvider func(orgUUID, providerID string) (int, error)

+ Create func(p *model.LLMProxy) error

+ Delete func(proxyID, orgUUID string) error

+ EnsureGatewayAssociation func(proxyUUID, gatewayUUID, orgUUID, deployMetadata string, metadataProvided bool) (string, error)

+ Exists func(proxyID, orgUUID string) (bool, error)

+ GetByID func(proxyID, orgUUID string) (*model.LLMProxy, error)

+ List func(orgUUID string, limit, offset int) ([]*model.LLMProxy, error)

+ ListByProject func(orgUUID, projectUUID string, limit, offset int) ([]*model.LLMProxy, error)

+ ListByProvider func(orgUUID, providerID string, limit, offset int) ([]*model.LLMProxy, error)

+ Update func(p *model.LLMProxy) error

+ func NewLLMProxyRepo(db *database.DB) LLMProxyRepository

+ type MCPProxyRepo struct

+ func NewMCPProxyRepo(db *database.DB) *MCPProxyRepo

+ func (r *MCPProxyRepo) Count(orgUUID string) (int, error)

+ func (r *MCPProxyRepo) CountByProject(orgUUID, projectUUID string) (int, error)

+ func (r *MCPProxyRepo) Create(p *model.MCPProxy) error

+ func (r *MCPProxyRepo) Delete(handle, orgUUID string) error

+ func (r *MCPProxyRepo) EnsureGatewayAssociation(proxyUUID, gatewayUUID, orgUUID, deployMetadata string, metadataProvided bool) (string, error)

+ func (r *MCPProxyRepo) Exists(handle, orgUUID string) (bool, error)

+ func (r *MCPProxyRepo) GetByHandle(handle, orgUUID string) (*model.MCPProxy, error)

+ func (r *MCPProxyRepo) GetByUUID(uuid, orgUUID string) (*model.MCPProxy, error)

+ func (r *MCPProxyRepo) List(orgUUID string, limit, offset int) ([]*model.MCPProxy, error)

+ func (r *MCPProxyRepo) ListByProject(orgUUID, projectUUID string) ([]*model.MCPProxy, error)

+ func (r *MCPProxyRepo) Update(p *model.MCPProxy) error

+ type MCPProxyRepository interface

+ Count func(orgUUID string) (int, error)

+ CountByProject func(orgUUID, projectUUID string) (int, error)

+ Create func(p *model.MCPProxy) error

+ Delete func(handle, orgUUID string) error

+ EnsureGatewayAssociation func(proxyUUID, gatewayUUID, orgUUID, deployMetadata string, metadataProvided bool) (string, error)

+ Exists func(handle, orgUUID string) (bool, error)

+ GetByHandle func(handle, orgUUID string) (*model.MCPProxy, error)

+ GetByUUID func(uuid, orgUUID string) (*model.MCPProxy, error)

+ List func(orgUUID string, limit, offset int) ([]*model.MCPProxy, error)

+ ListByProject func(orgUUID, projectUUID string) ([]*model.MCPProxy, error)

+ Update func(p *model.MCPProxy) error

+ type OrganizationRepo struct

+ func (r *OrganizationRepo) CountOrganizations() (int, error)

+ func (r *OrganizationRepo) CreateOrganization(org *model.Organization) error

+ func (r *OrganizationRepo) DeleteOrganization(orgId string) error

+ func (r *OrganizationRepo) GetOrganizationByHandle(handle string) (*model.Organization, error)

+ func (r *OrganizationRepo) GetOrganizationByIdOrHandle(id, handle string) (*model.Organization, error)

+ func (r *OrganizationRepo) GetOrganizationByIdpOrgRefUUID(idpOrgRefUUID string) (*model.Organization, error)

+ func (r *OrganizationRepo) GetOrganizationByUUID(orgId string) (*model.Organization, error)

+ func (r *OrganizationRepo) ListOrganizations(limit, offset int) ([]*model.Organization, error)

+ func (r *OrganizationRepo) UpdateOrganization(org *model.Organization) error

+ type OrganizationRepository interface

+ CountOrganizations func() (int, error)

+ CreateOrganization func(org *model.Organization) error

+ DeleteOrganization func(orgId string) error

+ GetOrganizationByHandle func(handle string) (*model.Organization, error)

+ GetOrganizationByIdOrHandle func(id, handle string) (*model.Organization, error)

+ GetOrganizationByIdpOrgRefUUID func(idpOrgRefUUID string) (*model.Organization, error)

+ GetOrganizationByUUID func(orgId string) (*model.Organization, error)

+ ListOrganizations func(limit, offset int) ([]*model.Organization, error)

+ UpdateOrganization func(org *model.Organization) error

+ func NewOrganizationRepo(db *database.DB) OrganizationRepository

+ type ProjectRepo struct

+ func (r *ProjectRepo) CreateProject(project *model.Project) error

+ func (r *ProjectRepo) DeleteProject(projectId string) error

+ func (r *ProjectRepo) GetProjectByHandleAndOrgID(handle, orgID string) (*model.Project, error)

+ func (r *ProjectRepo) GetProjectByNameAndOrgID(name, orgID string) (*model.Project, error)

+ func (r *ProjectRepo) GetProjectByUUID(projectId string) (*model.Project, error)

+ func (r *ProjectRepo) GetProjectsByOrganizationID(orgID string) ([]*model.Project, error)

+ func (r *ProjectRepo) ListProjects(orgID string, limit, offset int) ([]*model.Project, error)

+ func (r *ProjectRepo) UpdateProject(project *model.Project) error

+ type ProjectRepository interface

+ CreateProject func(project *model.Project) error

+ DeleteProject func(projectId string) error

+ GetProjectByHandleAndOrgID func(handle, orgID string) (*model.Project, error)

+ GetProjectByNameAndOrgID func(name, orgID string) (*model.Project, error)

+ GetProjectByUUID func(projectId string) (*model.Project, error)

+ GetProjectsByOrganizationID func(orgID string) ([]*model.Project, error)

+ ListProjects func(orgID string, limit, offset int) ([]*model.Project, error)

+ UpdateProject func(project *model.Project) error

+ func NewProjectRepo(db *database.DB) ProjectRepository

+ type SecretRepo struct

+ func (r *SecretRepo) Count(orgID string) (int, error)

+ func (r *SecretRepo) Create(s *model.Secret) error

+ func (r *SecretRepo) Exists(orgID, handle string) (bool, error)

+ func (r *SecretRepo) FindRefs(orgID, handle string) ([]model.SecretReference, error)

+ func (r *SecretRepo) FindRefsAndSoftDelete(orgID, handle, updatedBy string) ([]model.SecretReference, error)

+ func (r *SecretRepo) GetByHandle(orgID, handle string) (*model.Secret, error)

+ func (r *SecretRepo) List(orgID string, limit, offset int, updatedAfter *time.Time) ([]*model.Secret, error)

+ func (r *SecretRepo) ListByHandles(orgID string, handles []string, updatedAfter *time.Time) ([]*model.Secret, error)

+ func (r *SecretRepo) Update(s *model.Secret) error

+ type SecretRepository interface

+ Count func(orgID string) (int, error)

+ Create func(s *model.Secret) error

+ Exists func(orgID, handle string) (bool, error)

+ FindRefs func(orgID, handle string) ([]model.SecretReference, error)

+ FindRefsAndSoftDelete func(orgID, handle, updatedBy string) ([]model.SecretReference, error)

+ GetByHandle func(orgID, handle string) (*model.Secret, error)

+ List func(orgID string, limit, offset int, updatedAfter *time.Time) ([]*model.Secret, error)

+ ListByHandles func(orgID string, handles []string, updatedAfter *time.Time) ([]*model.Secret, error)

+ Update func(s *model.Secret) error

+ func NewSecretRepo(db *database.DB) SecretRepository

+ type StaleDeploymentStatus struct

+ ArtifactUUID string

+ DeploymentID string

+ GatewayUUID string

+ OrganizationUUID string

+ PerformedAt time.Time

+ Status model.DeploymentStatus

+ StatusDesired string

+ type SubscriptionPlanRepo struct

+ func (r *SubscriptionPlanRepo) Create(plan *model.SubscriptionPlan) error

+ func (r *SubscriptionPlanRepo) Delete(planID, orgUUID string) error

+ func (r *SubscriptionPlanRepo) ExistsByHandleAndOrg(handle, orgUUID string) (bool, error)

+ func (r *SubscriptionPlanRepo) GetByHandleAndOrg(handle, orgUUID string) (*model.SubscriptionPlan, error)

+ func (r *SubscriptionPlanRepo) GetByID(planID, orgUUID string) (*model.SubscriptionPlan, error)

+ func (r *SubscriptionPlanRepo) GetByIDs(planIDs []string, orgUUID string) (map[string]string, error)

+ func (r *SubscriptionPlanRepo) ListByOrganization(orgUUID string, limit, offset int) ([]*model.SubscriptionPlan, error)

+ func (r *SubscriptionPlanRepo) Update(plan *model.SubscriptionPlan) error

+ type SubscriptionPlanRepository interface

+ Create func(plan *model.SubscriptionPlan) error

+ Delete func(planID, orgUUID string) error

+ ExistsByHandleAndOrg func(handle, orgUUID string) (bool, error)

+ GetByHandleAndOrg func(handle, orgUUID string) (*model.SubscriptionPlan, error)

+ GetByID func(planID, orgUUID string) (*model.SubscriptionPlan, error)

+ GetByIDs func(planIDs []string, orgUUID string) (map[string]string, error)

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

+ Update func(plan *model.SubscriptionPlan) error

+ func NewSubscriptionPlanRepo(db *database.DB) SubscriptionPlanRepository

+ type SubscriptionRepo struct

+ func (r *SubscriptionRepo) CountByFilters(orgUUID string, apiUUID *string, subscriberID *string, applicationID *string, ...) (int, error)

+ func (r *SubscriptionRepo) Create(sub *model.Subscription) error

+ func (r *SubscriptionRepo) Delete(subscriptionID, orgUUID string) error

+ func (r *SubscriptionRepo) ExistsByAPIAndSubscriber(apiUUID, subscriberID, orgUUID string) (bool, error)

+ func (r *SubscriptionRepo) GetByID(subscriptionID, orgUUID string) (*model.Subscription, error)

+ func (r *SubscriptionRepo) ListByFilters(orgUUID string, apiUUID *string, subscriberID *string, applicationID *string, ...) ([]*model.Subscription, error)

+ func (r *SubscriptionRepo) Update(sub *model.Subscription) error

+ func (r *SubscriptionRepo) UpdateToken(subscriptionID, orgUUID, newToken string) error

+ type SubscriptionRepository interface

+ CountByFilters func(orgUUID string, apiUUID *string, subscriberID *string, applicationID *string, ...) (int, error)

+ Create func(sub *model.Subscription) error

+ Delete func(subscriptionID, orgUUID string) error

+ ExistsByAPIAndSubscriber func(apiUUID, subscriberID, orgUUID string) (bool, error)

+ GetByID func(subscriptionID, orgUUID string) (*model.Subscription, error)

+ ListByFilters func(orgUUID string, apiUUID *string, subscriberID *string, applicationID *string, ...) ([]*model.Subscription, error)

+ Update func(sub *model.Subscription) error

+ UpdateToken func(subscriptionID, orgUUID, newToken string) error

+ func NewSubscriptionRepo(db *database.DB) SubscriptionRepository

+ type UserIdentityMappingRepo struct

+ func (r *UserIdentityMappingRepo) GetOrCreateUUID(identity string) (string, error)

+ func (r *UserIdentityMappingRepo) GetSubByUUID(uuid string) (string, bool, error)

+ func (r *UserIdentityMappingRepo) GetSubsByUUIDs(uuids []string) (map[string]string, error)

+ type UserIdentityMappingRepository interface

+ GetOrCreateUUID func(identity string) (string, error)

+ GetSubByUUID func(uuid string) (identity string, found bool, err error)

+ GetSubsByUUIDs func(uuids []string) (map[string]string, error)

+ func NewUserIdentityMappingRepo(db *database.DB) UserIdentityMappingRepository

+ type UserOrganizationMappingRepo struct

+ func (r *UserOrganizationMappingRepo) AddMembership(userUUID, orgUUID string) error

+ func (r *UserOrganizationMappingRepo) DeleteByOrg(tx *sql.Tx, orgUUID string) error

+ func (r *UserOrganizationMappingRepo) DeleteByUser(tx *sql.Tx, userUUID string) error

+ type UserOrganizationMappingRepository interface

+ AddMembership func(userUUID, orgUUID string) error

+ DeleteByOrg func(tx *sql.Tx, orgUUID string) error

+ DeleteByUser func(tx *sql.Tx, userUUID string) error

+ func NewUserOrganizationMappingRepo(db *database.DB) UserOrganizationMappingRepository

+ type WebBrokerAPIRepository interface

+ Count func(orgUUID string) (int, error)

+ CountByProject func(orgUUID, projectUUID string) (int, error)

+ Create func(api *model.WebBrokerAPI) error

+ Delete func(handle, orgUUID string) error

+ Exists func(handle, orgUUID string) (bool, error)

+ GetByHandle func(handle, orgUUID string) (*model.WebBrokerAPI, error)

+ GetByUUID func(uuid, orgUUID string) (*model.WebBrokerAPI, error)

+ List func(orgUUID, projectUUID string, limit, offset int) ([]*model.WebBrokerAPI, error)

+ Update func(api *model.WebBrokerAPI) error

+ type WebSubAPIHmacSecretRepository interface

+ Create func(secret *model.WebSubAPIHmacSecret) error

+ Delete func(artifactUUID, name string) error

+ GetByArtifactAndName func(artifactUUID, name string) (*model.WebSubAPIHmacSecret, error)

+ ListByArtifact func(artifactUUID string) ([]*model.WebSubAPIHmacSecret, error)

+ Update func(secret *model.WebSubAPIHmacSecret) error

+ type WebSubAPIRepository interface

+ Count func(orgUUID string) (int, error)

+ CountByProject func(orgUUID, projectUUID string) (int, error)

+ Create func(api *model.WebSubAPI) error

+ Delete func(handle, orgUUID string) error

+ Exists func(handle, orgUUID string) (bool, error)

+ GetByHandle func(handle, orgUUID string) (*model.WebSubAPI, error)

+ GetByUUID func(uuid, orgUUID string) (*model.WebSubAPI, error)

+ List func(orgUUID, projectUUID string, limit, offset int) ([]*model.WebSubAPI, error)

+ Update func(api *model.WebSubAPI) error

v0.11.0-cloud1

Jul 8, 2026

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