Skip to content

Commit

Permalink
perf: rename project name (#27)
Browse files Browse the repository at this point in the history
  • Loading branch information
JTrancender authored Aug 11, 2021
1 parent 83485ad commit fb4178d
Show file tree
Hide file tree
Showing 25 changed files with 63 additions and 63 deletions.
6 changes: 3 additions & 3 deletions cmd/root.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package cmd

import (
"github.com/JieTrancender/nsq_to_consumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/cmd"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_consumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/cmd"
"github.com/JieTrancender/nsq_consumer/libconsumer/cmd/instance"

"github.com/spf13/pflag"
)
Expand Down
10 changes: 5 additions & 5 deletions consumer/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@ import (
"sync"
"time"

"github.com/JieTrancender/nsq_to_consumer/internal/version"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/internal/version"
"github.com/JieTrancender/nsq_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/nsqio/go-nsq"
)

Expand Down
4 changes: 2 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
module github.com/JieTrancender/nsq_to_consumer
module github.com/JieTrancender/nsq_consumer

go 1.14

Expand All @@ -12,7 +12,7 @@ require (
github.com/pkg/errors v0.9.1
github.com/spf13/cobra v1.1.3
github.com/spf13/pflag v1.0.5
github.com/stretchr/testify v1.5.0 // indirect
github.com/stretchr/testify v1.5.0
go.etcd.io/etcd v3.3.25+incompatible
go.uber.org/zap v1.14.0
golang.org/x/sys v0.0.0-20210124154548-22da62e12c0c // indirect
Expand Down
16 changes: 8 additions & 8 deletions libconsumer/cmd/instance/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,14 @@ import (

"go.etcd.io/etcd/clientv3"

"github.com/JieTrancender/nsq_to_consumer/internal/version"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp/configure"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/publisher/pipeline"
svc "github.com/JieTrancender/nsq_to_consumer/libconsumer/service"
"github.com/JieTrancender/nsq_consumer/internal/version"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp/configure"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/publisher/pipeline"
svc "github.com/JieTrancender/nsq_consumer/libconsumer/service"
)

// Consumer provides the runnable and configurable instance of a consumer.
Expand Down
2 changes: 1 addition & 1 deletion libconsumer/cmd/instance/imports_common.go
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
package instance

import (
_ "github.com/JieTrancender/nsq_to_consumer/libconsumer/publisher/includes"
_ "github.com/JieTrancender/nsq_consumer/libconsumer/publisher/includes"
)
4 changes: 2 additions & 2 deletions libconsumer/cmd/root.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package cmd

import (
"github.com/JieTrancender/nsq_to_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/spf13/cobra"
)

Expand Down
6 changes: 3 additions & 3 deletions libconsumer/cmd/run.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@ import (
"fmt"
"os"

"github.com/JieTrancender/nsq_to_consumer/internal/version"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/internal/version"
"github.com/JieTrancender/nsq_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/spf13/cobra"
)

Expand Down
4 changes: 2 additions & 2 deletions libconsumer/cmd/version.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,8 +6,8 @@ import (

"github.com/spf13/cobra"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/common/cli"
"github.com/JieTrancender/nsq_consumer/libconsumer/cmd/instance"
"github.com/JieTrancender/nsq_consumer/libconsumer/common/cli"
)

func genVersionCmd(settings instance.Settings) *cobra.Command {
Expand Down
2 changes: 1 addition & 1 deletion libconsumer/consumer/consumer.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
package consumer

import (
"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
)

type Creator func(*ConsumerEntity, *common.Config) (Consumer, error)
Expand Down
4 changes: 2 additions & 2 deletions libconsumer/logp/configure/logging.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,8 @@ import (
"flag"
"fmt"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
)

var (
Expand Down
8 changes: 4 additions & 4 deletions libconsumer/outputs/console/console.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@ import (
"os"
"runtime"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
)

type console struct {
Expand Down
6 changes: 3 additions & 3 deletions libconsumer/outputs/nsq/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@ import (
"context"
"sync"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
"github.com/nsqio/go-nsq"
)

Expand Down
2 changes: 1 addition & 1 deletion libconsumer/outputs/nsq/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ import (
"fmt"
"time"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
)

type Config struct {
Expand Down
6 changes: 3 additions & 3 deletions libconsumer/outputs/nsq/nsq.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package nsq

import (
"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
)

const (
Expand Down
6 changes: 3 additions & 3 deletions libconsumer/outputs/output_reg.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ package outputs
import (
"fmt"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/common"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
)

var outputReg = map[string]Factory{}
Expand Down
2 changes: 1 addition & 1 deletion libconsumer/outputs/outputs.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package outputs
import (
"context"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
)

type Client interface {
Expand Down
4 changes: 2 additions & 2 deletions libconsumer/publisher/includes/includes.go
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
package includes

import (
_ "github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs/console"
_ "github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs/nsq"
_ "github.com/JieTrancender/nsq_consumer/libconsumer/outputs/console"
_ "github.com/JieTrancender/nsq_consumer/libconsumer/outputs/nsq"
)
2 changes: 1 addition & 1 deletion libconsumer/publisher/pipeline/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package pipeline
import (
"fmt"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
)

type client struct {
Expand Down
4 changes: 2 additions & 2 deletions libconsumer/publisher/pipeline/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,8 @@ import (
"errors"
"sync"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/common/atomic"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/common/atomic"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
)

type eventConsumer struct {
Expand Down
6 changes: 3 additions & 3 deletions libconsumer/publisher/pipeline/controller.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package pipeline

import (
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
"github.com/nsqio/go-nsq"
)

Expand Down
6 changes: 3 additions & 3 deletions libconsumer/publisher/pipeline/module.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package pipeline

import (
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
)

type OutputFactory func() (string, outputs.Group, error)
Expand Down
6 changes: 3 additions & 3 deletions libconsumer/publisher/pipeline/output.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@ package pipeline
import (
"context"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
)

type worker struct {
Expand Down
6 changes: 3 additions & 3 deletions libconsumer/publisher/pipeline/pipeline.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package pipeline

import (
"github.com/JieTrancender/nsq_to_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_to_consumer/libconsumer/outputs"
"github.com/JieTrancender/nsq_consumer/libconsumer/consumer"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/outputs"
)

type Pipeline struct {
Expand Down
2 changes: 1 addition & 1 deletion libconsumer/service/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import (
"sync"
"syscall"

"github.com/JieTrancender/nsq_to_consumer/libconsumer/logp"
"github.com/JieTrancender/nsq_consumer/libconsumer/logp"
)

// HandleSignals manages OS signals that ask the service/daemon to stop.
Expand Down
2 changes: 1 addition & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package main
import (
"os"

"github.com/JieTrancender/nsq_to_consumer/cmd"
"github.com/JieTrancender/nsq_consumer/cmd"
)

func main() {
Expand Down

0 comments on commit fb4178d

Please sign in to comment.