草庐IT

client_grpc_app

全部标签

go - GRPC:什么时候有新客户?

我在我的项目中使用grpc,如果我有一个grpc服务调用helloService,我应该使用GetNewHelloServiceClient在每个函数中获取一个新的客户端吗?或者只在启动程序中获取一次?//forexample:c.GET("/hello",SayHello)funcSayHello(){c:=pb.GetNewHelloServiceClient()res,err:=c.SayHello(context.Background(),&request)iferr!=nil{return}fmt.print(res.Hello)} 最佳答案

go - 未定义 : SQLiteConn when trying to build go app for armv7

我必须为UbuntuARM-v7编译一个Go服务当我编译它时GOARCH=armGOARM=7gobuild-v-orelease/edge_to_bc-ldflags'-s-w-extldflags"-static"'./...我得到:gitlab.com/company/edge_to_bc/vendor/github.com/hyperledger/fabric/bccsp/pkcs11#gitlab.com/company/edge_to_bc/vendor/github.com/hyperledger/fabric/bccsp/pkcs11vendor/github.com/

go - HTTP : server gave HTTP response to HTTPS client

我正在使用go来使用googlemapsgeocodingAPI,但我不断收到此错误:TheHTTPrequestfailedwitherrorGethttps://maps.googleapis.com/maps/api/geocode/json?address=Bangalore&key=KEY:http:servergaveHTTPresponsetoHTTPSclient错误中的url在我的浏览器中工作正常并给出适当的响应,但不会在下面的代码片段中给出我想要的:packagemainimport("fmt""io/ioutil""net/http")funcmain(){key

google-app-engine - 如何使用结构数组实现 google datastore propertyloadsaver

当你有一个结构数组时,你如何为谷歌数据存储实现Load()和Save()?这显然是可能的,但如何实现呢?首先,当您允许数据​​存储本身使用Phone对象列表序列化一个Person时,您可以使用反射来查看它在内部创建了一个列表>*datastore.Entity对象:packagemainimport("fmt""reflect""cloud.google.com/go/datastore")typePhonestruct{TypestringNumberstring}typePersonstruct{NamestringPhone[]Phone}funcmain(){person:=P

go - grpc 服务器在同时发送多条消息后停止接收消息

我正在实现一个简单的grpc服务,其中任务摘要将被发送到grpc服务器。如果我发送的消息数量较少,一切正常,但是当我开始发送5000条消息时,服务器停止并在客户端收到超出截止日期的消息。我也尝试重新连接,但发现错误消息为。rpcerror:code=Unavailabledesc=allSubConnsareinTransientFailure,latestconnectionerror:timedoutwaitingforserverhandshake服务器未显示任何错误并且处于事件状态。我也尝试设置GRPC_GO_REQUIRE_HANDSHAKE=off但错误仍然存​​在。我还实

go - grpc:使用 oneof 会导致无效的内存地址或 nil 指针取消引用

我正在尝试使用Go将proto3结构发送到gRPC服务器。该结构有一个oneof类型,我似乎很好地填充了它。将消息发送到我的gRPC客户端时,我对无效内存地址或nil指针引用感到panic。我有原型(prototype)定义(完整文件位于https://github.com/MovingGauteng/geofancy-rs/blob/master/proto/geofancy.proto:#proto3messageDocument{stringcollection=1;stringid=2;oneofgeo{Pointpoint=4;LineStringline=5;Boundsb

go - 欺骗 grpc UnaryHandler 以在 Go 中对 gRPC 进行单元测试

我正在努力提高我的GogRPC服务器的覆盖率,但我在为服务器的拦截器功能编写测试时遇到了麻烦,因为我无法有意义地满足UnaryHandler类型。我有一个函数Interceptor具有以下签名:Interceptorfunc(ctxcontext.Context,reqinterface{},info*grpc.UnaryServerInfo,handlergrpc.UnaryHandler,//我假设任何gRPC方法都会满足UnaryHandler的签名:typeUnaryHandlerfunc(ctxcontext.Context,reqinterface{})(interface

google-app-engine - 在 Google App Engine 上从 main.go 传递出去时上下文值发生变化

有一个问题,当我将context.Context传递给GoogleAppEngine上的另一个包后,我不知道为什么会发生更改。以下代码在AppEngine上运行时运行良好:packagemainimport("net/http""log""google.golang.org/appengine")funcmain(){http.HandleFunc("/",myHandler)appengine.Main()}funcmyHandler(whttp.ResponseWriter,r*http.Request){ctx:=r.Context()account,err:=appengine

docker - 启动容器进程导致 "exec:\"/app\": permission denied": unknown

当我尝试使用docker构建golang时docker镜像构建成功,但是用dockerrun运行时出现如下错误docker:Errorresponsefromdaemon:OCIruntimecreatefailed:container_linux.go:345:startingcontainerprocesscaused"exec:\"/app\":permissiondenied":unknown.我认为这个错误导致没有用户添加,所以我添加了如下组和用户RUNgroupadd-g10001myapp\&&useradd-u10001-gmyappmyapp但没有修复。这是我的源do

go - 如何从集群内 client-go api 调用中检索 kubectl describe pods <namespace> 中的所有数据

我需要获取一些pod信息,这些信息将用于一些将在集群内运行的单元测试。我需要kubectldescribepo提供的所有信息,但来自集群api调用。我有一些工作代码可以对apis/metrics.k8s.io/v1beta1/pods进行api调用,并在minikube上安装了metrics-server进行测试,这一切正常并给我这样的输出:Namespace:kube-systemPodname:heapster-rgnljSelfLink:/apis/metrics.k8s.io/v1beta1/namespaces/kube-system/pods/heapster-rgnljC