Gearman-GoGearman-API 的 Go 语言版本
Gearman-Go 是 Gearman-API 的 Go 语言封装版本,示例代码:
Worker:
// Limit number of concurrent jobs execution. // Use worker.Unlimited (0) if you want no limitation. w := worker.New(worker.OneByOne) w.ErrHandler = func(e error) { log.Println(e) } w.AddServer("127.0.0.1:4730") // Use worker.Unlimited (0) if you want no timeout w.AddFunc("ToUpper", ToUpper, worker.Unlimited) // This will give a timeout of 5 seconds w.AddFunc("ToUpperTimeOut5", ToUpper, 5) if err := w.Ready(); err != nil { log.Fatal(err) return } go w.Work()
Client:
// ... c, err := client.New("tcp4", "127.0.0.1:4730") // ... error handling defer c.Close() c.ErrorHandler = func(e error) { log.Println(e) } echo := []byte("Hello\x00 world") echomsg, err := c.Echo(echo) // ... error handling log.Println(string(echomsg)) jobHandler := func(resp *client.Response) { log.Printf("%s", resp.Data) } handle, err := c.Do("ToUpper", echo, client.JobNormal, jobHandler) // ...
评论
go-systemdsystemd 的 Go 语言绑定版本
该项目是 systemd 的 Go 语言绑定版本,提供如下几个包:activation - for
go-systemdsystemd 的 Go 语言绑定版本
0
go-systemdsystemd 的 Go 语言绑定版本
该项目是systemd的Go语言绑定版本,提供如下几个包:activation -forwritingandusingsocketactivationfromGodbus -forstarting/s
go-systemdsystemd 的 Go 语言绑定版本
0
Go语言版本1.22的路由增强功能
Go 1.22对 net/http包中的路由器进行了两项增强:方式匹配和通配符。这些特性允许你将常见的路由表示为模式,而非Go代码。尽管这些功能简单易解释和使用,但想选择成功模式的正确规则(当多个模式匹配一个请求时)依...
GoCN
0
ScaladinScala 语言的封装版本
Scaladin是Vaadin提供的Scala语言的封装版本。Scaladin为所有的UI组件提供了全新构造器,例如:valpanel=newPanel(caption="Caption",width
ScaladinScala 语言的封装版本
0
Go1.21 还是 Go1.21.0?Go 语言的版本命名规则变了
点击上方蓝色“ Go语言中文网 ”关注, 每天一起学 Go Go语言的发展遵循了一个设计驱动的过程,任何对语言、库或工具的重大改变或增加都必须经过提议、讨论和文档化的步骤,才能被实现。 Go语言的版本号由三部分组成:...
polarisxu
0