func dialWorker(w *pb.MWorkerDescriptor) (*grpc.ClientConn, error) {
	conn, err := grpc.Dial(
		fmt.Sprintf("%s:%d", w.Host, w.Port),
		grpc.WithInsecure(),
	)
	if err != nil {
		return nil, fmt.Errorf("fail to dial: %v", err)
	}
	return conn, nil
}
dialWorker connects to a Worker
package cluster
import (
	"fmt"
	pb "github.com/go-sif/sif/internal/rpc"
	"google.golang.org/grpc"
)