| | |
|---|
| | | "time" |
|---|
| | | |
|---|
| | | sdb "basic.com/pubsub/syncdb.git/db" |
|---|
| | | |
|---|
| | | "github.com/hashicorp/serf/client" |
|---|
| | | "github.com/hashicorp/serf/cmd/serf/command/agent" |
|---|
| | | "github.com/mitchellh/cli" |
|---|
| | |
|---|
| | | payload = []byte(args[1]) |
|---|
| | | } |
|---|
| | | |
|---|
| | | fmt.Println("query send len payload", len(payload)) |
|---|
| | | cl, err := RPCClient(*rpcAddr, *rpcAuth) |
|---|
| | | if err != nil { |
|---|
| | | c.Ui.Error(fmt.Sprintf("Error connecting to Serf agent: %s", err)) |
|---|
| | |
|---|
| | | fmt.Println("create db conn of test.db error: ", err) |
|---|
| | | } |
|---|
| | | /* my self example*/ |
|---|
| | | fmt.Printf("Response from %s: %d\n", r.From, len(payload)) |
|---|
| | | |
|---|
| | | t.ui.Info(fmt.Sprintf("Response from '%s': %s", r.From, payload)) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (t *textQueryRespFormat) Finished() error { |
|---|
