From f1834275a5cf3bdf6492e49a000dcd12d53a900c Mon Sep 17 00:00:00 2001 From: Nick Stott Date: Tue, 3 Feb 2015 22:23:22 -0500 Subject: [PATCH] import rethinkdb from gopkg.in. it's still v0, so this will change still --- pkg/adaptor/rethinkdb.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/adaptor/rethinkdb.go b/pkg/adaptor/rethinkdb.go index fd0b0c38d..739c2f3ee 100644 --- a/pkg/adaptor/rethinkdb.go +++ b/pkg/adaptor/rethinkdb.go @@ -8,7 +8,7 @@ import ( "github.com/compose/transporter/pkg/message" "github.com/compose/transporter/pkg/pipe" - gorethink "github.com/dancannon/gorethink" + gorethink "gopkg.in/dancannon/gorethink.v0" ) // Rethinkdb is an adaptor that writes metrics to rethinkdb (http://rethinkdb.com/) @@ -128,9 +128,9 @@ func (r *Rethinkdb) setupClient() (*gorethink.Session, error) { fmt.Printf("Connecting to %s\n", r.uri.Host) } client, err := gorethink.Connect(gorethink.ConnectOpts{ - Address: r.uri.Host, - MaxIdle: 10, - IdleTimeout: time.Second * 10, + Address: r.uri.Host, + MaxIdle: 10, + Timeout: time.Second * 10, }) if err != nil { return nil, fmt.Errorf("unable to connect: %s", err)