Upgrade to latest gocbcore (v6).

Change-Id: I21431328a95247b3d2d947af42e5bfd175b7b17e Reviewed-on: http://review.couchbase.org/76513 Reviewed-by: Mark Nunberg <mark.nunberg@couchbase.com> Tested-by: Brett Lawson <brett19@gmail.com>
couchbase · Apr 10, 2017 · ccd582e · ccd582e
1 parent 9447f9e
commit ccd582e
Show file tree

Hide file tree

Showing 13 changed files with 14 additions and 14 deletions.
diff --git a/bucket.go b/bucket.go
@@ -1,7 +1,7 @@
 package gocb
 
 import (
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 	"math/rand"
 	"time"
 )

diff --git a/bucket_crud.go b/bucket_crud.go
@@ -1,7 +1,7 @@
 package gocb
 
 import (
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 // Get retrieves a document from the bucket

diff --git a/bucket_dura.go b/bucket_dura.go
@@ -1,7 +1,7 @@
 package gocb
 
 import (
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 func (b *Bucket) observeOnceCas(key []byte, cas Cas, forDelete bool, replicaIdx int, commCh chan uint) (pendingOp, error) {

diff --git a/bucket_internal.go b/bucket_internal.go
@@ -1,7 +1,7 @@
 package gocb
 
 import (
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 // BucketInternal holds various internally used bucket extension methods.

diff --git a/bucket_multi.go b/bucket_multi.go
@@ -1,7 +1,7 @@
 package gocb
 
 import (
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 type bulkOp struct {

diff --git a/bucket_subdoc.go b/bucket_subdoc.go
@@ -2,7 +2,7 @@ package gocb
 
 import (
 	"encoding/json"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 	"log"
 )
 

diff --git a/cluster.go b/cluster.go
@@ -4,7 +4,7 @@ import (
 	"crypto/tls"
 	"crypto/x509"
 	"errors"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 	"io/ioutil"
 	"net/http"
 	"sync"
@@ -322,7 +322,7 @@ func (c *Cluster) OpenStreamingBucket(streamName, bucket, password string) (*Str
 	if err != nil {
 		return nil, err
 	}
-	cli, err := gocbcore.CreateDcpAgent(agentConfig, streamName)
+	cli, err := gocbcore.CreateDcpAgent(agentConfig, streamName, 0)
 	if err != nil {
 		return nil, err
 	}

diff --git a/constants.go b/constants.go
@@ -1,7 +1,7 @@
 package gocb
 
 import (
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 const (

diff --git a/error.go b/error.go
@@ -2,7 +2,7 @@ package gocb
 
 import (
 	"errors"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 	"strings"
 )
 

diff --git a/logging.go b/logging.go
@@ -2,7 +2,7 @@ package gocb
 
 import (
 	"fmt"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 	"log"
 	"strings"
 )

diff --git a/token.go b/token.go
@@ -3,7 +3,7 @@ package gocb
 import (
 	"encoding/json"
 	"fmt"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 // MutationToken holds the mutation state information from an operation.

diff --git a/token_test.go b/token_test.go
@@ -2,7 +2,7 @@ package gocb
 
 import (
 	"encoding/json"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 	"strings"
 	"testing"
 )

diff --git a/transcoding.go b/transcoding.go
@@ -2,7 +2,7 @@ package gocb
 
 import (
 	"encoding/json"
-	"gopkg.in/couchbase/gocbcore.v5"
+	"gopkg.in/couchbase/gocbcore.v6"
 )
 
 // Transcoder provides an interface for transforming Go values to and