refactor(examples): use local modules

alebabai · Feb 13, 2024 · 5afbd45 · 5afbd45
1 parent 50aa90b
commit 5afbd45
Show file tree

Hide file tree

Showing 40 changed files with 243 additions and 165 deletions.
diff --git a/examples/README.md → _examples/README.md b/examples/README.md → _examples/README.md
diff --git a/examples/common/consumer/endpoints.go → _examples/common/consumer/endpoints.go b/examples/common/consumer/endpoints.go → _examples/common/consumer/endpoints.go
diff --git a/examples/common/consumer/request_response.go → ...mples/common/consumer/request_response.go b/examples/common/consumer/request_response.go → ...mples/common/consumer/request_response.go
diff --git a/examples/common/consumer/service.go → _examples/common/consumer/service.go b/examples/common/consumer/service.go → _examples/common/consumer/service.go
diff --git a/examples/common/consumer/storage.go → _examples/common/consumer/storage.go b/examples/common/consumer/storage.go → _examples/common/consumer/storage.go
diff --git a/examples/common/consumer/transport_http.go → _examples/common/consumer/transport_http.go b/examples/common/consumer/transport_http.go → _examples/common/consumer/transport_http.go
diff --git a/examples/common/consumer/transport_kafka.go → _examples/common/consumer/transport_kafka.go b/examples/common/consumer/transport_kafka.go → _examples/common/consumer/transport_kafka.go
diff --git a/examples/common/domain/constants.go → _examples/common/domain/constants.go b/examples/common/domain/constants.go → _examples/common/domain/constants.go
diff --git a/examples/common/domain/event.go → _examples/common/domain/event.go b/examples/common/domain/event.go → _examples/common/domain/event.go
diff --git a/_examples/common/go.mod b/_examples/common/go.mod
@@ -0,0 +1,13 @@
+module github.com/alebabai/go-kit-kafka/examples/common
+
+go 1.16
+
+require (
+	github.com/alebabai/go-kit-kafka v0.0.0
+	github.com/go-kit/kit v0.13.0
+	github.com/go-kit/log v0.2.1
+	github.com/google/uuid v1.2.0
+	github.com/gorilla/mux v1.8.0
+)
+
+replace github.com/alebabai/go-kit-kafka => ../../
diff --git a/examples/common/go.sum → _examples/common/go.sum b/examples/common/go.sum → _examples/common/go.sum
diff --git a/examples/common/producer/endpoints.go → _examples/common/producer/endpoints.go b/examples/common/producer/endpoints.go → _examples/common/producer/endpoints.go
diff --git a/examples/common/producer/generator.go → _examples/common/producer/generator.go b/examples/common/producer/generator.go → _examples/common/producer/generator.go
diff --git a/examples/common/producer/middleware.go → _examples/common/producer/middleware.go b/examples/common/producer/middleware.go → _examples/common/producer/middleware.go
diff --git a/examples/common/producer/request_response.go → ...mples/common/producer/request_response.go b/examples/common/producer/request_response.go → ...mples/common/producer/request_response.go
diff --git a/examples/common/producer/service.go → _examples/common/producer/service.go b/examples/common/producer/service.go → _examples/common/producer/service.go
diff --git a/examples/common/producer/transport_http.go → _examples/common/producer/transport_http.go b/examples/common/producer/transport_http.go → _examples/common/producer/transport_http.go
diff --git a/examples/common/producer/transport_kafka.go → _examples/common/producer/transport_kafka.go b/examples/common/producer/transport_kafka.go → _examples/common/producer/transport_kafka.go
diff --git a/examples/confluent/cmd/consumer/main.go → _examples/confluent/cmd/consumer/main.go b/examples/confluent/cmd/consumer/main.go → _examples/confluent/cmd/consumer/main.go
@@ -131,7 +131,7 @@ func main() {
 	var httpServer *http.Server
 	{
 		httpServer = &http.Server{
-			Addr:    ":8080",
+			Addr:    ":8081",
 			Handler: consumer.NewHTTPHandler(endpoints),
 		}
 

diff --git a/examples/confluent/cmd/producer/main.go → _examples/confluent/cmd/producer/main.go b/examples/confluent/cmd/producer/main.go → _examples/confluent/cmd/producer/main.go
diff --git a/examples/confluent/compose.yml → _examples/confluent/compose.yml b/examples/confluent/compose.yml → _examples/confluent/compose.yml
@@ -34,10 +34,9 @@ services:
     environment:
       BROKER_ADDR: kafka:9092
     volumes:
-      - .:/app
-      - $GOPATH/pkg/mod:/go/pkg/mod
+      - ../..:/app
     working_dir: /app
-    command: sh -c "go mod tidy && go run ./cmd/producer"
+    command: sh -c "cd ./_examples/confluent && go mod download && go run ./cmd/producer"
     ports:
       - 8080:8080
 
@@ -49,9 +48,8 @@ services:
     environment:
       BROKER_ADDR: kafka:9092
     volumes:
-      - .:/app
-      - $GOPATH/pkg/mod:/go/pkg/mod
+      - ../..:/app
     working_dir: /app
-    command: sh -c "go mod tidy && go run ./cmd/consumer"
+    command: sh -c "cd ./_examples/confluent && go mod download && go run ./cmd/consumer"
     ports:
       - 8081:8081
diff --git a/_examples/confluent/go.mod b/_examples/confluent/go.mod
@@ -0,0 +1,15 @@
+module github.com/alebabai/go-kit-kafka/examples/confluent
+
+go 1.16
+
+require (
+	github.com/alebabai/go-kit-kafka v0.0.0
+	github.com/alebabai/go-kit-kafka/examples/common v0.0.0
+	github.com/confluentinc/confluent-kafka-go v1.8.2
+	github.com/go-kit/kit v0.13.0
+	github.com/go-kit/log v0.2.1
+)
+
+replace github.com/alebabai/go-kit-kafka => ../..
+
+replace github.com/alebabai/go-kit-kafka/examples/common => ../common
diff --git a/examples/confluent/go.sum → _examples/confluent/go.sum b/examples/confluent/go.sum → _examples/confluent/go.sum
diff --git a/...nt/pkg/consumer/kafka/adapter/listener.go → ...nt/pkg/consumer/kafka/adapter/listener.go b/...nt/pkg/consumer/kafka/adapter/listener.go → ...nt/pkg/consumer/kafka/adapter/listener.go
diff --git a/...ent/pkg/consumer/kafka/adapter/message.go → ...ent/pkg/consumer/kafka/adapter/message.go b/...ent/pkg/consumer/kafka/adapter/message.go → ...ent/pkg/consumer/kafka/adapter/message.go
diff --git a/...ent/pkg/producer/kafka/adapter/message.go → ...ent/pkg/producer/kafka/adapter/message.go b/...ent/pkg/producer/kafka/adapter/message.go → ...ent/pkg/producer/kafka/adapter/message.go
diff --git a/...nt/pkg/producer/kafka/adapter/producer.go → ...nt/pkg/producer/kafka/adapter/producer.go b/...nt/pkg/producer/kafka/adapter/producer.go → ...nt/pkg/producer/kafka/adapter/producer.go
diff --git a/examples/sarama/cmd/consumer/main.go → _examples/sarama/cmd/consumer/main.go b/examples/sarama/cmd/consumer/main.go → _examples/sarama/cmd/consumer/main.go
@@ -140,7 +140,7 @@ func main() {
 	var httpServer *http.Server
 	{
 		httpServer = &http.Server{
-			Addr:    ":8080",
+			Addr:    ":8081",
 			Handler: consumer.NewHTTPHandler(endpoints),
 		}
 

diff --git a/examples/sarama/cmd/producer/main.go → _examples/sarama/cmd/producer/main.go b/examples/sarama/cmd/producer/main.go → _examples/sarama/cmd/producer/main.go
diff --git a/examples/sarama/compose.yml → _examples/sarama/compose.yml b/examples/sarama/compose.yml → _examples/sarama/compose.yml
@@ -34,10 +34,9 @@ services:
     environment:
       BROKER_ADDR: kafka:9092
     volumes:
-      - .:/app
-      - $GOPATH/pkg/mod:/go/pkg/mod
+      - ../..:/app
     working_dir: /app
-    command: sh -c "go mod tidy && go run ./cmd/producer"
+    command: sh -c "cd ./_examples/sarama && go mod download && go run ./cmd/producer"
     ports:
       - 8080:8080
 
@@ -49,9 +48,8 @@ services:
     environment:
       BROKER_ADDR: kafka:9092
     volumes:
-      - .:/app
-      - $GOPATH/pkg/mod:/go/pkg/mod
+      - ../..:/app
     working_dir: /app
-    command: sh -c "go mod tidy && go run ./cmd/consumer"
+    command: sh -c "cd ./_examples/sarama && go mod download && go run ./cmd/consumer"
     ports:
       - 8081:8081
diff --git a/_examples/sarama/go.mod b/_examples/sarama/go.mod
@@ -0,0 +1,15 @@
+module github.com/alebabai/go-kit-kafka/examples/sarama
+
+go 1.16
+
+require (
+	github.com/Shopify/sarama v1.32.0
+	github.com/alebabai/go-kit-kafka v0.0.0
+	github.com/alebabai/go-kit-kafka/examples/common v0.0.0
+	github.com/go-kit/kit v0.13.0
+	github.com/go-kit/log v0.2.1
+)
+
+replace github.com/alebabai/go-kit-kafka => ../..
+
+replace github.com/alebabai/go-kit-kafka/examples/common => ../common
diff --git a/examples/sarama/go.sum → _examples/sarama/go.sum b/examples/sarama/go.sum → _examples/sarama/go.sum
diff --git a/...r/kafka/adapter/consumer_group_handler.go → ...r/kafka/adapter/consumer_group_handler.go b/...r/kafka/adapter/consumer_group_handler.go → ...r/kafka/adapter/consumer_group_handler.go
diff --git a/...ma/pkg/consumer/kafka/adapter/listener.go → ...ma/pkg/consumer/kafka/adapter/listener.go b/...ma/pkg/consumer/kafka/adapter/listener.go → ...ma/pkg/consumer/kafka/adapter/listener.go
diff --git a/...ama/pkg/consumer/kafka/adapter/message.go → ...ama/pkg/consumer/kafka/adapter/message.go b/...ama/pkg/consumer/kafka/adapter/message.go → ...ama/pkg/consumer/kafka/adapter/message.go
diff --git a/...ama/pkg/producer/kafka/adapter/message.go → ...ama/pkg/producer/kafka/adapter/message.go b/...ama/pkg/producer/kafka/adapter/message.go → ...ama/pkg/producer/kafka/adapter/message.go
diff --git a/...ma/pkg/producer/kafka/adapter/producer.go → ...ma/pkg/producer/kafka/adapter/producer.go b/...ma/pkg/producer/kafka/adapter/producer.go → ...ma/pkg/producer/kafka/adapter/producer.go
diff --git a/examples/common/go.mod b/examples/common/go.mod
diff --git a/examples/confluent/go.mod b/examples/confluent/go.mod
diff --git a/examples/sarama/go.mod b/examples/sarama/go.mod