updated import paths

cevian · cevian · commit 75137db9262f · 2013-10-14T07:36:17.000-07:00
diff --git a/cluster/era.go b/cluster/era.go
@@ -2,7 +2,7 @@ package cluster
 
 import (
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type Era interface {
diff --git a/cluster/manager.go b/cluster/manager.go
@@ -5,7 +5,7 @@ import (
 	"github.com/cloudflare/golog/logger"
 	"io/ioutil"
 	"net/http"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 	"strconv"
 	"time"
 )
diff --git a/cube/aggregate.go b/cube/aggregate.go
@@ -1,7 +1,7 @@
 package cube
 
 import (
-	"stash.cloudflare.com/go-stream/cube/pg/hll"
+	"github.com/cloudflare/go-stream/cube/pg/hll"
 )
 
 type Aggregate interface {
diff --git a/cube/dimension.go b/cube/dimension.go
@@ -1,7 +1,7 @@
 package cube
 
 import (
-	"stash.cloudflare.com/go-stream/cube/pg/hll"
+	"github.com/cloudflare/go-stream/cube/pg/hll"
 	"time"
 )
 
diff --git a/cube/operator.go b/cube/operator.go
@@ -1,7 +1,7 @@
 package cube
 
 import (
-	"stash.cloudflare.com/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream"
 	//	"reflect"
 	"time"
 )
diff --git a/cube/pg/cube.go b/cube/pg/cube.go
@@ -1,6 +1,6 @@
 package pg
 
-import "stash.cloudflare.com/go-stream/cube"
+import "github.com/cloudflare/go-stream/cube"
 import (
 	"log"
 	"reflect"
diff --git a/cube/pg/executor.go b/cube/pg/executor.go
@@ -5,8 +5,8 @@ import (
 	"github.com/cevian/pq"
 	"github.com/cloudflare/golog/logger"
 	"reflect"
-	"stash.cloudflare.com/go-stream/cube"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/cube"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type Executor struct {
diff --git a/cube/pg/operator.go b/cube/pg/operator.go
@@ -1,8 +1,8 @@
 package pg
 
-import "stash.cloudflare.com/go-stream/cube"
-import "stash.cloudflare.com/go-stream/stream"
-import "stash.cloudflare.com/go-stream/stream/mapper"
+import "github.com/cloudflare/go-stream/cube"
+import "github.com/cloudflare/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream/mapper"
 
 import (
 	"database/sql"
diff --git a/cube/pg/table.go b/cube/pg/table.go
@@ -6,7 +6,7 @@ import (
 	//"database/sql"
 	"fmt"
 	"reflect"
-	"stash.cloudflare.com/go-stream/cube"
+	"github.com/cloudflare/go-stream/cube"
 	"strings"
 	"time"
 )
diff --git a/cube/pg/table_test.go b/cube/pg/table_test.go
@@ -3,7 +3,7 @@ package pg
 import (
 	"database/sql"
 	"database/sql/driver"
-	"stash.cloudflare.com/go-stream/cube"
+	"github.com/cloudflare/go-stream/cube"
 	"fmt"
 	"log"
 	"time"
diff --git a/stream/batcher.go b/stream/batcher.go
@@ -2,7 +2,7 @@ package stream
 
 import (
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 	"time"
 )
 
diff --git a/stream/chain.go b/stream/chain.go
@@ -2,7 +2,7 @@ package stream
 
 import (
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type Chain interface {
diff --git a/stream/compress/snappy.go b/stream/compress/snappy.go
@@ -3,8 +3,8 @@ package compress
 import (
 	"code.google.com/p/snappy-go/snappy"
 	"log"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
 )
 
 func NewSnappyEncodeOp() stream.Operator {
diff --git a/stream/distributor.go b/stream/distributor.go
@@ -3,7 +3,7 @@ package stream
 import (
 	"errors"
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type DistributorChildOp interface {
diff --git a/stream/encoding/gob.go b/stream/encoding/gob.go
@@ -5,8 +5,8 @@ import (
 	"encoding/gob"
 	"io"
 	"log"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
 	//"reflect"
 )
 
diff --git a/stream/encoding/gob_test.go b/stream/encoding/gob_test.go
@@ -6,7 +6,7 @@ import (
 )
 
 import (
-	"stash.cloudflare.com/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream"
 )
 
 /*import (
@@ -17,7 +17,7 @@ import (
 
 //import "log"
 
-//import "stash.cloudflare.com/go-stream/stream/encoding"
+//import "github.com/cloudflare/go-stream/stream/encoding"
 
 func TestGob(t *testing.T) {
 
diff --git a/stream/encoding/json.go b/stream/encoding/json.go
@@ -3,9 +3,9 @@ package encoding
 import (
 	"encoding/json"
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/util/slog"
 	//"reflect"
 )
 
diff --git a/stream/encoding/protobuf.go b/stream/encoding/protobuf.go
@@ -3,8 +3,8 @@ package encoding
 import (
 	"code.google.com/p/goprotobuf/proto"
 	"log"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
 	//"reflect"
 )
 
diff --git a/stream/fanout.go b/stream/fanout.go
@@ -3,7 +3,7 @@ package stream
 import (
 	"errors"
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type fanoutChildOp interface {
diff --git a/stream/mapper/generator.go b/stream/mapper/generator.go
@@ -1,7 +1,7 @@
 package mapper
 
 import "reflect"
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 import "log"
 
 //import "encoding/json"
diff --git a/stream/mapper/operator.go b/stream/mapper/operator.go
@@ -2,7 +2,7 @@ package mapper
 
 import "runtime"
 import "sync"
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 func NewOp(proc interface{}, tn string) *Op {
 	gen := CallbackGenerator{callback: proc, typename: tn}
diff --git a/stream/mapper/orderpreserving.go b/stream/mapper/orderpreserving.go
@@ -2,7 +2,7 @@ package mapper
 
 import "runtime"
 import "sync"
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 import "log"
 
diff --git a/stream/mapper/output.go b/stream/mapper/output.go
@@ -1,6 +1,6 @@
 package mapper
 
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 type Outputer interface {
 	Out(int) chan<- stream.Object
diff --git a/stream/mapper/worker.go b/stream/mapper/worker.go
@@ -3,8 +3,8 @@ package mapper
 import (
 	"github.com/cloudflare/golog/logger"
 	"reflect"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type Worker interface {
diff --git a/stream/runner.go b/stream/runner.go
@@ -2,7 +2,7 @@ package stream
 
 import (
 	"github.com/cloudflare/golog/logger"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/util/slog"
 	"sync"
 )
 
diff --git a/stream/sink/interfacewriter.go b/stream/sink/interfacewriter.go
@@ -1,6 +1,6 @@
 package sink
 
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 type InterfaceWriter interface {
 	Write(i interface{}) error
diff --git a/stream/sink/print/print.go b/stream/sink/print/print.go
@@ -3,8 +3,8 @@ package print
 import (
 	"log"
 	"os"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/sink"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/sink"
 )
 
 type PrintSink struct {
diff --git a/stream/sink/sink.go b/stream/sink/sink.go
@@ -1,7 +1,7 @@
 package sink
 
 import (
-	"stash.cloudflare.com/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream"
 )
 
 type Sinker interface {
diff --git a/stream/sink/writer.go b/stream/sink/writer.go
@@ -4,8 +4,8 @@ import (
 	"encoding/binary"
 	"github.com/cloudflare/golog/logger"
 	"io"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/util/slog"
 	"time"
 )
 
diff --git a/stream/sink/zmq/zmq.go b/stream/sink/zmq/zmq.go
@@ -4,8 +4,8 @@ import (
 	"log"
 )
 
-import "stash.cloudflare.com/go-stream/stream/sink"
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream/sink"
+import "github.com/cloudflare/go-stream/stream"
 
 import zmqapi "github.com/pebbe/zmq3"
 
diff --git a/stream/source/interfacereader.go b/stream/source/interfacereader.go
@@ -1,6 +1,6 @@
 package source
 
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 type InterfaceReader interface {
 	ReadNext() (i interface{}, eof bool, err error)
diff --git a/stream/source/reader.go b/stream/source/reader.go
@@ -7,8 +7,8 @@ import (
 	"github.com/cloudflare/golog/logger"
 	"io"
 	"math"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/util/slog"
 )
 
 type NextReader interface {
diff --git a/stream/source/source.go b/stream/source/source.go
@@ -1,6 +1,6 @@
 package source
 
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 type Sourcer interface {
 	stream.Operator
diff --git a/stream/source/unixgram/unixgram.go b/stream/source/unixgram/unixgram.go
@@ -6,8 +6,8 @@ import (
 	"github.com/cloudflare/golog/logger"
 	"net"
 	"os"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/util/slog"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/util/slog"
 	"syscall"
 )
 
diff --git a/stream/source/zmq/zmq.go b/stream/source/zmq/zmq.go
@@ -5,7 +5,7 @@ import (
 	"time"
 )
 
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 
 import zmqapi "github.com/pebbe/zmq3"
 
diff --git a/stream/source/zmq/zmq_test.go b/stream/source/zmq/zmq_test.go
@@ -1,11 +1,11 @@
 package zmq
 
 import "testing"
-import "stash.cloudflare.com/go-stream/stream"
+import "github.com/cloudflare/go-stream/stream"
 import "fmt"
 import "sync"
 
-import sink_zmq "stash.cloudflare.com/go-stream/stream/sink/zmq"
+import sink_zmq "github.com/cloudflare/go-stream/stream/sink/zmq"
 
 func TestZmqget(t *testing.T) {
 
diff --git a/stream/test/order_test.go b/stream/test/order_test.go
@@ -6,8 +6,8 @@ import (
 )
 
 import (
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
 )
 
 func TestNoOrder(t *testing.T) {
diff --git a/stream/timing/timing.go b/stream/timing/timing.go
@@ -2,8 +2,8 @@ package timing
 
 import (
 	"log"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
 	"sync/atomic"
 	"time"
 )
diff --git a/stream/util/util.go b/stream/util/util.go
@@ -3,8 +3,8 @@ package util
 import (
 	"log"
 	"os"
-	"stash.cloudflare.com/go-stream/stream"
-	"stash.cloudflare.com/go-stream/stream/mapper"
+	"github.com/cloudflare/go-stream/stream"
+	"github.com/cloudflare/go-stream/stream/mapper"
 )
 
 func NewDropOp() *mapper.Op {
diff --git a/transport/client.go b/transport/client.go
diff --git a/transport/common.go b/transport/common.go
diff --git a/transport/reliable_test.go b/transport/reliable_test.go
diff --git a/transport/server.go b/transport/server.go
diff --git a/util/slog/slog.go b/util/slog/slog.go

Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,7 @@ package cluster`
`2`	`2`
`3`	`3`	`import (`
`4`	`4`	`"github.com/cloudflare/golog/logger"`
`5`		`- "stash.cloudflare.com/go-stream/util/slog"`
	`5`	`+ "github.com/cloudflare/go-stream/util/slog"`
`6`	`6`	`)`
`7`	`7`
`8`	`8`	`type Era interface {`
Original file line number	Diff line number	Diff line change
`@@ -5,7 +5,7 @@ import (`
`5`	`5`	`"github.com/cloudflare/golog/logger"`
`6`	`6`	`"io/ioutil"`
`7`	`7`	`"net/http"`
`8`		`- "stash.cloudflare.com/go-stream/util/slog"`
	`8`	`+ "github.com/cloudflare/go-stream/util/slog"`
`9`	`9`	`"strconv"`
`10`	`10`	`"time"`
`11`	`11`	`)`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`package cube`
`2`	`2`
`3`	`3`	`import (`
`4`		`- "stash.cloudflare.com/go-stream/cube/pg/hll"`
	`4`	`+ "github.com/cloudflare/go-stream/cube/pg/hll"`
`5`	`5`	`)`
`6`	`6`
`7`	`7`	`type Aggregate interface {`
Original file line number	Diff line number	Diff line change
`@@ -6,7 +6,7 @@ import (`
`6`	`6`	`//"database/sql"`
`7`	`7`	`"fmt"`
`8`	`8`	`"reflect"`
`9`		`- "stash.cloudflare.com/go-stream/cube"`
	`9`	`+ "github.com/cloudflare/go-stream/cube"`
`10`	`10`	`"strings"`
`11`	`11`	`"time"`
`12`	`12`	`)`