make sure PDK can use latest go-pilosa options

Author: jaffee

go.mod

@@ -23,7 +23,7 @@ require (
 	github.com/onsi/ginkgo v1.7.0 // indirect
 	github.com/onsi/gomega v1.4.3 // indirect
 	github.com/pierrec/lz4 v0.0.0-20181005164709-635575b42742 // indirect
-	github.com/pilosa/go-pilosa v1.3.1-0.20190503193736-ad53edf56c18
+	github.com/pilosa/go-pilosa v1.3.1-0.20190612142550-e616c1393660
 	github.com/pilosa/pilosa v1.2.1-0.20190410162749-b973f8c96356
 	github.com/pkg/errors v0.8.1
 	github.com/rcrowley/go-metrics v0.0.0-20181016184325-3113b8401b8a // indirect

go.sum

@@ -130,6 +130,8 @@ github.com/pilosa/go-pilosa v1.2.1-0.20190416174400-de264d55e76f h1:faokUYJ6BwIK
 github.com/pilosa/go-pilosa v1.2.1-0.20190416174400-de264d55e76f/go.mod h1:x18hYx4nI0bHzQSFyanUEB7pmja1HMAZAb3PPhUpOZc=
 github.com/pilosa/go-pilosa v1.3.1-0.20190503193736-ad53edf56c18 h1:uUA588w4MeX0dFxhr0rj1XazSxaSwqL3qnG2MmTZRb8=
 github.com/pilosa/go-pilosa v1.3.1-0.20190503193736-ad53edf56c18/go.mod h1:9ECbvb0EQJvjxBups5CUCzeLh8KrLgQVY9/1zSoQHQE=
+github.com/pilosa/go-pilosa v1.3.1-0.20190612142550-e616c1393660 h1:0UUfONtKBe4n1yIRLshVPNCJbtXdg/WKNLDqmCxu/uw=
+github.com/pilosa/go-pilosa v1.3.1-0.20190612142550-e616c1393660/go.mod h1:9ECbvb0EQJvjxBups5CUCzeLh8KrLgQVY9/1zSoQHQE=
 github.com/pilosa/pilosa v0.0.0-20181130171212-dfb748ec5b01 h1:gtkt282G8/+8XN0D9+934/3zpUiEtsFINjqCs+vZs04=
 github.com/pilosa/pilosa v0.0.0-20181130171212-dfb748ec5b01/go.mod h1:NgpkJkefqUKUHV7O3TqBOu89tsao3ksth2wzTNe8CPQ=
 github.com/pilosa/pilosa v0.0.0-20190104143002-8c4b1548bc4b h1:2H/+JUxL4dv0uJ4G4i+C83S1yq/+pUrHHjsF8TEY85I=

pilosa.go

@@ -222,7 +222,7 @@ func (i *Index) setupField(field *gopilosa.Field) error {
 // Example:
 // pdk.SetupPilosa(...,
 //    pdk.OptPilosaImportOptions(gopilosa.OptImportThreadCount(4)),
-//    pdkOptPilosaClientOptions(gopilosa.OptClientRetries(5), gopilosa.OptClientConnectTimeout(time.Second * 60))
+//    pdk.OptPilosaClientOptions(gopilosa.OptClientRetries(5), gopilosa.OptClientConnectTimeout(time.Second * 60))
 // )
 
 func SetupPilosa(hosts []string, indexName string, schema *gopilosa.Schema, batchsize uint, options ...PilosaOption) (Indexer, error) {

pilosa_test.go

@@ -33,6 +33,8 @@
 package pdk_test
 
 import (
+	"io/ioutil"
+	"os"
 	"testing"
 	"time"
 
@@ -55,7 +57,12 @@ func TestSetupPilosa(t *testing.T) {
 	index.Field("field3", gopilosa.OptFieldTypeInt(0, 20000))
 	index.Field("fieldtime", gopilosa.OptFieldTypeTime(gopilosa.TimeQuantumYearMonthDay))
 
-	indexer, err := pdk.SetupPilosa(hosts, index.Name(), schema, 2)
+	logfile, err := ioutil.TempFile("", "")
+	if err != nil {
+		t.Fatalf("getting temp file for import log: %v", err)
+	}
+
+	indexer, err := pdk.SetupPilosa(hosts, index.Name(), schema, 2, pdk.OptPilosaImportOptions(gopilosa.OptImportThreadCount(4)), pdk.OptPilosaClientOptions(gopilosa.ExperimentalOptClientLogImports(logfile)))
 	if err != nil {
 		t.Fatalf("SetupPilosa: %v", err)
 	}
@@ -70,6 +77,18 @@ func TestSetupPilosa(t *testing.T) {
 	if err != nil {
 		t.Fatalf("closing indexer: %v", err)
 	}
+	logfile.Close()
+	f, err := os.Open(logfile.Name())
+	if err != nil {
+		t.Fatalf("reopening log file: %v", err)
+	}
+	data, err := ioutil.ReadAll(f)
+	if err != nil {
+		t.Fatalf("reading log file: %v", err)
+	}
+	if len(data) < 100 {
+		t.Errorf("small amount of data in replay file: %s", data)
+	}
 
 	client, err := gopilosa.NewClient(hosts)
 	if err != nil {