diff --git a/go/pools/resource_pool.go b/go/pools/resource_pool.go index 124c8cebc40..8a9ac5aabe7 100644 --- a/go/pools/resource_pool.go +++ b/go/pools/resource_pool.go @@ -29,6 +29,9 @@ import ( "vitess.io/vitess/go/sync2" "vitess.io/vitess/go/timer" "vitess.io/vitess/go/trace" + "vitess.io/vitess/go/vt/vterrors" + + vtrpcpb "vitess.io/vitess/go/vt/proto/vtrpc" ) var ( @@ -36,10 +39,10 @@ var ( ErrClosed = errors.New("resource pool is closed") // ErrTimeout is returned if a resource get times out. - ErrTimeout = errors.New("resource pool timed out") + ErrTimeout = vterrors.New(vtrpcpb.Code_DEADLINE_EXCEEDED, "resource pool timed out") // ErrCtxTimeout is returned if a ctx is already expired by the time the resource pool is used - ErrCtxTimeout = errors.New("resource pool context already expired") + ErrCtxTimeout = vterrors.New(vtrpcpb.Code_DEADLINE_EXCEEDED, "resource pool context already expired") prefillTimeout = 30 * time.Second )