diff --git a/hooks/sql/cluster.go b/hooks/sql/cluster.go index 1f4d367f..f30a1828 100644 --- a/hooks/sql/cluster.go +++ b/hooks/sql/cluster.go @@ -26,17 +26,6 @@ func newSQLRowError() *sql.Row { return row } -func newSQLRowsError() *sql.Rows { - rows := &sql.Rows{} - t := reflect.TypeOf(rows).Elem() - field, _ := t.FieldByName("lasterr") - rowPtr := unsafe.Pointer(rows) - errFieldPtr := unsafe.Pointer(uintptr(rowPtr) + field.Offset) - errPtr := (*error)(errFieldPtr) - *errPtr = errNoAliveNodes - return rows -} - type ClusterQuerier interface { Querier WaitForNodes(ctx context.Context, criterion ...hasql.NodeStateCriterion) error