sql

Sep 23, 2024

Changes in this version

+ type DBTX interface

+ ExecContext func(context.Context, string, ...interface{}) (sql.Result, error)

+ PrepareContext func(context.Context, string) (*sql.Stmt, error)

+ QueryContext func(context.Context, string, ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(context.Context, string, ...interface{}) *sql.Row

+ type GetLeaseInfoRow struct

+ ExpiresAt time.Time

+ Metadata pqtype.NullRawMessage

+ type Querier interface

+ ExpireLeases func(ctx context.Context) (int64, error)

+ GetLeaseInfo func(ctx context.Context, key leases.Key) (GetLeaseInfoRow, error)

+ NewLease func(ctx context.Context, key leases.Key, ttl sqltypes.Duration, ...) (uuid.UUID, error)

+ ReleaseLease func(ctx context.Context, idempotencyKey uuid.UUID, key leases.Key) (bool, error)

+ RenewLease func(ctx context.Context, ttl sqltypes.Duration, idempotencyKey uuid.UUID, ...) (bool, error)

+ type Queries struct

+ func New(db DBTX) *Queries

+ func (q *Queries) ExpireLeases(ctx context.Context) (int64, error)

+ func (q *Queries) GetLeaseInfo(ctx context.Context, key leases.Key) (GetLeaseInfoRow, error)

+ func (q *Queries) NewLease(ctx context.Context, key leases.Key, ttl sqltypes.Duration, ...) (uuid.UUID, error)

+ func (q *Queries) ReleaseLease(ctx context.Context, idempotencyKey uuid.UUID, key leases.Key) (bool, error)

+ func (q *Queries) RenewLease(ctx context.Context, ttl sqltypes.Duration, idempotencyKey uuid.UUID, ...) (bool, error)

+ func (q *Queries) WithTx(tx *sql.Tx) *Queries