yuxh/gearman-go
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

Fix bugs in example codes.

Browse Source
This commit is contained in:
mikespook 2011-10-09 17:53:55 +08:00
parent 68801a66fe
commit e34d969e47
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
example/client.go
View File

@ -8,29 +8,31 @@ import (
func main() { func main() {
client := gearman.NewClient() client := gearman.NewClient()
defer client.Close() defer client.Close()
client.AddServer("127.0.0.1:4730") if err := client.AddServer("127.0.0.1:4730"); err != nil {
log.Fatalln(err)
}
echo := []byte("Hello\x00 world") echo := []byte("Hello\x00 world")
if data, err := client.Echo(echo); err != nil { if data, err := client.Echo(echo); err != nil {
log.Println(string(data)) log.Fatalln(string(data))
} }
handle, err := client.Do("ToUpper", echo, gearman.JOB_NORMAL) handle, err := client.Do("ToUpper", echo, gearman.JOB_NORMAL)
if err != nil { if err != nil {
log.Println(err) log.Fatalln(err)
} else { } else {
log.Println(handle) log.Println(handle)
job := <-client.JobQueue /*job := <-client.JobQueue
if data, err := job.Result(); err != nil { if data, err := job.Result(); err != nil {
log.Println(err) log.Fatalln(err)
} else { } else {
log.Println(string(data)) log.Println(string(data))
} }*/
} }
known, running, numerator, denominator, err := client.Status(handle) known, running, numerator, denominator, err := client.Status(handle)
if err != nil { if err != nil {
log.Println(err) log.Fatalln(err)
} }
if !known { if !known {
log.Println("Unknown") log.Println("Unknown")