in cmd/spark-connect-example-raw-grpc-client/main.go [34:64]
func main() {
opts := []grpc.DialOption{
grpc.WithTransportCredentials(insecure.NewCredentials()),
}
conn, err := grpc.Dial(*remote, opts...)
if err != nil {
log.Fatalf("Failed: %s", err.Error())
}
defer conn.Close()
client := proto.NewSparkConnectServiceClient(conn)
ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
defer cancel()
configRequest := proto.ConfigRequest{
SessionId: uuid.NewString(),
Operation: &proto.ConfigRequest_Operation{
OpType: &proto.ConfigRequest_Operation_GetAll{
GetAll: &proto.ConfigRequest_GetAll{},
},
},
}
configResponse, err := client.Config(ctx, &configRequest)
if err != nil {
log.Fatalf("Failed: %s", err.Error())
}
log.Printf("configResponse: %v", configResponse)
}