Documentation
¶
Index ¶
- type BulkInitializeRegistrySyncsParams
- type BulkUpsertConfigRegistriesParams
- type BulkUpsertConfigRegistriesRow
- type CreationType
- type DBTX
- type DeleteOrphanedServersParams
- type DeleteServerVersionParams
- type GetAPIRegistriesByNamesRow
- type GetRegistryByNameRow
- type GetRegistryRow
- type GetServerIDsByRegistryNameVersionRow
- type GetServerVersionParams
- type GetServerVersionRow
- type IconTheme
- type InitializeRegistrySyncParams
- type InsertAPIRegistryParams
- type InsertConfigRegistryParams
- type InsertRegistrySyncParams
- type InsertServerIconParams
- type InsertServerPackageParams
- type InsertServerRemoteParams
- type InsertServerVersionForSyncParams
- type InsertServerVersionParams
- type LatestServerVersion
- type ListRegistriesParams
- type ListRegistriesRow
- type ListRegistrySyncsByLastUpdateRow
- type ListRegistrySyncsRow
- type ListServerPackagesRow
- type ListServerVersionsParams
- type ListServerVersionsRow
- type ListServersParams
- type ListServersRow
- type McpServer
- type McpServerIcon
- type McpServerPackage
- type McpServerRemote
- type NullCreationType
- type NullIconTheme
- type NullRegistryType
- type NullSyncStatus
- type Querier
- type Queries
- func (q *Queries) BulkInitializeRegistrySyncs(ctx context.Context, arg BulkInitializeRegistrySyncsParams) error
- func (q *Queries) BulkUpsertConfigRegistries(ctx context.Context, arg BulkUpsertConfigRegistriesParams) ([]BulkUpsertConfigRegistriesRow, error)
- func (q *Queries) CreateTempIconTable(ctx context.Context) error
- func (q *Queries) CreateTempPackageTable(ctx context.Context) error
- func (q *Queries) CreateTempRemoteTable(ctx context.Context) error
- func (q *Queries) CreateTempServerTable(ctx context.Context) error
- func (q *Queries) DeleteAPIRegistry(ctx context.Context, name string) (int64, error)
- func (q *Queries) DeleteConfigRegistriesNotInList(ctx context.Context, ids []uuid.UUID) error
- func (q *Queries) DeleteConfigRegistry(ctx context.Context, name string) (int64, error)
- func (q *Queries) DeleteOrphanedIcons(ctx context.Context, serverIds []uuid.UUID) error
- func (q *Queries) DeleteOrphanedPackages(ctx context.Context, serverIds []uuid.UUID) error
- func (q *Queries) DeleteOrphanedRemotes(ctx context.Context, serverIds []uuid.UUID) error
- func (q *Queries) DeleteOrphanedServers(ctx context.Context, arg DeleteOrphanedServersParams) error
- func (q *Queries) DeleteServerIconsByServerId(ctx context.Context, serverID uuid.UUID) error
- func (q *Queries) DeleteServerPackagesByServerId(ctx context.Context, serverID uuid.UUID) error
- func (q *Queries) DeleteServerRemotesByServerId(ctx context.Context, serverID uuid.UUID) error
- func (q *Queries) DeleteServerVersion(ctx context.Context, arg DeleteServerVersionParams) (int64, error)
- func (q *Queries) DeleteServersByRegistry(ctx context.Context, regID uuid.UUID) error
- func (q *Queries) GetAPIRegistriesByNames(ctx context.Context, names []string) ([]GetAPIRegistriesByNamesRow, error)
- func (q *Queries) GetRegistry(ctx context.Context, id uuid.UUID) (GetRegistryRow, error)
- func (q *Queries) GetRegistryByName(ctx context.Context, name string) (GetRegistryByNameRow, error)
- func (q *Queries) GetRegistrySync(ctx context.Context, id uuid.UUID) (RegistrySync, error)
- func (q *Queries) GetRegistrySyncByName(ctx context.Context, name string) (RegistrySync, error)
- func (q *Queries) GetServerIDsByRegistryNameVersion(ctx context.Context, regID uuid.UUID) ([]GetServerIDsByRegistryNameVersionRow, error)
- func (q *Queries) GetServerVersion(ctx context.Context, arg GetServerVersionParams) (GetServerVersionRow, error)
- func (q *Queries) InitializeRegistrySync(ctx context.Context, arg InitializeRegistrySyncParams) error
- func (q *Queries) InsertAPIRegistry(ctx context.Context, arg InsertAPIRegistryParams) (Registry, error)
- func (q *Queries) InsertConfigRegistry(ctx context.Context, arg InsertConfigRegistryParams) (uuid.UUID, error)
- func (q *Queries) InsertRegistrySync(ctx context.Context, arg InsertRegistrySyncParams) (uuid.UUID, error)
- func (q *Queries) InsertServerIcon(ctx context.Context, arg InsertServerIconParams) error
- func (q *Queries) InsertServerPackage(ctx context.Context, arg InsertServerPackageParams) error
- func (q *Queries) InsertServerRemote(ctx context.Context, arg InsertServerRemoteParams) error
- func (q *Queries) InsertServerVersion(ctx context.Context, arg InsertServerVersionParams) (uuid.UUID, error)
- func (q *Queries) InsertServerVersionForSync(ctx context.Context, arg InsertServerVersionForSyncParams) (uuid.UUID, error)
- func (q *Queries) ListAllRegistryNames(ctx context.Context) ([]string, error)
- func (q *Queries) ListRegistries(ctx context.Context, arg ListRegistriesParams) ([]ListRegistriesRow, error)
- func (q *Queries) ListRegistrySyncs(ctx context.Context) ([]ListRegistrySyncsRow, error)
- func (q *Queries) ListRegistrySyncsByLastUpdate(ctx context.Context) ([]ListRegistrySyncsByLastUpdateRow, error)
- func (q *Queries) ListServerPackages(ctx context.Context, serverIds []uuid.UUID) ([]ListServerPackagesRow, error)
- func (q *Queries) ListServerRemotes(ctx context.Context, serverIds []uuid.UUID) ([]McpServerRemote, error)
- func (q *Queries) ListServerVersions(ctx context.Context, arg ListServerVersionsParams) ([]ListServerVersionsRow, error)
- func (q *Queries) ListServers(ctx context.Context, arg ListServersParams) ([]ListServersRow, error)
- func (q *Queries) UpdateAPIRegistry(ctx context.Context, arg UpdateAPIRegistryParams) (Registry, error)
- func (q *Queries) UpdateRegistrySync(ctx context.Context, arg UpdateRegistrySyncParams) error
- func (q *Queries) UpdateRegistrySyncStatusByName(ctx context.Context, arg UpdateRegistrySyncStatusByNameParams) error
- func (q *Queries) UpsertConfigRegistry(ctx context.Context, arg UpsertConfigRegistryParams) (uuid.UUID, error)
- func (q *Queries) UpsertIconsFromTemp(ctx context.Context) error
- func (q *Queries) UpsertLatestServerVersion(ctx context.Context, arg UpsertLatestServerVersionParams) (uuid.UUID, error)
- func (q *Queries) UpsertPackagesFromTemp(ctx context.Context) error
- func (q *Queries) UpsertRegistrySyncByName(ctx context.Context, arg UpsertRegistrySyncByNameParams) error
- func (q *Queries) UpsertRemotesFromTemp(ctx context.Context) error
- func (q *Queries) UpsertServerVersionForSync(ctx context.Context, arg UpsertServerVersionForSyncParams) (uuid.UUID, error)
- func (q *Queries) UpsertServersFromTemp(ctx context.Context) error
- func (q *Queries) WithTx(tx pgx.Tx) *Queries
- type Registry
- type RegistrySync
- type RegistryType
- type SyncStatus
- type TempMcpServer
- type TempMcpServerIcon
- type TempMcpServerPackage
- type TempMcpServerRemote
- type UpdateAPIRegistryParams
- type UpdateRegistrySyncParams
- type UpdateRegistrySyncStatusByNameParams
- type UpsertConfigRegistryParams
- type UpsertLatestServerVersionParams
- type UpsertRegistrySyncByNameParams
- type UpsertServerVersionForSyncParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BulkInitializeRegistrySyncsParams ¶ added in v0.3.1
type BulkInitializeRegistrySyncsParams struct {
RegIds []uuid.UUID `json:"reg_ids"`
SyncStatuses []SyncStatus `json:"sync_statuses"`
ErrorMsgs []string `json:"error_msgs"`
}
type BulkUpsertConfigRegistriesParams ¶ added in v0.4.7
type BulkUpsertConfigRegistriesParams struct {
Names []string `json:"names"`
RegTypes []RegistryType `json:"reg_types"`
SourceTypes []string `json:"source_types"`
Formats []string `json:"formats"`
SourceConfigs [][]byte `json:"source_configs"`
FilterConfigs [][]byte `json:"filter_configs"`
SyncSchedules []pgtypes.Interval `json:"sync_schedules"`
Syncables []bool `json:"syncables"`
CreatedAts []time.Time `json:"created_ats"`
UpdatedAts []time.Time `json:"updated_ats"`
}
type BulkUpsertConfigRegistriesRow ¶ added in v0.4.7
type CreationType ¶ added in v0.4.4
type CreationType string
const ( CreationTypeAPI CreationType = "API" CreationTypeCONFIG CreationType = "CONFIG" )
func (*CreationType) Scan ¶ added in v0.4.4
func (e *CreationType) Scan(src interface{}) error
type DeleteOrphanedServersParams ¶ added in v0.3.2
type DeleteServerVersionParams ¶ added in v0.3.0
type GetAPIRegistriesByNamesRow ¶ added in v0.4.4
type GetAPIRegistriesByNamesRow struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
CreationType CreationType `json:"creation_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type GetRegistryByNameRow ¶ added in v0.4.4
type GetRegistryByNameRow struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
CreationType CreationType `json:"creation_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type GetRegistryRow ¶ added in v0.4.4
type GetRegistryRow struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
CreationType CreationType `json:"creation_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type GetServerIDsByRegistryNameVersionRow ¶ added in v0.3.2
type GetServerVersionParams ¶ added in v0.3.0
type GetServerVersionRow ¶ added in v0.3.0
type GetServerVersionRow struct {
RegistryType RegistryType `json:"registry_type"`
ID uuid.UUID `json:"id"`
Name string `json:"name"`
Version string `json:"version"`
IsLatest bool `json:"is_latest"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type InitializeRegistrySyncParams ¶ added in v0.3.1
type InitializeRegistrySyncParams struct {
Name string `json:"name"`
SyncStatus SyncStatus `json:"sync_status"`
ErrorMsg *string `json:"error_msg"`
}
type InsertAPIRegistryParams ¶ added in v0.4.7
type InsertAPIRegistryParams struct {
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
Syncable bool `json:"syncable"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type InsertConfigRegistryParams ¶ added in v0.4.7
type InsertConfigRegistryParams struct {
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
Syncable bool `json:"syncable"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type InsertServerIconParams ¶ added in v0.3.0
type InsertServerPackageParams ¶ added in v0.3.0
type InsertServerPackageParams struct {
ServerID uuid.UUID `json:"server_id"`
RegistryType string `json:"registry_type"`
PkgRegistryUrl string `json:"pkg_registry_url"`
PkgIdentifier string `json:"pkg_identifier"`
PkgVersion string `json:"pkg_version"`
RuntimeHint *string `json:"runtime_hint"`
RuntimeArguments []string `json:"runtime_arguments"`
PackageArguments []string `json:"package_arguments"`
EnvVars []byte `json:"env_vars"`
Sha256Hash *string `json:"sha256_hash"`
Transport string `json:"transport"`
TransportUrl *string `json:"transport_url"`
TransportHeaders []byte `json:"transport_headers"`
}
type InsertServerRemoteParams ¶ added in v0.3.0
type InsertServerVersionForSyncParams ¶ added in v0.3.2
type InsertServerVersionForSyncParams struct {
Name string `json:"name"`
Version string `json:"version"`
RegID uuid.UUID `json:"reg_id"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type InsertServerVersionParams ¶ added in v0.3.0
type InsertServerVersionParams struct {
Name string `json:"name"`
Version string `json:"version"`
RegID uuid.UUID `json:"reg_id"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type LatestServerVersion ¶
type ListRegistriesParams ¶
type ListRegistriesRow ¶ added in v0.4.4
type ListRegistriesRow struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
CreationType CreationType `json:"creation_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type ListRegistrySyncsByLastUpdateRow ¶ added in v0.4.1
type ListRegistrySyncsByLastUpdateRow struct {
Name string `json:"name"`
ID uuid.UUID `json:"id"`
RegID uuid.UUID `json:"reg_id"`
SyncStatus SyncStatus `json:"sync_status"`
ErrorMsg *string `json:"error_msg"`
StartedAt *time.Time `json:"started_at"`
EndedAt *time.Time `json:"ended_at"`
AttemptCount int64 `json:"attempt_count"`
LastSyncHash *string `json:"last_sync_hash"`
LastAppliedFilterHash *string `json:"last_applied_filter_hash"`
ServerCount int64 `json:"server_count"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
}
type ListRegistrySyncsRow ¶ added in v0.3.1
type ListRegistrySyncsRow struct {
Name string `json:"name"`
ID uuid.UUID `json:"id"`
RegID uuid.UUID `json:"reg_id"`
SyncStatus SyncStatus `json:"sync_status"`
ErrorMsg *string `json:"error_msg"`
StartedAt *time.Time `json:"started_at"`
EndedAt *time.Time `json:"ended_at"`
AttemptCount int64 `json:"attempt_count"`
LastSyncHash *string `json:"last_sync_hash"`
LastAppliedFilterHash *string `json:"last_applied_filter_hash"`
ServerCount int64 `json:"server_count"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
}
type ListServerPackagesRow ¶ added in v0.4.9
type ListServerPackagesRow struct {
ServerID uuid.UUID `json:"server_id"`
RegistryType string `json:"registry_type"`
PkgRegistryUrl string `json:"pkg_registry_url"`
PkgIdentifier string `json:"pkg_identifier"`
PkgVersion string `json:"pkg_version"`
RuntimeHint *string `json:"runtime_hint"`
RuntimeArguments []string `json:"runtime_arguments"`
PackageArguments []string `json:"package_arguments"`
EnvVars []byte `json:"env_vars"`
Sha256Hash *string `json:"sha256_hash"`
Transport string `json:"transport"`
TransportUrl *string `json:"transport_url"`
TransportHeaders []byte `json:"transport_headers"`
}
type ListServerVersionsRow ¶
type ListServerVersionsRow struct {
RegistryType RegistryType `json:"registry_type"`
ID uuid.UUID `json:"id"`
Name string `json:"name"`
Version string `json:"version"`
IsLatest bool `json:"is_latest"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type ListServersParams ¶
type ListServersRow ¶
type ListServersRow struct {
RegistryType RegistryType `json:"registry_type"`
ID uuid.UUID `json:"id"`
Name string `json:"name"`
Version string `json:"version"`
IsLatest bool `json:"is_latest"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type McpServer ¶
type McpServer struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
Version string `json:"version"`
RegID uuid.UUID `json:"reg_id"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type McpServerIcon ¶
type McpServerPackage ¶
type McpServerPackage struct {
ServerID uuid.UUID `json:"server_id"`
RegistryType string `json:"registry_type"`
PkgRegistryUrl string `json:"pkg_registry_url"`
PkgIdentifier string `json:"pkg_identifier"`
PkgVersion string `json:"pkg_version"`
RuntimeHint *string `json:"runtime_hint"`
RuntimeArguments []string `json:"runtime_arguments"`
PackageArguments []string `json:"package_arguments"`
Sha256Hash *string `json:"sha256_hash"`
Transport string `json:"transport"`
TransportUrl *string `json:"transport_url"`
EnvVars []byte `json:"env_vars"`
TransportHeaders []byte `json:"transport_headers"`
}
type McpServerRemote ¶
type NullCreationType ¶ added in v0.4.4
type NullCreationType struct {
CreationType CreationType `json:"creation_type"`
Valid bool `json:"valid"` // Valid is true if CreationType is not NULL
}
func (*NullCreationType) Scan ¶ added in v0.4.4
func (ns *NullCreationType) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullIconTheme ¶
type NullIconTheme struct {
IconTheme IconTheme `json:"icon_theme"`
Valid bool `json:"valid"` // Valid is true if IconTheme is not NULL
}
func (*NullIconTheme) Scan ¶
func (ns *NullIconTheme) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullRegistryType ¶
type NullRegistryType struct {
RegistryType RegistryType `json:"registry_type"`
Valid bool `json:"valid"` // Valid is true if RegistryType is not NULL
}
func (*NullRegistryType) Scan ¶
func (ns *NullRegistryType) Scan(value interface{}) error
Scan implements the Scanner interface.
type NullSyncStatus ¶
type NullSyncStatus struct {
SyncStatus SyncStatus `json:"sync_status"`
Valid bool `json:"valid"` // Valid is true if SyncStatus is not NULL
}
func (*NullSyncStatus) Scan ¶
func (ns *NullSyncStatus) Scan(value interface{}) error
Scan implements the Scanner interface.
type Querier ¶
type Querier interface {
BulkInitializeRegistrySyncs(ctx context.Context, arg BulkInitializeRegistrySyncsParams) error
// Bulk insert or update CONFIG registries (only updates existing CONFIG registries)
BulkUpsertConfigRegistries(ctx context.Context, arg BulkUpsertConfigRegistriesParams) ([]BulkUpsertConfigRegistriesRow, error)
// Temp Icon Table Operations
CreateTempIconTable(ctx context.Context) error
// Temp Package Table Operations
CreateTempPackageTable(ctx context.Context) error
// Temp Remote Table Operations
CreateTempRemoteTable(ctx context.Context) error
// Temporary table operations for bulk sync
// Note: These queries reference temp tables that don't exist in the schema.
// sqlc cannot validate these, but we organize them here for maintainability.
// Temp Server Table Operations
CreateTempServerTable(ctx context.Context) error
// Delete an API registry by name (returns 0 if not found or is CONFIG type)
DeleteAPIRegistry(ctx context.Context, name string) (int64, error)
// Delete CONFIG registries not in the provided list (for config file sync)
DeleteConfigRegistriesNotInList(ctx context.Context, ids []uuid.UUID) error
// Delete a CONFIG registry by name (returns 0 if not found or is API type)
DeleteConfigRegistry(ctx context.Context, name string) (int64, error)
DeleteOrphanedIcons(ctx context.Context, serverIds []uuid.UUID) error
DeleteOrphanedPackages(ctx context.Context, serverIds []uuid.UUID) error
DeleteOrphanedRemotes(ctx context.Context, serverIds []uuid.UUID) error
DeleteOrphanedServers(ctx context.Context, arg DeleteOrphanedServersParams) error
DeleteServerIconsByServerId(ctx context.Context, serverID uuid.UUID) error
DeleteServerPackagesByServerId(ctx context.Context, serverID uuid.UUID) error
DeleteServerRemotesByServerId(ctx context.Context, serverID uuid.UUID) error
DeleteServerVersion(ctx context.Context, arg DeleteServerVersionParams) (int64, error)
DeleteServersByRegistry(ctx context.Context, regID uuid.UUID) error
GetAPIRegistriesByNames(ctx context.Context, names []string) ([]GetAPIRegistriesByNamesRow, error)
GetRegistry(ctx context.Context, id uuid.UUID) (GetRegistryRow, error)
GetRegistryByName(ctx context.Context, name string) (GetRegistryByNameRow, error)
GetRegistrySync(ctx context.Context, id uuid.UUID) (RegistrySync, error)
GetRegistrySyncByName(ctx context.Context, name string) (RegistrySync, error)
GetServerIDsByRegistryNameVersion(ctx context.Context, regID uuid.UUID) ([]GetServerIDsByRegistryNameVersionRow, error)
GetServerVersion(ctx context.Context, arg GetServerVersionParams) (GetServerVersionRow, error)
InitializeRegistrySync(ctx context.Context, arg InitializeRegistrySyncParams) error
// ============================================================================
// API Registry Queries (only operate on creation_type='API')
// ============================================================================
// Insert a new API registry with full configuration
InsertAPIRegistry(ctx context.Context, arg InsertAPIRegistryParams) (Registry, error)
// ============================================================================
// CONFIG Registry Queries (only operate on creation_type='CONFIG')
// ============================================================================
// Insert a new CONFIG registry with full configuration
InsertConfigRegistry(ctx context.Context, arg InsertConfigRegistryParams) (uuid.UUID, error)
InsertRegistrySync(ctx context.Context, arg InsertRegistrySyncParams) (uuid.UUID, error)
InsertServerIcon(ctx context.Context, arg InsertServerIconParams) error
InsertServerPackage(ctx context.Context, arg InsertServerPackageParams) error
InsertServerRemote(ctx context.Context, arg InsertServerRemoteParams) error
InsertServerVersion(ctx context.Context, arg InsertServerVersionParams) (uuid.UUID, error)
InsertServerVersionForSync(ctx context.Context, arg InsertServerVersionForSyncParams) (uuid.UUID, error)
ListAllRegistryNames(ctx context.Context) ([]string, error)
ListRegistries(ctx context.Context, arg ListRegistriesParams) ([]ListRegistriesRow, error)
ListRegistrySyncs(ctx context.Context) ([]ListRegistrySyncsRow, error)
ListRegistrySyncsByLastUpdate(ctx context.Context) ([]ListRegistrySyncsByLastUpdateRow, error)
ListServerPackages(ctx context.Context, serverIds []uuid.UUID) ([]ListServerPackagesRow, error)
ListServerRemotes(ctx context.Context, serverIds []uuid.UUID) ([]McpServerRemote, error)
ListServerVersions(ctx context.Context, arg ListServerVersionsParams) ([]ListServerVersionsRow, error)
ListServers(ctx context.Context, arg ListServersParams) ([]ListServersRow, error)
// Update an existing API registry (returns NULL if not found or is CONFIG type)
UpdateAPIRegistry(ctx context.Context, arg UpdateAPIRegistryParams) (Registry, error)
UpdateRegistrySync(ctx context.Context, arg UpdateRegistrySyncParams) error
UpdateRegistrySyncStatusByName(ctx context.Context, arg UpdateRegistrySyncStatusByNameParams) error
// Insert or update a CONFIG registry (only updates if existing is CONFIG type)
UpsertConfigRegistry(ctx context.Context, arg UpsertConfigRegistryParams) (uuid.UUID, error)
UpsertIconsFromTemp(ctx context.Context) error
UpsertLatestServerVersion(ctx context.Context, arg UpsertLatestServerVersionParams) (uuid.UUID, error)
UpsertPackagesFromTemp(ctx context.Context) error
UpsertRegistrySyncByName(ctx context.Context, arg UpsertRegistrySyncByNameParams) error
UpsertRemotesFromTemp(ctx context.Context) error
UpsertServerVersionForSync(ctx context.Context, arg UpsertServerVersionForSyncParams) (uuid.UUID, error)
UpsertServersFromTemp(ctx context.Context) error
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) BulkInitializeRegistrySyncs ¶ added in v0.3.1
func (q *Queries) BulkInitializeRegistrySyncs(ctx context.Context, arg BulkInitializeRegistrySyncsParams) error
func (*Queries) BulkUpsertConfigRegistries ¶ added in v0.4.7
func (q *Queries) BulkUpsertConfigRegistries(ctx context.Context, arg BulkUpsertConfigRegistriesParams) ([]BulkUpsertConfigRegistriesRow, error)
Bulk insert or update CONFIG registries (only updates existing CONFIG registries)
func (*Queries) CreateTempIconTable ¶ added in v0.3.2
Temp Icon Table Operations
func (*Queries) CreateTempPackageTable ¶ added in v0.3.2
Temp Package Table Operations
func (*Queries) CreateTempRemoteTable ¶ added in v0.3.2
Temp Remote Table Operations
func (*Queries) CreateTempServerTable ¶ added in v0.3.2
Temporary table operations for bulk sync Note: These queries reference temp tables that don't exist in the schema. sqlc cannot validate these, but we organize them here for maintainability. Temp Server Table Operations
func (*Queries) DeleteAPIRegistry ¶ added in v0.4.7
Delete an API registry by name (returns 0 if not found or is CONFIG type)
func (*Queries) DeleteConfigRegistriesNotInList ¶ added in v0.4.7
Delete CONFIG registries not in the provided list (for config file sync)
func (*Queries) DeleteConfigRegistry ¶ added in v0.4.7
Delete a CONFIG registry by name (returns 0 if not found or is API type)
func (*Queries) DeleteOrphanedIcons ¶ added in v0.3.2
func (*Queries) DeleteOrphanedPackages ¶ added in v0.3.2
func (*Queries) DeleteOrphanedRemotes ¶ added in v0.3.2
func (*Queries) DeleteOrphanedServers ¶ added in v0.3.2
func (q *Queries) DeleteOrphanedServers(ctx context.Context, arg DeleteOrphanedServersParams) error
func (*Queries) DeleteServerIconsByServerId ¶ added in v0.3.2
func (*Queries) DeleteServerPackagesByServerId ¶ added in v0.3.2
func (*Queries) DeleteServerRemotesByServerId ¶ added in v0.3.2
func (*Queries) DeleteServerVersion ¶ added in v0.3.0
func (*Queries) DeleteServersByRegistry ¶ added in v0.3.2
func (*Queries) GetAPIRegistriesByNames ¶ added in v0.4.4
func (*Queries) GetRegistry ¶
func (*Queries) GetRegistryByName ¶ added in v0.3.0
func (*Queries) GetRegistrySync ¶
func (*Queries) GetRegistrySyncByName ¶ added in v0.3.1
func (*Queries) GetServerIDsByRegistryNameVersion ¶ added in v0.3.2
func (*Queries) GetServerVersion ¶ added in v0.3.0
func (q *Queries) GetServerVersion(ctx context.Context, arg GetServerVersionParams) (GetServerVersionRow, error)
func (*Queries) InitializeRegistrySync ¶ added in v0.3.1
func (q *Queries) InitializeRegistrySync(ctx context.Context, arg InitializeRegistrySyncParams) error
func (*Queries) InsertAPIRegistry ¶ added in v0.4.7
func (q *Queries) InsertAPIRegistry(ctx context.Context, arg InsertAPIRegistryParams) (Registry, error)
============================================================================ API Registry Queries (only operate on creation_type='API') ============================================================================ Insert a new API registry with full configuration
func (*Queries) InsertConfigRegistry ¶ added in v0.4.7
func (q *Queries) InsertConfigRegistry(ctx context.Context, arg InsertConfigRegistryParams) (uuid.UUID, error)
============================================================================ CONFIG Registry Queries (only operate on creation_type='CONFIG') ============================================================================ Insert a new CONFIG registry with full configuration
func (*Queries) InsertRegistrySync ¶
func (*Queries) InsertServerIcon ¶ added in v0.3.0
func (q *Queries) InsertServerIcon(ctx context.Context, arg InsertServerIconParams) error
func (*Queries) InsertServerPackage ¶ added in v0.3.0
func (q *Queries) InsertServerPackage(ctx context.Context, arg InsertServerPackageParams) error
func (*Queries) InsertServerRemote ¶ added in v0.3.0
func (q *Queries) InsertServerRemote(ctx context.Context, arg InsertServerRemoteParams) error
func (*Queries) InsertServerVersion ¶ added in v0.3.0
func (*Queries) InsertServerVersionForSync ¶ added in v0.3.2
func (*Queries) ListAllRegistryNames ¶ added in v0.3.1
func (*Queries) ListRegistries ¶
func (q *Queries) ListRegistries(ctx context.Context, arg ListRegistriesParams) ([]ListRegistriesRow, error)
func (*Queries) ListRegistrySyncs ¶ added in v0.3.1
func (q *Queries) ListRegistrySyncs(ctx context.Context) ([]ListRegistrySyncsRow, error)
func (*Queries) ListRegistrySyncsByLastUpdate ¶ added in v0.4.1
func (q *Queries) ListRegistrySyncsByLastUpdate(ctx context.Context) ([]ListRegistrySyncsByLastUpdateRow, error)
func (*Queries) ListServerPackages ¶ added in v0.3.0
func (*Queries) ListServerRemotes ¶ added in v0.3.0
func (*Queries) ListServerVersions ¶
func (q *Queries) ListServerVersions(ctx context.Context, arg ListServerVersionsParams) ([]ListServerVersionsRow, error)
func (*Queries) ListServers ¶
func (q *Queries) ListServers(ctx context.Context, arg ListServersParams) ([]ListServersRow, error)
func (*Queries) UpdateAPIRegistry ¶ added in v0.4.7
func (q *Queries) UpdateAPIRegistry(ctx context.Context, arg UpdateAPIRegistryParams) (Registry, error)
Update an existing API registry (returns NULL if not found or is CONFIG type)
func (*Queries) UpdateRegistrySync ¶
func (q *Queries) UpdateRegistrySync(ctx context.Context, arg UpdateRegistrySyncParams) error
func (*Queries) UpdateRegistrySyncStatusByName ¶ added in v0.4.1
func (q *Queries) UpdateRegistrySyncStatusByName(ctx context.Context, arg UpdateRegistrySyncStatusByNameParams) error
func (*Queries) UpsertConfigRegistry ¶ added in v0.4.7
func (q *Queries) UpsertConfigRegistry(ctx context.Context, arg UpsertConfigRegistryParams) (uuid.UUID, error)
Insert or update a CONFIG registry (only updates if existing is CONFIG type)
func (*Queries) UpsertIconsFromTemp ¶ added in v0.3.2
func (*Queries) UpsertLatestServerVersion ¶
func (*Queries) UpsertPackagesFromTemp ¶ added in v0.3.2
func (*Queries) UpsertRegistrySyncByName ¶ added in v0.3.1
func (q *Queries) UpsertRegistrySyncByName(ctx context.Context, arg UpsertRegistrySyncByNameParams) error
func (*Queries) UpsertRemotesFromTemp ¶ added in v0.3.2
func (*Queries) UpsertServerVersionForSync ¶ added in v0.3.2
func (*Queries) UpsertServersFromTemp ¶ added in v0.3.2
type Registry ¶
type Registry struct {
ID uuid.UUID `json:"id"`
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
CreationType CreationType `json:"creation_type"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
Syncable bool `json:"syncable"`
}
type RegistrySync ¶
type RegistrySync struct {
ID uuid.UUID `json:"id"`
RegID uuid.UUID `json:"reg_id"`
SyncStatus SyncStatus `json:"sync_status"`
ErrorMsg *string `json:"error_msg"`
StartedAt *time.Time `json:"started_at"`
EndedAt *time.Time `json:"ended_at"`
AttemptCount int64 `json:"attempt_count"`
LastSyncHash *string `json:"last_sync_hash"`
LastAppliedFilterHash *string `json:"last_applied_filter_hash"`
ServerCount int64 `json:"server_count"`
}
type RegistryType ¶
type RegistryType string
const ( RegistryTypeMANAGED RegistryType = "MANAGED" RegistryTypeFILE RegistryType = "FILE" RegistryTypeREMOTE RegistryType = "REMOTE" RegistryTypeKUBERNETES RegistryType = "KUBERNETES" )
func (*RegistryType) Scan ¶
func (e *RegistryType) Scan(src interface{}) error
type SyncStatus ¶
type SyncStatus string
const ( SyncStatusINPROGRESS SyncStatus = "IN_PROGRESS" SyncStatusCOMPLETED SyncStatus = "COMPLETED" SyncStatusFAILED SyncStatus = "FAILED" )
func (*SyncStatus) Scan ¶
func (e *SyncStatus) Scan(src interface{}) error
type TempMcpServer ¶ added in v0.3.2
type TempMcpServer struct {
Name string `json:"name"`
Version string `json:"version"`
RegID uuid.UUID `json:"reg_id"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}
type TempMcpServerIcon ¶ added in v0.3.2
type TempMcpServerPackage ¶ added in v0.3.2
type TempMcpServerPackage struct {
ServerID uuid.UUID `json:"server_id"`
RegistryType string `json:"registry_type"`
PkgRegistryUrl string `json:"pkg_registry_url"`
PkgIdentifier string `json:"pkg_identifier"`
PkgVersion string `json:"pkg_version"`
RuntimeHint *string `json:"runtime_hint"`
RuntimeArguments []string `json:"runtime_arguments"`
PackageArguments []string `json:"package_arguments"`
EnvVars []string `json:"env_vars"`
Sha256Hash *string `json:"sha256_hash"`
Transport string `json:"transport"`
TransportUrl *string `json:"transport_url"`
TransportHeaders []string `json:"transport_headers"`
}
type TempMcpServerRemote ¶ added in v0.3.2
type UpdateAPIRegistryParams ¶ added in v0.4.7
type UpdateAPIRegistryParams struct {
RegType RegistryType `json:"reg_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
Syncable bool `json:"syncable"`
UpdatedAt *time.Time `json:"updated_at"`
Name string `json:"name"`
}
type UpdateRegistrySyncStatusByNameParams ¶ added in v0.4.1
type UpdateRegistrySyncStatusByNameParams struct {
SyncStatus SyncStatus `json:"sync_status"`
StartedAt *time.Time `json:"started_at"`
Name string `json:"name"`
}
type UpsertConfigRegistryParams ¶ added in v0.4.7
type UpsertConfigRegistryParams struct {
Name string `json:"name"`
RegType RegistryType `json:"reg_type"`
SourceType *string `json:"source_type"`
Format *string `json:"format"`
SourceConfig []byte `json:"source_config"`
FilterConfig []byte `json:"filter_config"`
SyncSchedule pgtypes.Interval `json:"sync_schedule"`
Syncable bool `json:"syncable"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
}
type UpsertRegistrySyncByNameParams ¶ added in v0.3.1
type UpsertRegistrySyncByNameParams struct {
Name string `json:"name"`
SyncStatus SyncStatus `json:"sync_status"`
ErrorMsg *string `json:"error_msg"`
StartedAt *time.Time `json:"started_at"`
EndedAt *time.Time `json:"ended_at"`
AttemptCount int64 `json:"attempt_count"`
LastSyncHash *string `json:"last_sync_hash"`
LastAppliedFilterHash *string `json:"last_applied_filter_hash"`
ServerCount int64 `json:"server_count"`
}
type UpsertServerVersionForSyncParams ¶ added in v0.3.2
type UpsertServerVersionForSyncParams struct {
Name string `json:"name"`
Version string `json:"version"`
RegID uuid.UUID `json:"reg_id"`
CreatedAt *time.Time `json:"created_at"`
UpdatedAt *time.Time `json:"updated_at"`
Description *string `json:"description"`
Title *string `json:"title"`
Website *string `json:"website"`
UpstreamMeta []byte `json:"upstream_meta"`
ServerMeta []byte `json:"server_meta"`
RepositoryUrl *string `json:"repository_url"`
RepositoryID *string `json:"repository_id"`
RepositorySubfolder *string `json:"repository_subfolder"`
RepositoryType *string `json:"repository_type"`
}