diff --git a/cayley.go b/cayley.go index eae0ff9..41b3244 100644 --- a/cayley.go +++ b/cayley.go @@ -33,6 +33,7 @@ import ( "github.com/google/cayley/db" "github.com/google/cayley/graph" "github.com/google/cayley/http" + "github.com/google/cayley/internal" "github.com/google/cayley/quad" "github.com/google/cayley/quad/cquads" "github.com/google/cayley/quad/nquads" @@ -286,7 +287,7 @@ func decompressAndLoad(qw graph.QuadWriter, cfg *config.Config, path, typ string r = res.Body } - r, err = quad.Decompressor(r) + r, err = internal.Decompressor(r) if err != nil { if err == io.EOF { return nil diff --git a/cayley_test.go b/cayley_test.go index 18cae90..f488a3c 100644 --- a/cayley_test.go +++ b/cayley_test.go @@ -32,6 +32,7 @@ import ( "github.com/google/cayley/config" "github.com/google/cayley/db" "github.com/google/cayley/graph" + "github.com/google/cayley/internal" "github.com/google/cayley/quad" "github.com/google/cayley/query/gremlin" ) @@ -705,7 +706,7 @@ var testDecompressor = []struct { func TestDecompressor(t *testing.T) { for _, test := range testDecompressor { - r, err := decompressor(test.input) + r, err := internal.Decompressor(test.input) if err != test.err { t.Fatalf("Unexpected error for %s, got:%v expect:%v", test.message, err, test.err) } diff --git a/http/write.go b/http/write.go index 0c71f13..de2c24b 100644 --- a/http/write.go +++ b/http/write.go @@ -25,6 +25,7 @@ import ( "github.com/barakmich/glog" "github.com/julienschmidt/httprouter" + "github.com/google/cayley/internal" "github.com/google/cayley/quad" "github.com/google/cayley/quad/cquads" ) @@ -82,7 +83,7 @@ func (api *API) ServeV1WriteNQuad(w http.ResponseWriter, r *http.Request, params blockSize = int64(api.config.LoadSize) } - quadReader, err := quad.Decompressor(formFile) + quadReader, err := internal.Decompressor(formFile) // TODO(kortschak) Make this configurable from the web UI. dec := cquads.NewDecoder(quadReader) diff --git a/quad/decompressor.go b/internal/decompressor.go similarity index 98% rename from quad/decompressor.go rename to internal/decompressor.go index 35ee714..1d3ab00 100644 --- a/quad/decompressor.go +++ b/internal/decompressor.go @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -package quad +package internal import ( "bufio"