sqlc

package
v0.6.4 Latest Latest
Warning

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

Go to latest
Published: Mar 16, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

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 BulkUpsertConfigRegistriesRow struct {
	ID   uuid.UUID `json:"id"`
	Name string    `json:"name"`
}

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 DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type DeleteEntryVersionParams added in v0.6.4

type DeleteEntryVersionParams struct {
	EntryID uuid.UUID `json:"entry_id"`
	Version string    `json:"version"`
}

type DeleteOrphanedServersParams added in v0.3.2

type DeleteOrphanedServersParams struct {
	RegID   uuid.UUID   `json:"reg_id"`
	KeepIds []uuid.UUID `json:"keep_ids"`
}

type DeleteOrphanedSkillsParams added in v0.6.3

type DeleteOrphanedSkillsParams struct {
	RegID   uuid.UUID   `json:"reg_id"`
	KeepIds []uuid.UUID `json:"keep_ids"`
}

type DeleteRegistryEntryParams added in v0.6.0

type DeleteRegistryEntryParams struct {
	RegID     uuid.UUID `json:"reg_id"`
	EntryType EntryType `json:"entry_type"`
	Name      string    `json:"name"`
}

type EntryType added in v0.6.0

type EntryType string
const (
	EntryTypeMCP   EntryType = "MCP"
	EntryTypeSKILL EntryType = "SKILL"
)

func (*EntryType) Scan added in v0.6.0

func (e *EntryType) Scan(src interface{}) error

type EntryVersion added in v0.6.4

type EntryVersion struct {
	ID          uuid.UUID  `json:"id"`
	EntryID     uuid.UUID  `json:"entry_id"`
	Version     string     `json:"version"`
	Title       *string    `json:"title"`
	Description *string    `json:"description"`
	CreatedAt   *time.Time `json:"created_at"`
	UpdatedAt   *time.Time `json:"updated_at"`
}

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 GetLatestVersionForServerParams added in v0.6.3

type GetLatestVersionForServerParams struct {
	Name  string    `json:"name"`
	RegID uuid.UUID `json:"reg_id"`
}

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 GetRegistryEntryByNameParams added in v0.6.4

type GetRegistryEntryByNameParams struct {
	RegID     uuid.UUID `json:"reg_id"`
	EntryType EntryType `json:"entry_type"`
	Name      string    `json:"name"`
}

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 GetServerIDsByRegistryNameVersionRow struct {
	VersionID uuid.UUID `json:"version_id"`
	Name      string    `json:"name"`
	Version   string    `json:"version"`
}

type GetServerVersionParams added in v0.3.0

type GetServerVersionParams struct {
	Name         string  `json:"name"`
	Version      string  `json:"version"`
	RegistryName *string `json:"registry_name"`
}

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 GetSkillVersionParams added in v0.6.3

type GetSkillVersionParams struct {
	Name         string  `json:"name"`
	Version      string  `json:"version"`
	RegistryName *string `json:"registry_name"`
	Namespace    *string `json:"namespace"`
}

type GetSkillVersionRow added in v0.6.3

type GetSkillVersionRow 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"`
	SkillVersionID uuid.UUID    `json:"skill_version_id"`
	Namespace      string       `json:"namespace"`
	Status         SkillStatus  `json:"status"`
	License        *string      `json:"license"`
	Compatibility  *string      `json:"compatibility"`
	AllowedTools   []string     `json:"allowed_tools"`
	Repository     []byte       `json:"repository"`
	Icons          []byte       `json:"icons"`
	Metadata       []byte       `json:"metadata"`
	ExtensionMeta  []byte       `json:"extension_meta"`
}

type IconTheme

type IconTheme string
const (
	IconThemeLIGHT IconTheme = "LIGHT"
	IconThemeDARK  IconTheme = "DARK"
)

func (*IconTheme) Scan

func (e *IconTheme) Scan(src interface{}) error

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 InsertEntryVersionParams added in v0.6.4

type InsertEntryVersionParams struct {
	EntryID     uuid.UUID  `json:"entry_id"`
	Version     string     `json:"version"`
	Title       *string    `json:"title"`
	Description *string    `json:"description"`
	CreatedAt   *time.Time `json:"created_at"`
	UpdatedAt   *time.Time `json:"updated_at"`
}

type InsertRegistryEntryParams added in v0.6.0

type InsertRegistryEntryParams struct {
	RegID     uuid.UUID  `json:"reg_id"`
	EntryType EntryType  `json:"entry_type"`
	Name      string     `json:"name"`
	CreatedAt *time.Time `json:"created_at"`
	UpdatedAt *time.Time `json:"updated_at"`
}

type InsertRegistrySyncParams

type InsertRegistrySyncParams struct {
	RegID      uuid.UUID  `json:"reg_id"`
	SyncStatus SyncStatus `json:"sync_status"`
	ErrorMsg   *string    `json:"error_msg"`
	StartedAt  *time.Time `json:"started_at"`
}

type InsertServerIconParams added in v0.3.0

type InsertServerIconParams struct {
	ServerID  uuid.UUID `json:"server_id"`
	SourceUri string    `json:"source_uri"`
	MimeType  string    `json:"mime_type"`
	Theme     IconTheme `json:"theme"`
}

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 InsertServerRemoteParams struct {
	ServerID         uuid.UUID `json:"server_id"`
	Transport        string    `json:"transport"`
	TransportUrl     string    `json:"transport_url"`
	TransportHeaders []byte    `json:"transport_headers"`
}

type InsertServerVersionForSyncParams added in v0.3.2

type InsertServerVersionForSyncParams struct {
	VersionID           uuid.UUID `json:"version_id"`
	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 {
	VersionID           uuid.UUID `json:"version_id"`
	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 InsertSkillGitPackageParams added in v0.6.3

type InsertSkillGitPackageParams struct {
	SkillID   uuid.UUID `json:"skill_id"`
	Url       string    `json:"url"`
	Ref       *string   `json:"ref"`
	CommitSha *string   `json:"commit_sha"`
	Subfolder *string   `json:"subfolder"`
}

type InsertSkillOciPackageParams added in v0.6.3

type InsertSkillOciPackageParams struct {
	SkillID    uuid.UUID `json:"skill_id"`
	Identifier string    `json:"identifier"`
	Digest     *string   `json:"digest"`
	MediaType  *string   `json:"media_type"`
}

type InsertSkillVersionForSyncParams added in v0.6.3

type InsertSkillVersionForSyncParams struct {
	VersionID     uuid.UUID       `json:"version_id"`
	Namespace     string          `json:"namespace"`
	Status        NullSkillStatus `json:"status"`
	License       *string         `json:"license"`
	Compatibility *string         `json:"compatibility"`
	AllowedTools  []string        `json:"allowed_tools"`
	Repository    []byte          `json:"repository"`
	Icons         []byte          `json:"icons"`
	Metadata      []byte          `json:"metadata"`
	ExtensionMeta []byte          `json:"extension_meta"`
}

type InsertSkillVersionParams added in v0.6.3

type InsertSkillVersionParams struct {
	VersionID     uuid.UUID       `json:"version_id"`
	Namespace     string          `json:"namespace"`
	Status        NullSkillStatus `json:"status"`
	License       *string         `json:"license"`
	Compatibility *string         `json:"compatibility"`
	AllowedTools  []string        `json:"allowed_tools"`
	Repository    []byte          `json:"repository"`
	Icons         []byte          `json:"icons"`
	Metadata      []byte          `json:"metadata"`
	ExtensionMeta []byte          `json:"extension_meta"`
}

type LatestEntryVersion added in v0.6.0

type LatestEntryVersion struct {
	RegID           uuid.UUID `json:"reg_id"`
	Name            string    `json:"name"`
	Version         string    `json:"version"`
	LatestVersionID uuid.UUID `json:"latest_version_id"`
}

type ListRegistriesParams

type ListRegistriesParams struct {
	Next *time.Time `json:"next"`
	Prev *time.Time `json:"prev"`
	Size int64      `json:"size"`
}

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 ListServerVersionsParams

type ListServerVersionsParams struct {
	Name         string     `json:"name"`
	RegistryName *string    `json:"registry_name"`
	Next         *time.Time `json:"next"`
	Prev         *time.Time `json:"prev"`
	Size         int64      `json:"size"`
}

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 ListServersParams struct {
	RegistryName  *string    `json:"registry_name"`
	Search        *string    `json:"search"`
	UpdatedSince  *time.Time `json:"updated_since"`
	CursorName    *string    `json:"cursor_name"`
	CursorVersion *string    `json:"cursor_version"`
	Version       *string    `json:"version"`
	Size          int64      `json:"size"`
}

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 ListSkillsParams added in v0.6.3

type ListSkillsParams struct {
	RegistryName  *string    `json:"registry_name"`
	Namespace     *string    `json:"namespace"`
	Name          *string    `json:"name"`
	Search        *string    `json:"search"`
	UpdatedSince  *time.Time `json:"updated_since"`
	CursorName    *string    `json:"cursor_name"`
	CursorVersion *string    `json:"cursor_version"`
	Size          int64      `json:"size"`
}

type ListSkillsRow added in v0.6.3

type ListSkillsRow struct {
	RegistryType  RegistryType `json:"registry_type"`
	VersionID     uuid.UUID    `json:"version_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"`
	Namespace     string       `json:"namespace"`
	Status        SkillStatus  `json:"status"`
	License       *string      `json:"license"`
	Compatibility *string      `json:"compatibility"`
	AllowedTools  []string     `json:"allowed_tools"`
	Repository    []byte       `json:"repository"`
	Icons         []byte       `json:"icons"`
	Metadata      []byte       `json:"metadata"`
	ExtensionMeta []byte       `json:"extension_meta"`
}

type McpServer

type McpServer struct {
	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"`
	VersionID           uuid.UUID `json:"version_id"`
}

type McpServerIcon

type McpServerIcon struct {
	ServerID  uuid.UUID `json:"server_id"`
	SourceUri string    `json:"source_uri"`
	MimeType  string    `json:"mime_type"`
	Theme     IconTheme `json:"theme"`
}

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 McpServerRemote struct {
	ServerID         uuid.UUID `json:"server_id"`
	Transport        string    `json:"transport"`
	TransportUrl     string    `json:"transport_url"`
	TransportHeaders []byte    `json:"transport_headers"`
}

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.

func (NullCreationType) Value added in v0.4.4

func (ns NullCreationType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullEntryType added in v0.6.0

type NullEntryType struct {
	EntryType EntryType `json:"entry_type"`
	Valid     bool      `json:"valid"` // Valid is true if EntryType is not NULL
}

func (*NullEntryType) Scan added in v0.6.0

func (ns *NullEntryType) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullEntryType) Value added in v0.6.0

func (ns NullEntryType) Value() (driver.Value, error)

Value implements the driver Valuer 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.

func (NullIconTheme) Value

func (ns NullIconTheme) Value() (driver.Value, error)

Value implements the driver Valuer 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.

func (NullRegistryType) Value

func (ns NullRegistryType) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type NullSkillStatus added in v0.6.3

type NullSkillStatus struct {
	SkillStatus SkillStatus `json:"skill_status"`
	Valid       bool        `json:"valid"` // Valid is true if SkillStatus is not NULL
}

func (*NullSkillStatus) Scan added in v0.6.3

func (ns *NullSkillStatus) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullSkillStatus) Value added in v0.6.3

func (ns NullSkillStatus) Value() (driver.Value, error)

Value implements the driver Valuer 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.

func (NullSyncStatus) Value

func (ns NullSyncStatus) Value() (driver.Value, error)

Value implements the driver Valuer 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)
	CountEntryVersions(ctx context.Context, entryID uuid.UUID) (int64, error)
	// Temp Entry Version Table Operations
	CreateTempEntryVersionTable(ctx context.Context) error
	// Temp Icon Table Operations
	CreateTempIconTable(ctx context.Context) error
	// Temp Package Table Operations
	CreateTempPackageTable(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
	CreateTempRegistryEntryTable(ctx context.Context) error
	// Temp Remote Table Operations
	CreateTempRemoteTable(ctx context.Context) error
	// 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)
	DeleteEntryVersion(ctx context.Context, arg DeleteEntryVersionParams) (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
	DeleteOrphanedSkills(ctx context.Context, arg DeleteOrphanedSkillsParams) error
	DeleteRegistryEntry(ctx context.Context, arg DeleteRegistryEntryParams) (int64, error)
	DeleteRegistryEntryByID(ctx context.Context, id uuid.UUID) (int64, 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
	DeleteServersByRegistry(ctx context.Context, regID uuid.UUID) error
	DeleteSkillsByRegistry(ctx context.Context, regID uuid.UUID) error
	GetAPIRegistriesByNames(ctx context.Context, names []string) ([]GetAPIRegistriesByNamesRow, error)
	GetLatestVersionForServer(ctx context.Context, arg GetLatestVersionForServerParams) (string, error)
	GetRegistry(ctx context.Context, id uuid.UUID) (GetRegistryRow, error)
	GetRegistryByName(ctx context.Context, name string) (GetRegistryByNameRow, error)
	GetRegistryEntryByName(ctx context.Context, arg GetRegistryEntryByNameParams) (uuid.UUID, 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)
	GetSkillVersion(ctx context.Context, arg GetSkillVersionParams) (GetSkillVersionRow, 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)
	InsertEntryVersion(ctx context.Context, arg InsertEntryVersionParams) (uuid.UUID, error)
	InsertRegistryEntry(ctx context.Context, arg InsertRegistryEntryParams) (uuid.UUID, error)
	InsertRegistrySync(ctx context.Context, arg InsertRegistrySyncParams) (uuid.UUID, error)
	InsertServerIcon(ctx context.Context, arg InsertServerIconParams) error
	// TODO: this seems unused
	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)
	InsertSkillGitPackage(ctx context.Context, arg InsertSkillGitPackageParams) error
	InsertSkillOciPackage(ctx context.Context, arg InsertSkillOciPackageParams) error
	InsertSkillVersion(ctx context.Context, arg InsertSkillVersionParams) (uuid.UUID, error)
	InsertSkillVersionForSync(ctx context.Context, arg InsertSkillVersionForSyncParams) (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, versionIds []uuid.UUID) ([]ListServerPackagesRow, error)
	ListServerRemotes(ctx context.Context, versionIds []uuid.UUID) ([]McpServerRemote, error)
	ListServerVersions(ctx context.Context, arg ListServerVersionsParams) ([]ListServerVersionsRow, error)
	// Cursor-based pagination using (name, version) compound cursor.
	// The cursor_name and cursor_version parameters define the starting point.
	// When cursor is provided, results start AFTER the specified (name, version) tuple.
	ListServers(ctx context.Context, arg ListServersParams) ([]ListServersRow, error)
	ListSkillGitPackages(ctx context.Context, versionIds []uuid.UUID) ([]SkillGitPackage, error)
	ListSkillOciPackages(ctx context.Context, versionIds []uuid.UUID) ([]SkillOciPackage, error)
	// Cursor-based pagination using (name, version) compound cursor.
	// The cursor_name and cursor_version parameters define the starting point.
	// When cursor is provided, results start AFTER the specified (name, version) tuple.
	ListSkills(ctx context.Context, arg ListSkillsParams) ([]ListSkillsRow, 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)
	UpsertEntryVersionsFromTemp(ctx context.Context) ([]UpsertEntryVersionsFromTempRow, error)
	UpsertIconsFromTemp(ctx context.Context) error
	UpsertLatestServerVersion(ctx context.Context, arg UpsertLatestServerVersionParams) (uuid.UUID, error)
	UpsertLatestSkillVersion(ctx context.Context, arg UpsertLatestSkillVersionParams) (uuid.UUID, error)
	UpsertPackagesFromTemp(ctx context.Context) error
	UpsertRegistryEntriesFromTemp(ctx context.Context) ([]UpsertRegistryEntriesFromTempRow, 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
	UpsertSkillVersionForSync(ctx context.Context, arg UpsertSkillVersionForSyncParams) (uuid.UUID, error)
}

type Queries

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

func New

func New(db DBTX) *Queries

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) CountEntryVersions added in v0.6.4

func (q *Queries) CountEntryVersions(ctx context.Context, entryID uuid.UUID) (int64, error)

func (*Queries) CreateTempEntryVersionTable added in v0.6.4

func (q *Queries) CreateTempEntryVersionTable(ctx context.Context) error

Temp Entry Version Table Operations

func (*Queries) CreateTempIconTable added in v0.3.2

func (q *Queries) CreateTempIconTable(ctx context.Context) error

Temp Icon Table Operations

func (*Queries) CreateTempPackageTable added in v0.3.2

func (q *Queries) CreateTempPackageTable(ctx context.Context) error

Temp Package Table Operations

func (*Queries) CreateTempRegistryEntryTable added in v0.6.0

func (q *Queries) CreateTempRegistryEntryTable(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

func (*Queries) CreateTempRemoteTable added in v0.3.2

func (q *Queries) CreateTempRemoteTable(ctx context.Context) error

Temp Remote Table Operations

func (*Queries) CreateTempServerTable added in v0.3.2

func (q *Queries) CreateTempServerTable(ctx context.Context) error

Temp Server Table Operations

func (*Queries) DeleteAPIRegistry added in v0.4.7

func (q *Queries) DeleteAPIRegistry(ctx context.Context, name string) (int64, error)

Delete an API registry by name (returns 0 if not found or is CONFIG type)

func (*Queries) DeleteConfigRegistriesNotInList added in v0.4.7

func (q *Queries) DeleteConfigRegistriesNotInList(ctx context.Context, ids []uuid.UUID) error

Delete CONFIG registries not in the provided list (for config file sync)

func (*Queries) DeleteConfigRegistry added in v0.4.7

func (q *Queries) DeleteConfigRegistry(ctx context.Context, name string) (int64, error)

Delete a CONFIG registry by name (returns 0 if not found or is API type)

func (*Queries) DeleteEntryVersion added in v0.6.4

func (q *Queries) DeleteEntryVersion(ctx context.Context, arg DeleteEntryVersionParams) (int64, error)

func (*Queries) DeleteOrphanedIcons added in v0.3.2

func (q *Queries) DeleteOrphanedIcons(ctx context.Context, serverIds []uuid.UUID) error

func (*Queries) DeleteOrphanedPackages added in v0.3.2

func (q *Queries) DeleteOrphanedPackages(ctx context.Context, serverIds []uuid.UUID) error

func (*Queries) DeleteOrphanedRemotes added in v0.3.2

func (q *Queries) DeleteOrphanedRemotes(ctx context.Context, serverIds []uuid.UUID) error

func (*Queries) DeleteOrphanedServers added in v0.3.2

func (q *Queries) DeleteOrphanedServers(ctx context.Context, arg DeleteOrphanedServersParams) error

func (*Queries) DeleteOrphanedSkills added in v0.6.3

func (q *Queries) DeleteOrphanedSkills(ctx context.Context, arg DeleteOrphanedSkillsParams) error

func (*Queries) DeleteRegistryEntry added in v0.6.0

func (q *Queries) DeleteRegistryEntry(ctx context.Context, arg DeleteRegistryEntryParams) (int64, error)

func (*Queries) DeleteRegistryEntryByID added in v0.6.4

func (q *Queries) DeleteRegistryEntryByID(ctx context.Context, id uuid.UUID) (int64, error)

func (*Queries) DeleteServerIconsByServerId added in v0.3.2

func (q *Queries) DeleteServerIconsByServerId(ctx context.Context, serverID uuid.UUID) error

func (*Queries) DeleteServerPackagesByServerId added in v0.3.2

func (q *Queries) DeleteServerPackagesByServerId(ctx context.Context, serverID uuid.UUID) error

func (*Queries) DeleteServerRemotesByServerId added in v0.3.2

func (q *Queries) DeleteServerRemotesByServerId(ctx context.Context, serverID uuid.UUID) error

func (*Queries) DeleteServersByRegistry added in v0.3.2

func (q *Queries) DeleteServersByRegistry(ctx context.Context, regID uuid.UUID) error

func (*Queries) DeleteSkillsByRegistry added in v0.6.3

func (q *Queries) DeleteSkillsByRegistry(ctx context.Context, regID uuid.UUID) error

func (*Queries) GetAPIRegistriesByNames added in v0.4.4

func (q *Queries) GetAPIRegistriesByNames(ctx context.Context, names []string) ([]GetAPIRegistriesByNamesRow, error)

func (*Queries) GetLatestVersionForServer added in v0.6.3

func (q *Queries) GetLatestVersionForServer(ctx context.Context, arg GetLatestVersionForServerParams) (string, error)

func (*Queries) GetRegistry

func (q *Queries) GetRegistry(ctx context.Context, id uuid.UUID) (GetRegistryRow, error)

func (*Queries) GetRegistryByName added in v0.3.0

func (q *Queries) GetRegistryByName(ctx context.Context, name string) (GetRegistryByNameRow, error)

func (*Queries) GetRegistryEntryByName added in v0.6.4

func (q *Queries) GetRegistryEntryByName(ctx context.Context, arg GetRegistryEntryByNameParams) (uuid.UUID, error)

func (*Queries) GetRegistrySync

func (q *Queries) GetRegistrySync(ctx context.Context, id uuid.UUID) (RegistrySync, error)

func (*Queries) GetRegistrySyncByName added in v0.3.1

func (q *Queries) GetRegistrySyncByName(ctx context.Context, name string) (RegistrySync, error)

func (*Queries) GetServerIDsByRegistryNameVersion added in v0.3.2

func (q *Queries) GetServerIDsByRegistryNameVersion(ctx context.Context, regID uuid.UUID) ([]GetServerIDsByRegistryNameVersionRow, error)

func (*Queries) GetServerVersion added in v0.3.0

func (q *Queries) GetServerVersion(ctx context.Context, arg GetServerVersionParams) (GetServerVersionRow, error)

func (*Queries) GetSkillVersion added in v0.6.3

func (q *Queries) GetSkillVersion(ctx context.Context, arg GetSkillVersionParams) (GetSkillVersionRow, 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) InsertEntryVersion added in v0.6.4

func (q *Queries) InsertEntryVersion(ctx context.Context, arg InsertEntryVersionParams) (uuid.UUID, error)

func (*Queries) InsertRegistryEntry added in v0.6.0

func (q *Queries) InsertRegistryEntry(ctx context.Context, arg InsertRegistryEntryParams) (uuid.UUID, error)

func (*Queries) InsertRegistrySync

func (q *Queries) InsertRegistrySync(ctx context.Context, arg InsertRegistrySyncParams) (uuid.UUID, error)

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

TODO: this seems unused

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 (q *Queries) InsertServerVersion(ctx context.Context, arg InsertServerVersionParams) (uuid.UUID, error)

func (*Queries) InsertServerVersionForSync added in v0.3.2

func (q *Queries) InsertServerVersionForSync(ctx context.Context, arg InsertServerVersionForSyncParams) (uuid.UUID, error)

func (*Queries) InsertSkillGitPackage added in v0.6.3

func (q *Queries) InsertSkillGitPackage(ctx context.Context, arg InsertSkillGitPackageParams) error

func (*Queries) InsertSkillOciPackage added in v0.6.3

func (q *Queries) InsertSkillOciPackage(ctx context.Context, arg InsertSkillOciPackageParams) error

func (*Queries) InsertSkillVersion added in v0.6.3

func (q *Queries) InsertSkillVersion(ctx context.Context, arg InsertSkillVersionParams) (uuid.UUID, error)

func (*Queries) InsertSkillVersionForSync added in v0.6.3

func (q *Queries) InsertSkillVersionForSync(ctx context.Context, arg InsertSkillVersionForSyncParams) (uuid.UUID, error)

func (*Queries) ListAllRegistryNames added in v0.3.1

func (q *Queries) ListAllRegistryNames(ctx context.Context) ([]string, error)

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 (q *Queries) ListServerPackages(ctx context.Context, versionIds []uuid.UUID) ([]ListServerPackagesRow, error)

func (*Queries) ListServerRemotes added in v0.3.0

func (q *Queries) ListServerRemotes(ctx context.Context, versionIds []uuid.UUID) ([]McpServerRemote, error)

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)

Cursor-based pagination using (name, version) compound cursor. The cursor_name and cursor_version parameters define the starting point. When cursor is provided, results start AFTER the specified (name, version) tuple.

func (*Queries) ListSkillGitPackages added in v0.6.3

func (q *Queries) ListSkillGitPackages(ctx context.Context, versionIds []uuid.UUID) ([]SkillGitPackage, error)

func (*Queries) ListSkillOciPackages added in v0.6.3

func (q *Queries) ListSkillOciPackages(ctx context.Context, versionIds []uuid.UUID) ([]SkillOciPackage, error)

func (*Queries) ListSkills added in v0.6.3

func (q *Queries) ListSkills(ctx context.Context, arg ListSkillsParams) ([]ListSkillsRow, error)

Cursor-based pagination using (name, version) compound cursor. The cursor_name and cursor_version parameters define the starting point. When cursor is provided, results start AFTER the specified (name, version) tuple.

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) UpsertEntryVersionsFromTemp added in v0.6.4

func (q *Queries) UpsertEntryVersionsFromTemp(ctx context.Context) ([]UpsertEntryVersionsFromTempRow, error)

func (*Queries) UpsertIconsFromTemp added in v0.3.2

func (q *Queries) UpsertIconsFromTemp(ctx context.Context) error

func (*Queries) UpsertLatestServerVersion

func (q *Queries) UpsertLatestServerVersion(ctx context.Context, arg UpsertLatestServerVersionParams) (uuid.UUID, error)

func (*Queries) UpsertLatestSkillVersion added in v0.6.3

func (q *Queries) UpsertLatestSkillVersion(ctx context.Context, arg UpsertLatestSkillVersionParams) (uuid.UUID, error)

func (*Queries) UpsertPackagesFromTemp added in v0.3.2

func (q *Queries) UpsertPackagesFromTemp(ctx context.Context) error

func (*Queries) UpsertRegistryEntriesFromTemp added in v0.6.0

func (q *Queries) UpsertRegistryEntriesFromTemp(ctx context.Context) ([]UpsertRegistryEntriesFromTempRow, error)

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 (q *Queries) UpsertRemotesFromTemp(ctx context.Context) error

func (*Queries) UpsertServerVersionForSync added in v0.3.2

func (q *Queries) UpsertServerVersionForSync(ctx context.Context, arg UpsertServerVersionForSyncParams) (uuid.UUID, error)

func (*Queries) UpsertServersFromTemp added in v0.3.2

func (q *Queries) UpsertServersFromTemp(ctx context.Context) error

func (*Queries) UpsertSkillVersionForSync added in v0.6.3

func (q *Queries) UpsertSkillVersionForSync(ctx context.Context, arg UpsertSkillVersionForSyncParams) (uuid.UUID, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx pgx.Tx) *Queries

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 RegistryEntry added in v0.6.0

type RegistryEntry struct {
	ID        uuid.UUID  `json:"id"`
	RegID     uuid.UUID  `json:"reg_id"`
	EntryType EntryType  `json:"entry_type"`
	Name      string     `json:"name"`
	CreatedAt *time.Time `json:"created_at"`
	UpdatedAt *time.Time `json:"updated_at"`
}

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 Skill added in v0.6.3

type Skill struct {
	VersionID     uuid.UUID   `json:"version_id"`
	Namespace     string      `json:"namespace"`
	Status        SkillStatus `json:"status"`
	License       *string     `json:"license"`
	Compatibility *string     `json:"compatibility"`
	AllowedTools  []string    `json:"allowed_tools"`
	Repository    []byte      `json:"repository"`
	Icons         []byte      `json:"icons"`
	Metadata      []byte      `json:"metadata"`
	ExtensionMeta []byte      `json:"extension_meta"`
}

type SkillGitPackage added in v0.6.3

type SkillGitPackage struct {
	ID        uuid.UUID `json:"id"`
	SkillID   uuid.UUID `json:"skill_id"`
	Url       string    `json:"url"`
	Ref       *string   `json:"ref"`
	CommitSha *string   `json:"commit_sha"`
	Subfolder *string   `json:"subfolder"`
}

type SkillOciPackage added in v0.6.3

type SkillOciPackage struct {
	ID         uuid.UUID `json:"id"`
	SkillID    uuid.UUID `json:"skill_id"`
	Identifier string    `json:"identifier"`
	Digest     *string   `json:"digest"`
	MediaType  *string   `json:"media_type"`
}

type SkillStatus added in v0.6.3

type SkillStatus string
const (
	SkillStatusACTIVE     SkillStatus = "ACTIVE"
	SkillStatusDEPRECATED SkillStatus = "DEPRECATED"
	SkillStatusARCHIVED   SkillStatus = "ARCHIVED"
)

func (*SkillStatus) Scan added in v0.6.3

func (e *SkillStatus) 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 TempEntryVersion added in v0.6.4

type TempEntryVersion struct {
	ID          uuid.UUID  `json:"id"`
	EntryID     uuid.UUID  `json:"entry_id"`
	Version     string     `json:"version"`
	Title       *string    `json:"title"`
	Description *string    `json:"description"`
	CreatedAt   *time.Time `json:"created_at"`
	UpdatedAt   *time.Time `json:"updated_at"`
}

type TempMcpServer added in v0.3.2

type TempMcpServer struct {
	VersionID           uuid.UUID `json:"version_id"`
	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 TempMcpServerIcon struct {
	ServerID  uuid.UUID `json:"server_id"`
	SourceUri string    `json:"source_uri"`
	MimeType  string    `json:"mime_type"`
	Theme     string    `json:"theme"`
}

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 TempMcpServerRemote struct {
	ServerID         uuid.UUID `json:"server_id"`
	Transport        string    `json:"transport"`
	TransportUrl     string    `json:"transport_url"`
	TransportHeaders []string  `json:"transport_headers"`
}

type TempRegistryEntry added in v0.6.0

type TempRegistryEntry struct {
	ID        uuid.UUID  `json:"id"`
	RegID     uuid.UUID  `json:"reg_id"`
	EntryType EntryType  `json:"entry_type"`
	Name      string     `json:"name"`
	CreatedAt *time.Time `json:"created_at"`
	UpdatedAt *time.Time `json:"updated_at"`
}

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 UpdateRegistrySyncParams

type UpdateRegistrySyncParams struct {
	SyncStatus SyncStatus `json:"sync_status"`
	ErrorMsg   *string    `json:"error_msg"`
	EndedAt    *time.Time `json:"ended_at"`
	ID         uuid.UUID  `json:"id"`
}

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 UpsertEntryVersionsFromTempRow added in v0.6.4

type UpsertEntryVersionsFromTempRow struct {
	ID      uuid.UUID `json:"id"`
	EntryID uuid.UUID `json:"entry_id"`
	Version string    `json:"version"`
}

type UpsertLatestServerVersionParams

type UpsertLatestServerVersionParams struct {
	RegID     uuid.UUID `json:"reg_id"`
	Name      string    `json:"name"`
	Version   string    `json:"version"`
	VersionID uuid.UUID `json:"version_id"`
}

type UpsertLatestSkillVersionParams added in v0.6.3

type UpsertLatestSkillVersionParams struct {
	RegID     uuid.UUID `json:"reg_id"`
	Name      string    `json:"name"`
	Version   string    `json:"version"`
	VersionID uuid.UUID `json:"version_id"`
}

type UpsertRegistryEntriesFromTempRow added in v0.6.0

type UpsertRegistryEntriesFromTempRow struct {
	ID        uuid.UUID `json:"id"`
	RegID     uuid.UUID `json:"reg_id"`
	EntryType EntryType `json:"entry_type"`
	Name      string    `json:"name"`
}

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 {
	VersionID           uuid.UUID `json:"version_id"`
	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 UpsertSkillVersionForSyncParams added in v0.6.3

type UpsertSkillVersionForSyncParams struct {
	VersionID     uuid.UUID       `json:"version_id"`
	Namespace     string          `json:"namespace"`
	Status        NullSkillStatus `json:"status"`
	License       *string         `json:"license"`
	Compatibility *string         `json:"compatibility"`
	AllowedTools  []string        `json:"allowed_tools"`
	Repository    []byte          `json:"repository"`
	Icons         []byte          `json:"icons"`
	Metadata      []byte          `json:"metadata"`
	ExtensionMeta []byte          `json:"extension_meta"`
}

Jump to

Keyboard shortcuts

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