Move config consumer folder

Signed-off-by: Davit Yeghshatyan <davo@uber.com>
jaegertracing · Jul 26, 2018 · 0f74051 · 0f74051
1 parent 9eda653
commit 0f74051
Show file tree

Hide file tree

Showing 6 changed files with 3 additions and 40 deletions.
diff --git a/cmd/ingester/app/consumer/consumer.go b/cmd/ingester/app/consumer/consumer.go
@@ -23,7 +23,7 @@ import (
 	"go.uber.org/zap"
 
 	"github.com/jaegertracing/jaeger/cmd/ingester/app/processor"
-	"github.com/jaegertracing/jaeger/pkg/kafka/config/consumer"
+	"github.com/jaegertracing/jaeger/pkg/kafka/consumer"
 )
 
 // Params are the parameters of a Consumer

diff --git a/cmd/ingester/app/consumer/processor_factory.go b/cmd/ingester/app/consumer/processor_factory.go
@@ -23,7 +23,7 @@ import (
 	"github.com/jaegertracing/jaeger/cmd/ingester/app/consumer/offset"
 	"github.com/jaegertracing/jaeger/cmd/ingester/app/processor"
 	"github.com/jaegertracing/jaeger/cmd/ingester/app/processor/decorator"
-	"github.com/jaegertracing/jaeger/pkg/kafka/config/consumer"
+	"github.com/jaegertracing/jaeger/pkg/kafka/consumer"
 )
 
 // FactoryParams are the parameters of a ProcessorFactory

diff --git a/pkg/kafka/config/producer/.nocover b/pkg/kafka/config/producer/.nocover
diff --git a/pkg/kafka/config/producer/config.go b/pkg/kafka/config/producer/config.go
diff --git a/pkg/kafka/config/consumer/config.go → pkg/kafka/consumer/config.go b/pkg/kafka/config/consumer/config.go → pkg/kafka/consumer/config.go
diff --git a/plugin/storage/kafka/factory_test.go b/plugin/storage/kafka/factory_test.go
@@ -33,7 +33,7 @@ import (
 var _ storage.Factory = new(Factory)
 
 type mockProducerBuilder struct {
-	kafkaConfig.ProducerConfiguration
+	kafkaConfig.Configuration
 	err error
 	t   *testing.T
 }