fix(stream): drpc, srpc: detect deadline exceeded error

Signed-off-by: Christian Stewart <christian@aperture.us>

Author: paralin

rpc/client-controller.go

@@ -92,6 +92,4 @@ func (c *ClientController) Close() error {
 }
 
 // _ is a type assertion
-var (
-	_ controller.Controller = ((*ClientController)(nil))
-)
+var _ controller.Controller = ((*ClientController)(nil))

stream/drpc/client/client.go

@@ -93,6 +93,10 @@ func (c *Client) ExecuteConnection(
 			c.c.GetTransportId(),
 		)
 		if err != nil {
+			// detect deadline exceeded
+			if err == context.Canceled && estCtx.Err() != nil && ctx.Err() == nil {
+				err = context.DeadlineExceeded
+			}
 			le.WithError(err).Warn("unable to establish drpc conn")
 			lastErr = err
 			continue

stream/srpc/srpc.go

@@ -79,6 +79,10 @@ func NewMultiOpenStreamFunc(
 			)
 			estCtxCancel()
 			if err != nil {
+				// detect deadline exceeded
+				if err == context.Canceled && estCtx.Err() != nil && ctx.Err() == nil {
+					err = context.DeadlineExceeded
+				}
 				le.WithError(err).Warn("unable to establish srpc conn")
 				lastErr = err
 				continue