From 2c47d62072cfa461279f94c6f7f310d1df611953 Mon Sep 17 00:00:00 2001 From: ThereWeGo Date: Mon, 12 Aug 2024 14:22:28 +0800 Subject: [PATCH] fix(resolver/discovery): expose create watcher timeout error --- transport/grpc/resolver/discovery/builder.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/transport/grpc/resolver/discovery/builder.go b/transport/grpc/resolver/discovery/builder.go index 3d147cd83b2..5a084416a0c 100644 --- a/transport/grpc/resolver/discovery/builder.go +++ b/transport/grpc/resolver/discovery/builder.go @@ -14,6 +14,8 @@ import ( const name = "discovery" +var ErrWatcherCreateTimeout = errors.New("discovery create watcher overtime") + // Option is builder option. type Option func(o *builder) @@ -96,7 +98,7 @@ func (b *builder) Build(target resolver.Target, cc resolver.ClientConn, _ resolv case <-done: err = watchRes.err case <-time.After(b.timeout): - err = errors.New("discovery create watcher overtime") + err = ErrWatcherCreateTimeout } if err != nil { cancel()