From f23822bf5585040ab89f5c01dcef641d553d52fa Mon Sep 17 00:00:00 2001 From: Ethan Buchman Date: Sat, 27 Feb 2016 07:02:34 +0000 Subject: [PATCH] export NewReqRes --- client/client.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/client/client.go b/client/client.go index f4af5256..37243cfe 100644 --- a/client/client.go +++ b/client/client.go @@ -99,7 +99,7 @@ func (cli *Client) sendRequestsRoutine() { select { case <-cli.flushTimer.Ch: select { - case cli.reqQueue <- newReqRes(types.RequestFlush()): + case cli.reqQueue <- NewReqRes(types.RequestFlush()): default: // Probably will fill the buffer, or retry later. } @@ -283,7 +283,7 @@ func (cli *Client) QuerySync(query []byte) (code types.CodeType, result []byte, //---------------------------------------- func (cli *Client) queueRequest(req *types.Request) *ReqRes { - reqres := newReqRes(req) + reqres := NewReqRes(req) // TODO: set cli.err if reqQueue times out cli.reqQueue <- reqres @@ -314,7 +314,7 @@ type ReqRes struct { cb func(*types.Response) // A single callback that may be set. } -func newReqRes(req *types.Request) *ReqRes { +func NewReqRes(req *types.Request) *ReqRes { return &ReqRes{ Request: req, WaitGroup: waitGroup1(),