fix: set pluggable component grpc dial timeout

components/hello/pluggable.go

@@ -16,6 +16,7 @@ package hello
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"mosn.io/layotto/components/pluggable"
 	helloproto "mosn.io/layotto/spec/proto/pluggable/v1/hello"
@@ -43,7 +44,8 @@ func NewGRPCHello(dialer pluggable.GRPCConnectionDialer) HelloService {
 
 func (g *grpcHello) Init(config *HelloConfig) error {
 	// 1.dial grpc server
-	ctx := context.TODO()
+	ctx, cancel := context.WithTimeout(context.TODO(), time.Second*5)
+	defer cancel()
 	conn, err := g.dialer(ctx)
 	if err != nil {
 		return fmt.Errorf("dial hello pluggable component: %w", err)

pkg/runtime/pluggable/discover.go

@@ -17,6 +17,7 @@ import (
 	"context"
 	"os"
 	"path/filepath"
+	"time"
 
 	reflectpb "google.golang.org/grpc/reflection/grpc_reflection_v1alpha"
 
@@ -80,12 +81,13 @@ type grpcConnectionCloser interface {
 
 // discover use grpc reflect to get services' information.
 func discover() ([]grpcService, error) {
-	ctx := context.TODO()
+	// set grpc connection timeout to prevent block
+	ctx, cancel := context.WithTimeout(context.TODO(), time.Second*5)
+	defer cancel()
 	serviceList, err := serviceDiscovery(func(socket string) (client reflectServiceClient, closer func(), err error) {
 		conn, err := pluggable.SocketDial(
 			ctx,
 			socket,
-			grpc.WithBlock(), // 超时设置
 		)
 		if err != nil {
 			return nil, nil, err
@@ -159,7 +161,7 @@ func serviceDiscovery(reflectClientFactory func(socket string) (client reflectSe
 		for _, s := range serviceList {
 			res = append(res, grpcService{
 				protoRef:      s,
-				dialer:        pluggable.SocketDialer(socket, grpc.WithBlock(), grpc.FailOnNonTempDialError(true)),
+				dialer:        pluggable.SocketDialer(socket, grpc.FailOnNonTempDialError(true)),
 				componentName: common.RemoveExt(f.Name()),
 			})
 		}