Fixed some import issues resulting from syncing the private repo

Author: Fletcher Haynes

api.go

@@ -23,7 +23,6 @@ import (
 	"time"
 
 	"github.com/featurebasedb/featurebase/v3/disco"
-	"github.com/featurebasedb/featurebase/v3/ingest"
 	"github.com/featurebasedb/featurebase/v3/rbf"
 
 	//"github.com/featurebasedb/featurebase/v3/pg"

batch/batch.go

@@ -1,6 +1,5 @@
-// Copyright 2022 Molecula Corp. (DBA FeatureBase).
-// SPDX-License-Identifier: Apache-2.0
-package client
+// Package batch provides tooling to prepare batches of records for ingest.
+package batch
 
 import (
 	"bytes"
@@ -11,8 +10,9 @@ import (
 	"time"
 
 	featurebase "github.com/featurebasedb/featurebase/v3"
-	"github.com/featurebasedb/featurebase/v3/client/egpool"
+	"github.com/featurebasedb/featurebase/v3/batch/egpool"
 	"github.com/featurebasedb/featurebase/v3/logger"
+	"github.com/featurebasedb/featurebase/v3/pql"
 	"github.com/featurebasedb/featurebase/v3/roaring"
 	"github.com/pkg/errors"
 )
@@ -716,7 +716,7 @@ func (b *Batch) Add(rec Row) error {
 	return nil
 }
 
-// ErrBatchNowFull — similar to io.EOF — is a marker error to notify the user of
+// ErrBatchNowFull — similar to io.EOF — is a marker error to notify the user of
 // a batch that it is time to call Import.
 var ErrBatchNowFull = errors.New("batch is now full - you cannot add any more records (though the one you just added was accepted)")
 

batch/batch_test.go

@@ -10,9 +10,9 @@ import (
 	"testing"
 	"time"
 
-	featurebase "github.com/molecula/featurebase/v3"
-	"github.com/molecula/featurebase/v3/client"
-	"github.com/molecula/featurebase/v3/pql"
+	featurebase "github.com/featurebasedb/featurebase/v3"
+	"github.com/featurebasedb/featurebase/v3/client"
+	"github.com/featurebasedb/featurebase/v3/pql"
 	"github.com/stretchr/testify/assert"
 
 	"github.com/pkg/errors"

batch/convert.go

@@ -3,8 +3,8 @@ package batch
 import (
 	"time"
 
-	featurebase "github.com/molecula/featurebase/v3"
-	"github.com/molecula/featurebase/v3/errors"
+	featurebase "github.com/featurebasedb/featurebase/v3"
+	"github.com/featurebasedb/featurebase/v3/errors"
 )
 
 var (

batch/egpool/egpool_test.go

@@ -6,7 +6,7 @@ import (
 	"errors"
 	"testing"
 
-	"github.com/featurebasedb/featurebase/v3/client/egpool"
+	"github.com/featurebasedb/featurebase/v3/batch/egpool"
 )
 
 func TestEGPool(t *testing.T) {

batch/importer.go

@@ -5,10 +5,10 @@ import (
 	"time"
 
 	"github.com/golang/protobuf/proto" //nolint:staticcheck
-	featurebase "github.com/molecula/featurebase/v3"
-	featurebaseproto "github.com/molecula/featurebase/v3/encoding/proto"
-	"github.com/molecula/featurebase/v3/pb"
-	"github.com/molecula/featurebase/v3/roaring"
+	featurebase "github.com/featurebasedb/featurebase/v3"
+	featurebaseproto "github.com/featurebasedb/featurebase/v3/encoding/proto"
+	"github.com/featurebasedb/featurebase/v3/pb"
+	"github.com/featurebasedb/featurebase/v3/roaring"
 	"github.com/pkg/errors"
 )
 

batch/metrics.go

@@ -1,6 +1,6 @@
 // Copyright 2022 Molecula Corp. (DBA FeatureBase).
 // SPDX-License-Identifier: Apache-2.0
-package client
+package batch
 
 const (
 	// MetricBatchImportDurationSeconds records the full time of the

client/api.go

@@ -3,8 +3,8 @@ package client
 import (
 	"context"
 
-	featurebase "github.com/molecula/featurebase/v3"
-	"github.com/molecula/featurebase/v3/errors"
+	featurebase "github.com/featurebasedb/featurebase/v3"
+	"github.com/featurebasedb/featurebase/v3/errors"
 )
 
 var _ featurebase.SchemaAPI = &schemaAPI{}

client/importer.go

@@ -4,8 +4,8 @@ import (
 	"context"
 	"time"
 
-	featurebase "github.com/molecula/featurebase/v3"
-	"github.com/molecula/featurebase/v3/roaring"
+	featurebase "github.com/featurebasedb/featurebase/v3"
+	"github.com/featurebasedb/featurebase/v3/roaring"
 	"github.com/pkg/errors"
 )
 

cluster.go

@@ -9,7 +9,6 @@ import (
 	"time"
 
 	"github.com/featurebasedb/featurebase/v3/disco"
-	"github.com/featurebasedb/featurebase/v3/ingest"
 	"github.com/featurebasedb/featurebase/v3/logger"
 	"github.com/featurebasedb/featurebase/v3/roaring"
 	"github.com/pkg/errors"