Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

database

package

Go to main page

Versions in this module

v0

v0.1.21

Feb 10, 2026

v0.1.20

Feb 6, 2026

v0.1.19

Feb 4, 2026

v0.1.18

Feb 4, 2026

v0.1.17

Jan 30, 2026

v0.1.16

Jan 29, 2026

Changes in this version

+ type Migration struct

+ Name string

+ SQL string

+ Version int

+ type Migrator struct

+ func NewMigrator(conn *pgx.Conn, config MigratorConfig) *Migrator

+ func (m *Migrator) Migrate(ctx context.Context) error

+ type MigratorConfig struct

+ EnsureTable bool

+ MigrationFiles embed.FS

+ VersionOffset int

v0.1.15

Jan 28, 2026

v0.1.14

Jan 28, 2026

Changes in this version

+ var ErrAlreadyExists = errors.New("record already exists")

+ var ErrDatabase = errors.New("database error")

+ var ErrForbidden = errors.New("forbidden")

+ var ErrInvalidInput = errors.New("invalid input")

+ var ErrInvalidVersion = errors.New("invalid version: cannot publish duplicate version")

+ var ErrMaxServersReached = errors.New(...)

+ var ErrNotFound = errors.New("record not found")

+ func InTransactionT[T any](ctx context.Context, db Database, ...) (T, error)

+ type AgentFilter struct

+ IsLatest *bool

+ Name *string

+ Published *bool

+ RemoteURL *string

+ Semantic *SemanticSearchOptions

+ SubstringName *string

+ UpdatedSince *time.Time

+ Version *string

+ type Database interface

+ AcquirePublishLock func(ctx context.Context, tx pgx.Tx, serverName string) error

+ CheckAgentVersionExists func(ctx context.Context, tx pgx.Tx, agentName, version string) (bool, error)

+ CheckSkillVersionExists func(ctx context.Context, tx pgx.Tx, skillName, version string) (bool, error)

+ CheckVersionExists func(ctx context.Context, tx pgx.Tx, serverName, version string) (bool, error)

+ Close func() error

+ CountAgentVersions func(ctx context.Context, tx pgx.Tx, agentName string) (int, error)

+ CountServerVersions func(ctx context.Context, tx pgx.Tx, serverName string) (int, error)

+ CountSkillVersions func(ctx context.Context, tx pgx.Tx, skillName string) (int, error)

+ CreateAgent func(ctx context.Context, tx pgx.Tx, agentJSON *models.AgentJSON, ...) (*models.AgentResponse, error)

+ CreateDeployment func(ctx context.Context, tx pgx.Tx, deployment *models.Deployment) error

+ CreateServer func(ctx context.Context, tx pgx.Tx, serverJSON *apiv0.ServerJSON, ...) (*apiv0.ServerResponse, error)

+ CreateSkill func(ctx context.Context, tx pgx.Tx, skillJSON *models.SkillJSON, ...) (*models.SkillResponse, error)

+ DeleteAgent func(ctx context.Context, tx pgx.Tx, agentName, version string) error

+ DeleteServer func(ctx context.Context, tx pgx.Tx, serverName, version string) error

+ GetAgentByName func(ctx context.Context, tx pgx.Tx, agentName string) (*models.AgentResponse, error)

+ GetAgentByNameAndVersion func(ctx context.Context, tx pgx.Tx, agentName string, version string) (*models.AgentResponse, error)

+ GetAgentEmbeddingMetadata func(ctx context.Context, tx pgx.Tx, agentName, version string) (*SemanticEmbeddingMetadata, error)

+ GetAllVersionsByAgentName func(ctx context.Context, tx pgx.Tx, agentName string) ([]*models.AgentResponse, error)

+ GetAllVersionsByServerName func(ctx context.Context, tx pgx.Tx, serverName string, publishedOnly bool) ([]*apiv0.ServerResponse, error)

+ GetAllVersionsBySkillName func(ctx context.Context, tx pgx.Tx, skillName string) ([]*models.SkillResponse, error)

+ GetCurrentLatestAgentVersion func(ctx context.Context, tx pgx.Tx, agentName string) (*models.AgentResponse, error)

+ GetCurrentLatestSkillVersion func(ctx context.Context, tx pgx.Tx, skillName string) (*models.SkillResponse, error)

+ GetCurrentLatestVersion func(ctx context.Context, tx pgx.Tx, serverName string) (*apiv0.ServerResponse, error)

+ GetDeploymentByNameAndVersion func(ctx context.Context, tx pgx.Tx, serverName string, version string, ...) (*models.Deployment, error)

+ GetDeployments func(ctx context.Context, tx pgx.Tx) ([]*models.Deployment, error)

+ GetLatestServerReadme func(ctx context.Context, tx pgx.Tx, serverName string) (*ServerReadme, error)

+ GetServerByName func(ctx context.Context, tx pgx.Tx, serverName string) (*apiv0.ServerResponse, error)

+ GetServerByNameAndVersion func(ctx context.Context, tx pgx.Tx, serverName string, version string, ...) (*apiv0.ServerResponse, error)

+ GetServerEmbeddingMetadata func(ctx context.Context, tx pgx.Tx, serverName, version string) (*SemanticEmbeddingMetadata, error)

+ GetServerReadme func(ctx context.Context, tx pgx.Tx, serverName, version string) (*ServerReadme, error)

+ GetSkillByName func(ctx context.Context, tx pgx.Tx, skillName string) (*models.SkillResponse, error)

+ GetSkillByNameAndVersion func(ctx context.Context, tx pgx.Tx, skillName string, version string) (*models.SkillResponse, error)

+ InTransaction func(ctx context.Context, fn func(ctx context.Context, tx pgx.Tx) error) error

+ IsAgentPublished func(ctx context.Context, tx pgx.Tx, agentName, version string) (bool, error)

+ IsServerPublished func(ctx context.Context, tx pgx.Tx, serverName, version string) (bool, error)

+ IsSkillPublished func(ctx context.Context, tx pgx.Tx, skillName, version string) (bool, error)

+ ListAgents func(ctx context.Context, tx pgx.Tx, filter *AgentFilter, cursor string, limit int) ([]*models.AgentResponse, string, error)

+ ListServers func(ctx context.Context, tx pgx.Tx, filter *ServerFilter, cursor string, limit int) ([]*apiv0.ServerResponse, string, error)

+ ListSkills func(ctx context.Context, tx pgx.Tx, filter *SkillFilter, cursor string, limit int) ([]*models.SkillResponse, string, error)

+ PublishAgent func(ctx context.Context, tx pgx.Tx, agentName, version string) error

+ PublishServer func(ctx context.Context, tx pgx.Tx, serverName, version string) error

+ PublishSkill func(ctx context.Context, tx pgx.Tx, skillName, version string) error

+ RemoveDeployment func(ctx context.Context, tx pgx.Tx, serverName string, version string, ...) error

+ SetAgentEmbedding func(ctx context.Context, tx pgx.Tx, agentName, version string, ...) error

+ SetAgentStatus func(ctx context.Context, tx pgx.Tx, agentName, version string, status string) (*models.AgentResponse, error)

+ SetServerEmbedding func(ctx context.Context, tx pgx.Tx, serverName, version string, ...) error

+ SetServerStatus func(ctx context.Context, tx pgx.Tx, serverName, version string, status string) (*apiv0.ServerResponse, error)

+ SetSkillStatus func(ctx context.Context, tx pgx.Tx, skillName, version string, status string) (*models.SkillResponse, error)

+ UnmarkAgentAsLatest func(ctx context.Context, tx pgx.Tx, agentName string) error

+ UnmarkAsLatest func(ctx context.Context, tx pgx.Tx, serverName string) error

+ UnmarkSkillAsLatest func(ctx context.Context, tx pgx.Tx, skillName string) error

+ UnpublishAgent func(ctx context.Context, tx pgx.Tx, agentName, version string) error

+ UnpublishServer func(ctx context.Context, tx pgx.Tx, serverName, version string) error

+ UnpublishSkill func(ctx context.Context, tx pgx.Tx, skillName, version string) error

+ UpdateAgent func(ctx context.Context, tx pgx.Tx, agentName, version string, ...) (*models.AgentResponse, error)

+ UpdateDeploymentConfig func(ctx context.Context, tx pgx.Tx, serverName string, version string, ...) error

+ UpdateDeploymentStatus func(ctx context.Context, tx pgx.Tx, ...) error

+ UpdateServer func(ctx context.Context, tx pgx.Tx, serverName, version string, ...) (*apiv0.ServerResponse, error)

+ UpdateSkill func(ctx context.Context, tx pgx.Tx, skillName, version string, ...) (*models.SkillResponse, error)

+ UpsertServerReadme func(ctx context.Context, tx pgx.Tx, readme *ServerReadme) error

+ type SemanticEmbedding struct

+ Checksum string

+ Dimensions int

+ Generated time.Time

+ Model string

+ Provider string

+ Vector []float32

+ type SemanticEmbeddingMetadata struct

+ Checksum string

+ Dimensions int

+ Generated time.Time

+ HasEmbedding bool

+ Model string

+ Provider string

+ type SemanticSearchOptions struct

+ HybridSubstring *string

+ QueryEmbedding []float32

+ RawQuery string

+ Threshold float64

+ type ServerFilter struct

+ IsLatest *bool

+ Name *string

+ Published *bool

+ RemoteURL *string

+ Semantic *SemanticSearchOptions

+ SubstringName *string

+ UpdatedSince *time.Time

+ Version *string

+ type ServerReadme struct

+ Content []byte

+ ContentType string

+ FetchedAt time.Time

+ SHA256 []byte

+ ServerName string

+ SizeBytes int

+ Version string

+ type SkillFilter struct

+ IsLatest *bool

+ Name *string

+ Published *bool

+ RemoteURL *string

+ Semantic *SemanticSearchOptions

+ SubstringName *string

+ UpdatedSince *time.Time

+ Version *string