import (
    "context"
    "fmt"
    "google.golang.org/grpc"
    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
    "k8s.io/client-go/tools/clientcmd"
    "k8s.io/client-go/util/retry"
    "k8s.io/apimachinery/pkg/api/errors"
    "k8s.io/apimachinery/pkg/api/resource"
    "k8s.io/apimachinery/pkg/apis/meta/v1"
)

var kubeClient kubernetes.Interface
var kubeConfig *rest.Config

func init() {
    var err error

    kubeConfig, err = clientcmd.BuildConfigFromFlags("", "/path/to/kubeconfig")
    if err != nil {
        // handle error
    }

    kubeClient, err = kubernetes.NewForConfig(kubeConfig)
    if err != nil {
        // handle error
    }
}

func main() {
    r := manual.NewBuilderWithScheme("grpc")

    // get the IP and port of the pod for the gRPC service
    address, port, err := GetPodIPAndPort("grpc-service")
    if err != nil {
        // handle error
    }

    // add the server address to the resolver
    r.InitialState(resolver.State{Addresses: []resolver.Address{
        {Addr: fmt.Sprintf("%s:%d", address, port)},
    }})

    dialer := grpc.WithResolver(r).DialContext

    // use the dialer to create a connection to the server
    conn, err := grpc.DialContext(ctx, "grpc://service-name", dialer)
    if err != nil {
        // handle error
    }

    // do gRPC 
}

func GetPodIPAndPort(serviceName string) (string, int32, error) {
    // get the endpoints for the service
    endpoints, err := kubeClient.CoreV1().Endpoints("default").Get(context.TODO(), serviceName, v1.GetOptions{})
    if err != nil {
        if errors.IsNotFound(err) {
            return "", 0, fmt.Errorf("service not found: %s", serviceName)
        } else {
            return "", 0, err
        }
    }

    // get the IP and port of the first pod in the endpoints list
    if len(endpoints.Subsets) == 0 {
        return "", 0, fmt.Errorf("no pods found for service: %s", serviceName)
    }
    address := endpoints.Subsets[0].Addresses[0].IP
    port := endpoints.Subsets[0].Ports[0].Port

    return address, port, nil
}

为了获取特定的pod细节，我们需要使用kubernetes api。