| | |
|---|
| | | import ( |
|---|
| | | "flag" |
|---|
| | | "fmt" |
|---|
| | | "io/ioutil" |
|---|
| | | "strings" |
|---|
| | | "time" |
|---|
| | | |
|---|
| | | sdb "basic.com/pubsub/syncdb.git/db" |
|---|
| | | |
|---|
| | | "github.com/hashicorp/serf/client" |
|---|
| | | "github.com/hashicorp/serf/cmd/serf/command/agent" |
|---|
| | |
|---|
| | | handler.AckReceived(a) |
|---|
| | | |
|---|
| | | case r := <-respCh: |
|---|
| | | fmt.Println("enter respch: r.payload", len(r.Payload)) |
|---|
| | | if r.From == "" { |
|---|
| | | break OUTER |
|---|
| | | } |
|---|
| | |
|---|
| | | payload = payload[:n-1] |
|---|
| | | } |
|---|
| | | |
|---|
| | | t.ui.Info(fmt.Sprintf("Response from '%s': %s", r.From, payload)) |
|---|
| | | /** my self example*/ |
|---|
| | | |
|---|
| | | sdb.Dbconn.Close() |
|---|
| | | sdb.Dbconn = nil |
|---|
| | | err := ioutil.WriteFile("test.db", payload, 0644) |
|---|
| | | if err != nil { |
|---|
| | | fmt.Println("query byte to file error!", err) |
|---|
| | | } |
|---|
| | | err = sdb.GetConn() |
|---|
| | | if err != nil { |
|---|
| | | fmt.Println("create db conn of test.db error: ", err) |
|---|
| | | } |
|---|
| | | /* my self example*/ |
|---|
| | | fmt.Printf("Response from %s: %d\n", r.From, len(payload)) |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (t *textQueryRespFormat) Finished() error { |
|---|
