database

package

Go to main page

Versions in this module

v1

v1.3.10

Nov 18, 2025

v1.3.9

Nov 17, 2025

v1.3.8

Nov 3, 2025

v1.3.7

Oct 29, 2025

v1.3.6

Oct 29, 2025

v1.3.5

Oct 24, 2025

v1.3.4

Oct 24, 2025

v1.3.3

Oct 16, 2025

v1.3.2

Oct 16, 2025

v1.3.1

Oct 15, 2025

v1.3.0

Oct 14, 2025

v1.2.3

Sep 30, 2025

v1.2.2

Sep 30, 2025

v1.2.1

Sep 30, 2025

v1.2.0

Sep 29, 2025

Changes in this version

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

type Database

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

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

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

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

+ GetCurrentLatestVersion func(ctx context.Context, tx pgx.Tx, serverName string) (*apiv0.ServerResponse, 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)

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

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

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

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

+ type Executor interface

+ Exec func(ctx context.Context, sql string, arguments ...any) (pgconn.CommandTag, error)

+ Query func(ctx context.Context, sql string, args ...any) (pgx.Rows, error)

+ QueryRow func(ctx context.Context, sql string, args ...any) pgx.Row

type PostgreSQL

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

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

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

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

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

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

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

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

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

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

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

v1.1.0

Sep 23, 2025

Changes in this version

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

type Database

+ func NewTestDB(t *testing.T) Database

+ GetAllVersionsByServerID func(ctx context.Context, serverID string) ([]*apiv0.ServerJSON, error)

+ GetByServerID func(ctx context.Context, serverID string) (*apiv0.ServerJSON, error)

+ GetByServerIDAndVersion func(ctx context.Context, serverID string, version string) (*apiv0.ServerJSON, error)

+ GetByVersionID func(ctx context.Context, versionID string) (*apiv0.ServerJSON, error)

+ WithPublishLock func(ctx context.Context, serverName string, fn func(ctx context.Context) error) error

type PostgreSQL

+ func (db *PostgreSQL) GetAllVersionsByServerID(ctx context.Context, serverID string) ([]*apiv0.ServerJSON, error)

+ func (db *PostgreSQL) GetByServerID(ctx context.Context, serverID string) (*apiv0.ServerJSON, error)

+ func (db *PostgreSQL) GetByServerIDAndVersion(ctx context.Context, serverID string, version string) (*apiv0.ServerJSON, error)

+ func (db *PostgreSQL) GetByVersionID(ctx context.Context, versionID string) (*apiv0.ServerJSON, error)

+ func (db *PostgreSQL) WithPublishLock(ctx context.Context, serverName string, fn func(ctx context.Context) error) error

v1.0.0

Sep 8, 2025

v0

v0.0.3

Sep 8, 2025

Changes in this version

type ServerFilter

+ IsLatest *bool

+ SubstringName *string

+ UpdatedSince *time.Time

+ Version *string

v0.0.2

Sep 8, 2025

v0.0.1

Sep 8, 2025

Changes in this version

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

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

+ 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")

+ type ConnectionType string

+ const ConnectionTypeMemory

+ const ConnectionTypePostgreSQL

+ type Database interface

+ Close func() error

+ CreateServer func(ctx context.Context, server *apiv0.ServerJSON) (*apiv0.ServerJSON, error)

+ GetByID func(ctx context.Context, id string) (*apiv0.ServerJSON, error)

+ List func(ctx context.Context, filter *ServerFilter, cursor string, limit int) ([]*apiv0.ServerJSON, string, error)

+ UpdateServer func(ctx context.Context, id string, server *apiv0.ServerJSON) (*apiv0.ServerJSON, error)

+ type MemoryDB struct

+ func NewMemoryDB() *MemoryDB

+ func (db *MemoryDB) Close() error

+ func (db *MemoryDB) CreateServer(ctx context.Context, server *apiv0.ServerJSON) (*apiv0.ServerJSON, error)

+ func (db *MemoryDB) GetByID(ctx context.Context, id string) (*apiv0.ServerJSON, error)

+ func (db *MemoryDB) List(ctx context.Context, filter *ServerFilter, cursor string, limit int) ([]*apiv0.ServerJSON, string, error)

+ func (db *MemoryDB) UpdateServer(ctx context.Context, id string, server *apiv0.ServerJSON) (*apiv0.ServerJSON, error)

+ type Migration struct

+ Name string

+ SQL string

+ Version int

+ type Migrator struct

+ func NewMigrator(conn *pgx.Conn) *Migrator

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

+ type PostgreSQL struct

+ func NewPostgreSQL(ctx context.Context, connectionURI string) (*PostgreSQL, error)

+ func (db *PostgreSQL) Close() error

+ func (db *PostgreSQL) CreateServer(ctx context.Context, server *apiv0.ServerJSON) (*apiv0.ServerJSON, error)

+ func (db *PostgreSQL) GetByID(ctx context.Context, id string) (*apiv0.ServerJSON, error)

+ func (db *PostgreSQL) List(ctx context.Context, filter *ServerFilter, cursor string, limit int) ([]*apiv0.ServerJSON, string, error)

+ func (db *PostgreSQL) UpdateServer(ctx context.Context, id string, server *apiv0.ServerJSON) (*apiv0.ServerJSON, error)

+ type ServerFilter struct

+ Name *string

+ RemoteURL *string

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