Move consumerfanout package to internal

Signed-off-by: Bogdan Drutu <bogdandrutu@gmail.com>
open-telemetry · May 17, 2021 · 2ab6664 · 2ab6664
1 parent 2d48457
commit 2ab6664
Show file tree

Hide file tree

Showing 6 changed files with 2 additions and 2 deletions.
diff --git a/service/internal/builder/pipelines_builder.go b/service/internal/builder/pipelines_builder.go
@@ -24,7 +24,7 @@ import (
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/consumer"
 	"go.opentelemetry.io/collector/consumer/consumererror"
-	"go.opentelemetry.io/collector/consumer/fanoutconsumer"
+	"go.opentelemetry.io/collector/service/internal/fanoutconsumer"
 )
 
 // builtPipeline is a pipeline that is built based on a config.

diff --git a/service/internal/builder/receivers_builder.go b/service/internal/builder/receivers_builder.go
@@ -26,7 +26,7 @@ import (
 	"go.opentelemetry.io/collector/config"
 	"go.opentelemetry.io/collector/consumer"
 	"go.opentelemetry.io/collector/consumer/consumererror"
-	"go.opentelemetry.io/collector/consumer/fanoutconsumer"
+	"go.opentelemetry.io/collector/service/internal/fanoutconsumer"
 )
 
 var errUnusedReceiver = errors.New("receiver defined but not used by any pipeline")

diff --git a/consumer/fanoutconsumer/cloningconsumer.go → ...nternal/fanoutconsumer/cloningconsumer.go b/consumer/fanoutconsumer/cloningconsumer.go → ...nternal/fanoutconsumer/cloningconsumer.go
diff --git a/...er/fanoutconsumer/cloningconsumer_test.go → ...al/fanoutconsumer/cloningconsumer_test.go b/...er/fanoutconsumer/cloningconsumer_test.go → ...al/fanoutconsumer/cloningconsumer_test.go
diff --git a/consumer/fanoutconsumer/consumer.go → service/internal/fanoutconsumer/consumer.go b/consumer/fanoutconsumer/consumer.go → service/internal/fanoutconsumer/consumer.go
diff --git a/consumer/fanoutconsumer/consumer_test.go → .../internal/fanoutconsumer/consumer_test.go b/consumer/fanoutconsumer/consumer_test.go → .../internal/fanoutconsumer/consumer_test.go