db

Aug 20, 2024

Changes in this version

+ func GrantedPolicyObjectProtoJSON(grantsJSON []byte) ([]*kasregistry.GrantedPolicyObject, error)

type Config

+ func (c Config) LogValue() slog.Value

Aug 12, 2024

Changes in this version

type Client

+ func (c *Client) MigrationsEnabled() bool

+ func (c *Client) RanMigrations() bool

Jul 14, 2024

Changes in this version

type Client

+ Logger *logger.Logger

May 7, 2024

Changes in this version

type Client

+ SQLDB *sql.DB

Apr 30, 2024

Changes in this version

+ const ErrTextConflict

+ const ErrTextCreationFailed

+ const ErrTextDeactivationFailed

+ const ErrTextDeletionFailed

+ const ErrTextEnumValueInvalid

+ const ErrTextFqnMissingValue

+ const ErrTextGetRetrievalFailed

+ const ErrTextListRetrievalFailed

+ const ErrTextNotFound

+ const ErrTextRelationInvalid

+ const ErrTextRestrictViolation

+ const ErrTextUUIDInvalid

+ const ErrTextUpdateFailed

+ func IsQueryBuilderSetClauseError(err error) bool

+ func KeyAccessServerProtoJSON(keyAccessServerJSON []byte) ([]*policy.KeyAccessServer, error)

+ func MarshalCreateMetadata(metadata *common.MetadataMutable) ([]byte, *common.Metadata, error)

+ func MarshalUpdateMetadata(m *common.MetadataMutable, b common.MetadataUpdateEnum, ...) ([]byte, *common.Metadata, error)

+ func NewStatementBuilder() sq.StatementBuilderType

+ func NewTable(schema string) func(name string) Table

+ func NewUniqueAlreadyExistsError(value string) error

+ func StatusifyError(err error, fallbackErr string, log ...any) error

+ func WrapIfKnownInvalidQueryErr(err error) error

+ type Client struct

+ Pgx PgxIface

+ SqlDB *sql.DB

+ func New(ctx context.Context, config Config, o ...OptsFunc) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) MigrationDown(ctx context.Context, migrations *embed.FS) error

+ func (c *Client) MigrationStatus(ctx context.Context) ([]*goose.MigrationStatus, error)

+ func (c *Client) RunMigrations(ctx context.Context, migrations *embed.FS) (int, error)

+ func (c *Client) Schema() string

+ func (c Client) Exec(ctx context.Context, sql string, args []interface{}) error

+ func (c Client) Query(ctx context.Context, sql string, args []interface{}) (pgx.Rows, error)

+ func (c Client) QueryRow(ctx context.Context, sql string, args []interface{}) (pgx.Row, error)

+ type Config struct

+ Database string

+ Host string

+ MigrationsFS *embed.FS

+ Password string

+ Port int

+ RunMigrations bool

+ SSLMode string

+ Schema string

+ User string

+ VerifyConnection bool

+ type DBError string

+ const ErrEnumValueInvalid

+ const ErrForeignKeyViolation

+ const ErrFqnMissingValue

+ const ErrMissingValue

+ const ErrNotFound

+ const ErrNotNullViolation

+ const ErrRestrictViolation

+ const ErrUUIDInvalid

+ const ErrUniqueConstraintViolation

+ func (e DBError) Error() string

+ type OptsFunc func(c Config) Config

+ func WithMigrations(fs *embed.FS) OptsFunc

+ func WithService(name string) OptsFunc

+ type PgxIface interface

+ Acquire func(ctx context.Context) (*pgxpool.Conn, error)

+ Close func()

+ Config func() *pgxpool.Config

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

+ Ping func(context.Context) error

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

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

+ type Table struct

+ func (t Table) Field(field string) string

+ func (t Table) Name() string

+ func (t Table) WithoutSchema() Table