Update repo name on sources

criteo · Nov 23, 2020 · 17a2c91 · 17a2c91
1 parent 971c736
commit 17a2c91
Show file tree

Hide file tree

Showing 30 changed files with 55 additions and 55 deletions.
diff --git a/README.md b/README.md
@@ -10,7 +10,7 @@ Its modular architecture makes it easy to build powerful pipelines that fit spec
 
 A simple pipeline that takes requests from HAProxy and sends them to a test server.
 
-![simple](https://github.com/ShimmerGlass/http-mirror-pipeline/raw/master/docs/simple.png)
+![simple](https://github.com/criteo/traffic-mirroring/raw/master/docs/simple.png)
 
 `config.json` :
 
@@ -39,7 +39,7 @@ A more complex use case. In this example we use two pipelines:
 - The first one takes requests from HAProxy and sends them to a Kafka queue
 - The second one reads the message from Kafka, and both writes them to disk for storage and sends them to a test server
 
-![kafka](https://github.com/ShimmerGlass/http-mirror-pipeline/raw/master/docs/kafka.png)
+![kafka](https://github.com/criteo/traffic-mirroring/raw/master/docs/kafka.png)
 
 ## Modules
 

diff --git a/go.mod b/go.mod
@@ -1,4 +1,4 @@
-module github.com/shimmerglass/http-mirror-pipeline
+module github.com/criteo/traffic-mirroring
 
 go 1.15
 

diff --git a/main.go b/main.go
@@ -4,11 +4,11 @@ import (
 	"flag"
 	"os"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/config"
-	_ "github.com/shimmerglass/http-mirror-pipeline/mirror/modules/control"
-	_ "github.com/shimmerglass/http-mirror-pipeline/mirror/modules/sink"
-	_ "github.com/shimmerglass/http-mirror-pipeline/mirror/modules/source"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/server"
+	"github.com/criteo/traffic-mirroring/mirror/config"
+	_ "github.com/criteo/traffic-mirroring/mirror/modules/control"
+	_ "github.com/criteo/traffic-mirroring/mirror/modules/sink"
+	_ "github.com/criteo/traffic-mirroring/mirror/modules/source"
+	"github.com/criteo/traffic-mirroring/mirror/server"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/mirror/config/config.go b/mirror/config/config.go
@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"io"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 type pipeline struct {

diff --git a/mirror/config/module.go b/mirror/config/module.go
@@ -4,8 +4,8 @@ import (
 	"encoding/json"
 	"fmt"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 var moduleIndex = map[string]int{}

diff --git a/mirror/expr/env.go b/mirror/expr/env.go
@@ -6,7 +6,7 @@ import (
 	"github.com/google/cel-go/common/types"
 	"github.com/google/cel-go/common/types/ref"
 	"github.com/google/cel-go/interpreter/functions"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1"
 )
 

diff --git a/mirror/expr/expr.go b/mirror/expr/expr.go
@@ -6,7 +6,7 @@ import (
 
 	"github.com/google/cel-go/cel"
 	"github.com/google/cel-go/checker/decls"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 )
 
 type Expr interface {

diff --git a/mirror/expr/expr_test.go b/mirror/expr/expr_test.go
@@ -3,7 +3,7 @@ package expr
 import (
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/require"
 )
 

diff --git a/mirror/expr/json_test.go b/mirror/expr/json_test.go
@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/require"
 )
 

diff --git a/mirror/expr/type.go b/mirror/expr/type.go
@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 	"fmt"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 )
 
 type Type string

diff --git a/mirror/graph/graph.go b/mirror/graph/graph.go
@@ -7,7 +7,7 @@ import (
 	"strings"
 
 	"github.com/emicklei/dot"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 )
 
 func FromModule(m mirror.Module) *dot.Graph {

diff --git a/mirror/modules/control/decouple.go b/mirror/modules/control/decouple.go
@@ -7,8 +7,8 @@ import (
 
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/mirror/modules/control/fanout.go b/mirror/modules/control/fanout.go
@@ -3,9 +3,9 @@ package control
 import (
 	"sync/atomic"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/config"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/config"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 const (

diff --git a/mirror/modules/control/fanout_test.go b/mirror/modules/control/fanout_test.go
@@ -3,7 +3,7 @@ package control
 import (
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/require"
 )
 

diff --git a/mirror/modules/control/identity.go b/mirror/modules/control/identity.go
@@ -1,8 +1,8 @@
 package control
 
 import (
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 const (

diff --git a/mirror/modules/control/rate_limit.go b/mirror/modules/control/rate_limit.go
@@ -6,9 +6,9 @@ import (
 	"log"
 	"time"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/expr"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/expr"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 const (

diff --git a/mirror/modules/control/seq.go b/mirror/modules/control/seq.go
@@ -1,9 +1,9 @@
 package control
 
 import (
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/config"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/config"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 const (

diff --git a/mirror/modules/control/split_by.go b/mirror/modules/control/split_by.go
@@ -7,10 +7,10 @@ import (
 	"sync"
 	"time"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/config"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/expr"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/config"
+	"github.com/criteo/traffic-mirroring/mirror/expr"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/mirror/modules/control/virtual.go b/mirror/modules/control/virtual.go
@@ -1,7 +1,7 @@
 package control
 
 import (
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 )
 
 type Virtual struct {

diff --git a/mirror/modules/sink/file.go b/mirror/modules/sink/file.go
@@ -11,9 +11,9 @@ import (
 	"github.com/gogo/protobuf/proto"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/expr"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/expr"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/mirror/modules/sink/file_test.go b/mirror/modules/sink/file_test.go
@@ -7,7 +7,7 @@ import (
 	"os"
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/require"
 )
 

diff --git a/mirror/modules/sink/http.go b/mirror/modules/sink/http.go
@@ -14,8 +14,8 @@ import (
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
 	"github.com/prometheus/common/log"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 )
 
 const (

diff --git a/mirror/modules/sink/sink_http_bench_test.go b/mirror/modules/sink/sink_http_bench_test.go
@@ -5,7 +5,7 @@ import (
 	"net/http/httptest"
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/require"
 )
 

diff --git a/mirror/modules/sink/sink_http_test.go b/mirror/modules/sink/sink_http_test.go
@@ -5,7 +5,7 @@ import (
 	"net/http/httptest"
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )

diff --git a/mirror/modules/source/haproxy_spoe.go b/mirror/modules/source/haproxy_spoe.go
@@ -8,8 +8,8 @@ import (
 	"strings"
 
 	spoe "github.com/criteo/haproxy-spoe-go"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/mirror/modules/source/haproxy_spoe_test.go b/mirror/modules/source/haproxy_spoe_test.go
@@ -6,7 +6,7 @@ import (
 	"os"
 	"testing"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 	"github.com/stretchr/testify/require"
 )
 

diff --git a/mirror/modules/source/pcap.go b/mirror/modules/source/pcap.go
@@ -14,8 +14,8 @@ import (
 	"github.com/golang/protobuf/ptypes"
 	"github.com/google/gopacket"
 	"github.com/google/gopacket/pcap"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/registry"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/registry"
 	log "github.com/sirupsen/logrus"
 )
 

diff --git a/mirror/registry/global.go b/mirror/registry/global.go
@@ -1,6 +1,6 @@
 package registry
 
-import "github.com/shimmerglass/http-mirror-pipeline/mirror"
+import "github.com/criteo/traffic-mirroring/mirror"
 
 var DefaultRegistry = New()
 

diff --git a/mirror/registry/registry.go b/mirror/registry/registry.go
@@ -3,7 +3,7 @@ package registry
 import (
 	"fmt"
 
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
+	"github.com/criteo/traffic-mirroring/mirror"
 )
 
 type FactoryFunc func(ctx *mirror.ModuleContext, cfg []byte) (mirror.Module, error)

diff --git a/mirror/server/server.go b/mirror/server/server.go
@@ -6,9 +6,9 @@ import (
 
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	"github.com/rakyll/statik/fs"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror"
-	"github.com/shimmerglass/http-mirror-pipeline/mirror/graph"
-	_ "github.com/shimmerglass/http-mirror-pipeline/mirror/server/statik"
+	"github.com/criteo/traffic-mirroring/mirror"
+	"github.com/criteo/traffic-mirroring/mirror/graph"
+	_ "github.com/criteo/traffic-mirroring/mirror/server/statik"
 	log "github.com/sirupsen/logrus"
 )