modify query.go

longganhua

2019-07-18 6f6e748602c0694712564cdf54164ca7f903222b

modify query.go

 command/query.go

@@ -8,6 +8,7 @@
    "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"
@@ -107,7 +108,6 @@
        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))
@@ -234,8 +234,8 @@
        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 {