-
假设我们有一个带有grpc服务定义的services.proto，例如：servicefoo{rpcbar(barrequest)returns(barreply){}}messagebarrequest{stringtest=1;}messagebarreply{stringtest=1;}我们可以通过运行类似的东西将其本地编译为go$protoc--go_out=.--go_opt=paths=source_rel
-
我是Golang和Kafka的新手，我正在使用segmentiokafka-go通过Golang连接到Kafka服务器。截至目前，我想推送Kafka中用户的每个事件，所以我想推送单个消息（而不是批量），但由于该库提供的写入操作对于批量或单个消息需要相同的时间，因此需要很多时间。有没有什么方法可以快速编写单条消息，以便我可以在更短的时间内在kafka中推送数百万个事件？我已经对单条消息和批量消息进行了测试，它花费相同的时间（最短为10毫秒）。
-
我认为这是一个愚蠢的问题，我需要一个mqtt客户端在连接和订阅后继续运行。我从未遇到过这个问题，因为我的mqtt客户端始终与http服务器耦合，并且启动http服务器时，代码不会停止运行。但在当前的用例中，我只需要一个mqtt客户端来订阅某个主题并保持活动状态。这就是我所做的（该函数只是连接到代理并订阅一个主题。）funcmain(){godotenv.load("./.env")_initmqttconnection()}我需要客户端保持
-
假设我们将来要创建这样的表：createtablecity(city_idint8uniquenotnull,foundation_datetimestamptznotnulldefaultnow(),city_namevarcharnull,city_typevarchardefault'unknown',invisibleboolnull);我正在尝试创建一个proto文件，该文件将与此表结构匹配且
-
我正在尝试使用go在树莓派上远程部署容器。以下代码是原始代码的简化片段。command:="docker-hssh://[email protected]compose-f/tmp/code/docker-compose.ymlup-d"parsedcommand:=parsecommand(command)fmt.println(command)cmd:=exec.command(parsedcommand[0],p
-
我想使用_id和clientid作为过滤器键更新文档clientdata之一，我如何更新它以及它们通过聚合的任何方法。如何使用id和clientid作为过滤器将swapnil名称更新为其他名称//UpdateClientisusedtoupdateclientDatafuncUpdateClient(Datastructure.ClientDataUpdate)bool{connection:=GetConnection()ifc
-
解析正则表达式时，golang的行为不符合预期。我已经在regextester上测试了我的注册表短语，它似乎按预期工作。这是我的代码：funcmain(){tags:=regexp.MustCompile(`[^,\s][^\,]*[^,\s]`).Split("foo,bar,baz",-1)fmt.Println(tags)}golang，在我的本地环境和演示中，返回[,,]，它应该返回["foo","bar","baz"]
-
我有一个用go编写的网络应用程序，使用oauth2（包golang.org/x/oauth2）通过google登录用户（按照本教程https://developers.google.com/identity/sign-in/网络/服务器端流）。当我在本地测试应用程序时，它工作正常，但是当我部署应用程序并在docker容器内运行时（基于alpine:latest，运行二进制文件），它出现错误：posthttps://accounts.google.com/o/oauth2/token：x509
-
我有以下yaml文件，我需要对其进行parse（解析按预期工作），并且需要从yaml文件内容中提供data，该文件内容应由以下解耦函数公开我需要提供以下功能（这是其中一些功能的示例，需要更多具有相同模式的功能...）获取应用程序（）获取服务()获取应用程序（应用程序名称）getserviceforapp（应用程序名称）这是代码（可以工作......）vardmz=[]byte(`applications:-name:app1type:php
-
golang中下载依赖项子模块的推荐方法是什么？我认为通过例子可以最好地描述我的问题。示例#1：我有一个客户端和一个服务器。我的服务器是一个api，并且有许多其他依赖项，例如数据库、消息队列、consul等。我希望我的客户端是一个轻量级包，用户只需下载所需的少量依赖项客户端。您可以说客户端和服务器可以位于不同的存储库上。然而，它们之间也可能有一些共同的代码，如果我们遵循这种模式，它们将再次成为另一个存储库。我正在考虑一些如下所示的结构：service/--->common/-----
-
我对这个goswagger生成的代码有两个问题，首先我用goswagger制作了我的第一个api，但我的雇主要求我实现该单元（gotest），但尝试执行通常的http测试不起作用，这是我的测试代码//handlers_test.gopackagehandlersimport("net/http""net/http/httptest""testing""stocksapp/restapi/operations")functe
-
我知道我可以通过返回函数在go中包装函数，bug如何在go中实现等效的pythonfunctools.wraps？如何将属性附加到go中的函数？就像下面的python代码一样。fromfunctoolsimportwrapsdefd(f):defwrapper(*args):f(*args)returnwrapperdefd_wraps(f):@wraps(f)defwrapper(*args)
-
我正在尝试将下面的python代码移植（用于学习）到go-python工作正常。forninrange(81522017,81522025):b=int(str(n)+str(n+1)+str(n+2))ifb**(1/3)%1==0:print(n,b)break//solution81522019and815220198152202081522021所以在go中，我最终得到：
-
按照go示例，我使用以下代码将文件上传到google存储桶：funcuploadFile(bucketstring,uploadFilePathstring,destFilePathstring)error{os.Setenv("GOOGLE_APPLICATION_CREDENTIALS","./credential.json")ctx:=context.Background()client,err:=storage.NewClient
-
我正在尝试确定传入接口的数据类型是什么然后分配声明具有该数据类型的新对象。示例如下：funcSomeFunction(ctxcontext.Context,recordsinterface{})(interface{},error){typeobjType=CustomStruct0switchv:=records.(type){caseCustomStruct1:fmt.Print
