From ee5ac7ed17a300c8f70b0999838ab196dfc8e203 Mon Sep 17 00:00:00 2001 From: Nishchal Gautam Date: Mon, 12 Feb 2024 15:07:07 +0700 Subject: [PATCH] feat: add an encoding package --- v2/kp_example_test.go | 2 +- v2/middlewares/consumer/consumer_test.go | 2 +- v2/producer/producer.go | 2 +- v2/producer/producer_test.go | 2 +- v2/{internal => }/serialization/benchmark_test.go | 2 +- v2/{internal => }/serialization/decoder.go | 0 v2/{internal => }/serialization/encoder.go | 0 v2/{internal => }/serialization/serialization_test.go | 2 +- 8 files changed, 6 insertions(+), 6 deletions(-) rename v2/{internal => }/serialization/benchmark_test.go (95%) rename v2/{internal => }/serialization/decoder.go (100%) rename v2/{internal => }/serialization/encoder.go (100%) rename v2/{internal => }/serialization/serialization_test.go (97%) diff --git a/v2/kp_example_test.go b/v2/kp_example_test.go index a8dc98a..0884652 100644 --- a/v2/kp_example_test.go +++ b/v2/kp_example_test.go @@ -11,12 +11,12 @@ import ( v2 "github.com/honestbank/kp/v2" "github.com/honestbank/kp/v2/config" consumer2 "github.com/honestbank/kp/v2/consumer" - "github.com/honestbank/kp/v2/internal/serialization" "github.com/honestbank/kp/v2/middlewares/consumer" "github.com/honestbank/kp/v2/middlewares/deadletter" "github.com/honestbank/kp/v2/middlewares/retry" "github.com/honestbank/kp/v2/middlewares/retry_count" "github.com/honestbank/kp/v2/producer" + "github.com/honestbank/kp/v2/serialization" ) type UserLoggedInEvent struct { diff --git a/v2/middlewares/consumer/consumer_test.go b/v2/middlewares/consumer/consumer_test.go index 10c83b8..cea0ff9 100644 --- a/v2/middlewares/consumer/consumer_test.go +++ b/v2/middlewares/consumer/consumer_test.go @@ -8,8 +8,8 @@ import ( "github.com/confluentinc/confluent-kafka-go/v2/kafka" "github.com/stretchr/testify/assert" - "github.com/honestbank/kp/v2/internal/serialization" "github.com/honestbank/kp/v2/middlewares/consumer" + "github.com/honestbank/kp/v2/serialization" ) type mockConsumer struct { diff --git a/v2/producer/producer.go b/v2/producer/producer.go index 56081da..1c02ab3 100644 --- a/v2/producer/producer.go +++ b/v2/producer/producer.go @@ -7,8 +7,8 @@ import ( "github.com/honestbank/kp/v2/config" "github.com/honestbank/kp/v2/internal/schemaregistry" - "github.com/honestbank/kp/v2/internal/serialization" "github.com/honestbank/kp/v2/internal/tracing" + "github.com/honestbank/kp/v2/serialization" ) type producer[BodyType any] struct { diff --git a/v2/producer/producer_test.go b/v2/producer/producer_test.go index 03c227b..8f14c2c 100644 --- a/v2/producer/producer_test.go +++ b/v2/producer/producer_test.go @@ -15,8 +15,8 @@ import ( "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" "github.com/stretchr/testify/assert" - "github.com/honestbank/kp/v2/internal/serialization" "github.com/honestbank/kp/v2/producer" + "github.com/honestbank/kp/v2/serialization" ) type MyMessage struct { diff --git a/v2/internal/serialization/benchmark_test.go b/v2/serialization/benchmark_test.go similarity index 95% rename from v2/internal/serialization/benchmark_test.go rename to v2/serialization/benchmark_test.go index e7f16d7..c3269cc 100644 --- a/v2/internal/serialization/benchmark_test.go +++ b/v2/serialization/benchmark_test.go @@ -11,7 +11,7 @@ import ( "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" "github.com/stretchr/testify/assert" - "github.com/honestbank/kp/v2/internal/serialization" + "github.com/honestbank/kp/v2/serialization" ) func BenchmarkEncode(b *testing.B) { diff --git a/v2/internal/serialization/decoder.go b/v2/serialization/decoder.go similarity index 100% rename from v2/internal/serialization/decoder.go rename to v2/serialization/decoder.go diff --git a/v2/internal/serialization/encoder.go b/v2/serialization/encoder.go similarity index 100% rename from v2/internal/serialization/encoder.go rename to v2/serialization/encoder.go diff --git a/v2/internal/serialization/serialization_test.go b/v2/serialization/serialization_test.go similarity index 97% rename from v2/internal/serialization/serialization_test.go rename to v2/serialization/serialization_test.go index e71be49..390ab29 100644 --- a/v2/internal/serialization/serialization_test.go +++ b/v2/serialization/serialization_test.go @@ -12,7 +12,7 @@ import ( "github.com/confluentinc/confluent-kafka-go/v2/schemaregistry/serde/avro" "github.com/stretchr/testify/assert" - "github.com/honestbank/kp/v2/internal/serialization" + "github.com/honestbank/kp/v2/serialization" ) type BenchmarkMessage struct {