Skip to content

Commit

Permalink
fix package names
Browse files Browse the repository at this point in the history
  • Loading branch information
CanerPatir committed Dec 30, 2022
1 parent 7006bb0 commit 60f3214
Show file tree
Hide file tree
Showing 8 changed files with 19 additions and 17 deletions.
3 changes: 2 additions & 1 deletion config/config.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,10 @@
package config

import (
"godcpkafkaconnector/logger"
"time"

"github.com/Trendyol/go-kafka-connect-couchbase/logger"

"github.com/gookit/config/v2"
"github.com/gookit/config/v2/yamlv3"
)
Expand Down
10 changes: 5 additions & 5 deletions connector.go
Original file line number Diff line number Diff line change
@@ -1,13 +1,13 @@
package godcpkafkaconnector
package gokafkaconnectcouchbase

import (
"context"
"godcpkafkaconnector/config"
"godcpkafkaconnector/couchbase"
kafka "godcpkafkaconnector/kafka/producer"
"godcpkafkaconnector/logger"

godcpclient "github.com/Trendyol/go-dcp-client"
"github.com/Trendyol/go-kafka-connect-couchbase/config"
"github.com/Trendyol/go-kafka-connect-couchbase/couchbase"
kafka "github.com/Trendyol/go-kafka-connect-couchbase/kafka/producer"
"github.com/Trendyol/go-kafka-connect-couchbase/logger"
)

type Connector interface {
Expand Down
5 changes: 2 additions & 3 deletions example/main.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,8 @@
package main

import (
"godcpkafkaconnector"
"godcpkafkaconnector/couchbase"
"godcpkafkaconnector/kafka"
"github.com/Trendyol/go-kafka-connect-couchbase/couchbase"
"github.com/Trendyol/go-kafka-connect-couchbase/kafka"
)

func mapper(event *couchbase.Event) *kafka.Message {
Expand Down
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module godcpkafkaconnector
module github.com/Trendyol/go-kafka-connect-couchbase

go 1.19

Expand Down
2 changes: 1 addition & 1 deletion json_config.go
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package godcpkafkaconnector
package gokafkaconnectcouchbase

import "github.com/json-iterator/go"

Expand Down
5 changes: 3 additions & 2 deletions kafka/producer/producer.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,13 @@ package kafka

import (
"context"
"godcpkafkaconnector/config"
"godcpkafkaconnector/logger"
"math"
"strings"
"time"

"github.com/Trendyol/go-kafka-connect-couchbase/config"
"github.com/Trendyol/go-kafka-connect-couchbase/logger"

"github.com/segmentio/kafka-go"
)

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,11 @@ package kafka

import (
"context"
"godcpkafkaconnector/logger"
"sync"
"time"

"github.com/Trendyol/go-kafka-connect-couchbase/logger"

"github.com/segmentio/kafka-go"
)

Expand Down
6 changes: 3 additions & 3 deletions mapper.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package godcpkafkaconnector
package gokafkaconnectcouchbase

import (
"godcpkafkaconnector/couchbase"
"godcpkafkaconnector/kafka"
"github.com/Trendyol/go-kafka-connect-couchbase/couchbase"
"github.com/Trendyol/go-kafka-connect-couchbase/kafka"
)

type Mapper func(event *couchbase.Event) *kafka.Message

0 comments on commit 60f3214

Please sign in to comment.