diff --git a/internal/rhash/tx.go b/internal/rhash/tx.go index dc74ed2..83e42cf 100644 --- a/internal/rhash/tx.go +++ b/internal/rhash/tx.go @@ -453,7 +453,7 @@ func (tx *Tx) set(key string, field string, value any) error { } _, err := tx.tx.Exec(sqlSet, args...) if err != nil { - return sqlx.TypedError(err) + return err } return nil } diff --git a/internal/rstring/tx.go b/internal/rstring/tx.go index 202f2c7..8508eb0 100644 --- a/internal/rstring/tx.go +++ b/internal/rstring/tx.go @@ -239,7 +239,7 @@ func set(tx sqlx.Tx, key string, value any, at time.Time) error { } _, err := tx.Exec(sqlSet, args...) if err != nil { - return sqlx.TypedError(err) + return err } return nil } @@ -260,7 +260,7 @@ func update(tx sqlx.Tx, key string, value any) error { } _, err := tx.Exec(sqlUpdate, args...) if err != nil { - return sqlx.TypedError(err) + return err } return nil } diff --git a/internal/rzset/inter.go b/internal/rzset/inter.go index 5bc6675..691eddc 100644 --- a/internal/rzset/inter.go +++ b/internal/rzset/inter.go @@ -181,7 +181,7 @@ func (c InterCmd) store(tx sqlx.Tx) (int, error) { res, err := tx.Exec(query, args...) if err != nil { - return 0, sqlx.TypedError(err) + return 0, err } // Return the number of elements in the resulting set. diff --git a/internal/rzset/tx.go b/internal/rzset/tx.go index 72d3205..561dbbb 100644 --- a/internal/rzset/tx.go +++ b/internal/rzset/tx.go @@ -241,7 +241,7 @@ func (tx *Tx) Incr(key string, elem any, delta float64) (float64, error) { } _, err := tx.tx.Exec(sqlIncr1, args...) if err != nil { - return 0, sqlx.TypedError(err) + return 0, err } var score float64 @@ -373,7 +373,7 @@ func (tx *Tx) add(key string, elem any, score float64) error { _, err := tx.tx.Exec(sqlAdd, args...) if err != nil { - return sqlx.TypedError(err) + return err } return nil } diff --git a/internal/rzset/union.go b/internal/rzset/union.go index 3c5ae22..f816684 100644 --- a/internal/rzset/union.go +++ b/internal/rzset/union.go @@ -176,7 +176,7 @@ func (c UnionCmd) store(tx sqlx.Tx) (int, error) { res, err := tx.Exec(query, args...) if err != nil { - return 0, sqlx.TypedError(err) + return 0, err } // Return the number of elements in the resulting set. diff --git a/internal/sqlx/sql.go b/internal/sqlx/sql.go index 31cca7c..f7e0e94 100644 --- a/internal/sqlx/sql.go +++ b/internal/sqlx/sql.go @@ -67,8 +67,3 @@ func Select[T any](db Tx, query string, args []any, return vals, err } - -// Returns typed errors for some specific cases. -func TypedError(err error) error { - return err -}