database

type Config struct {
	// URL is a complete connection string, for example
	// postgres://user:password@host:5432/dbname?sslmode=require.
	URL string `envconfig:"DATABASE_URL"`
	// Host is the database server's host name, used when URL is empty.
	Host string `envconfig:"DATABASE_HOST"`
	// Port is the database server's port, used when URL is empty.
	Port int `envconfig:"DATABASE_PORT" default:"5432"`
	// Name is the database to connect to, used when URL is empty.
	Name string `envconfig:"DATABASE_NAME" default:"kargo"`
	// User is the user to connect as, used when URL is empty.
	User string `envconfig:"DATABASE_USER" default:"kargo"`
	// Password is the user's password, used when URL is empty.
	Password string `envconfig:"DATABASE_PASSWORD"`
	// SSLMode is the libpq sslmode to use, used when URL is empty.
	SSLMode string `envconfig:"DATABASE_SSL_MODE" default:"disable"`
	// ConnectTimeout bounds how long to keep retrying the first connection.
	// The database may still be starting when a component does, so being
	// unreachable or not ready is retried rather than treated as fatal until
	// this elapses. Errors that cannot clear on their own, such as a rejected
	// password, are not retried.
	ConnectTimeout time.Duration `envconfig:"DATABASE_CONNECT_TIMEOUT" default:"5m"`
	// MigrationLockTimeout bounds how long a migration run waits for another
	// run to release the lock on the schema before giving up. It must be
	// longer than the slowest migration, since that is exactly what a waiting
	// runner is waiting on.
	MigrationLockTimeout time.Duration `envconfig:"DATABASE_MIGRATION_LOCK_TIMEOUT" default:"1h"`
}

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 DeleteReplacedProjectParams struct {
	Name string
	ID   string
}

type Migrator interface {
	// Up applies every pending migration in order and returns the versions
	// it applied. It holds a session-level advisory lock, keyed on the schema
	// being migrated, for the duration, so concurrent runners against the
	// same schema wait for one another instead of racing. It is safe to call
	// when nothing is pending.
	Up(ctx context.Context) ([]int64, error)
	// Version returns the version the database is at and the version this
	// binary's migrations reach.
	Version(ctx context.Context) (current int64, target int64, err error)
	// Check returns ErrSchemaOutOfDate if the database is behind the version
	// this binary expects. Components that read the database should call it at
	// startup and refuse to serve until it passes, so that new code never runs
	// against an old schema.
	Check(ctx context.Context) error
}

type ProjectRow struct {
	ID        string
	Name      string
	CreatedAt time.Time
	SyncedAt  time.Time
}

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

type UpsertProjectParams struct {
	ID        string
	Name      string
	CreatedAt time.Time
}