cgalo5758
296236a721
Persist non-secret ConfigSpec overrides in core and apply them at boot ahead of environment values and defaults. Validate typed and enum values, show pending restart state, and remove Stripe's unused provider config table.
77 lines
1.8 KiB
Go
77 lines
1.8 KiB
Go
// Code generated by sqlc. DO NOT EDIT.
|
|
// versions:
|
|
// sqlc v1.29.0
|
|
// source: config_overrides.sql
|
|
|
|
package integration
|
|
|
|
import (
|
|
"context"
|
|
"database/sql"
|
|
)
|
|
|
|
const deleteConfigOverride = `-- name: DeleteConfigOverride :execrows
|
|
DELETE FROM core.integration_config_overrides
|
|
WHERE key = $1
|
|
`
|
|
|
|
func (q *Queries) DeleteConfigOverride(ctx context.Context, key string) (int64, error) {
|
|
result, err := q.db.ExecContext(ctx, deleteConfigOverride, key)
|
|
if err != nil {
|
|
return 0, err
|
|
}
|
|
return result.RowsAffected()
|
|
}
|
|
|
|
const listConfigOverrides = `-- name: ListConfigOverrides :many
|
|
SELECT key, value, updated_by, updated_at
|
|
FROM core.integration_config_overrides
|
|
ORDER BY key
|
|
`
|
|
|
|
func (q *Queries) ListConfigOverrides(ctx context.Context) ([]ConfigOverride, error) {
|
|
rows, err := q.db.QueryContext(ctx, listConfigOverrides)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
defer rows.Close()
|
|
items := []ConfigOverride{}
|
|
for rows.Next() {
|
|
var i ConfigOverride
|
|
if err := rows.Scan(
|
|
&i.Key,
|
|
&i.Value,
|
|
&i.UpdatedBy,
|
|
&i.UpdatedAt,
|
|
); err != nil {
|
|
return nil, err
|
|
}
|
|
items = append(items, i)
|
|
}
|
|
if err := rows.Close(); err != nil {
|
|
return nil, err
|
|
}
|
|
if err := rows.Err(); err != nil {
|
|
return nil, err
|
|
}
|
|
return items, nil
|
|
}
|
|
|
|
const upsertConfigOverride = `-- name: UpsertConfigOverride :exec
|
|
INSERT INTO core.integration_config_overrides (key, value, updated_by)
|
|
VALUES ($1, $2, $3)
|
|
ON CONFLICT (key) DO UPDATE
|
|
SET value = EXCLUDED.value, updated_by = EXCLUDED.updated_by, updated_at = NOW()
|
|
`
|
|
|
|
type UpsertConfigOverrideParams struct {
|
|
Key string `json:"key"`
|
|
Value string `json:"value"`
|
|
UpdatedBy sql.NullString `json:"updated_by"`
|
|
}
|
|
|
|
func (q *Queries) UpsertConfigOverride(ctx context.Context, arg UpsertConfigOverrideParams) error {
|
|
_, err := q.db.ExecContext(ctx, upsertConfigOverride, arg.Key, arg.Value, arg.UpdatedBy)
|
|
return err
|
|
}
|