Skip to content

Commit 2d55e10

Browse files
zzzmingzzzming
authored
set up correct kafkaesque-io golang package (#41)
1 parent 3a427b6 commit 2d55e10

26 files changed

+55
-55
lines changed

‎.github/workflows/go.yml

+5-5
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ jobs:
2424
uses: actions/checkout@v1
2525
with:
2626
fetch-depth: 1
27-
path: go/src/github.com/pulsar-beam
27+
path: go/src/github.com/kafkaesque-io/pulsar-beam
2828

2929
- name: Lint Go Code
3030
run: |
@@ -55,7 +55,7 @@ jobs:
5555
uses: actions/checkout@v1
5656
with:
5757
fetch-depth: 1
58-
path: go/src/github.com/pulsar-beam
58+
path: go/src/github.com/kafkaesque-io/pulsar-beam
5959
- name: Install MongoDB
6060
run: |
6161
echo $GITHUB_EVENT_NAME
@@ -106,7 +106,7 @@ jobs:
106106
file: ./coverage.txt
107107
yml: ./.codecov.yml
108108
fail_ci_fi_error: true
109-
path: go/src/github.com/pulsar-beam
109+
path: go/src/github.com/kafkaesque-io/pulsar-beam
110110

111111
e2e_test:
112112
name: e2e_test
@@ -117,7 +117,7 @@ jobs:
117117
uses: actions/checkout@v1
118118
with:
119119
fetch-depth: 1
120-
path: go/src/github.com/pulsar-beam
120+
path: go/src/github.com/kafkaesque-io/pulsar-beam
121121

122122
- name: Install dependencies
123123
run: |
@@ -181,7 +181,7 @@ jobs:
181181
uses: actions/checkout@v1
182182
with:
183183
fetch-depth: 1
184-
path: go/src/github.com/pulsar-beam
184+
path: go/src/github.com/kafkaesque-io/pulsar-beam
185185

186186
- name: Build Docker Image
187187
run: |

‎config/github_action_beam.json

+2-2
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@
22
"PORT": "3000",
33
"CLUSTER": "localhost",
44
"PbDbType": "mongo",
5-
"PulsarPublicKey": "/home/runner/work/pulsar-beam/go/src/github.com/pulsar-beam/src/unit-test/example_public_key.pub",
6-
"PulsarPrivateKey": "/home/runner/work/pulsar-beam/go/src/github.com/pulsar-beam/src/unit-test/example_private_key",
5+
"PulsarPublicKey": "/home/runner/work/pulsar-beam/go/src/github.com/kafkaesque-io/pulsar-beam/src/unit-test/example_public_key.pub",
6+
"PulsarPrivateKey": "/home/runner/work/pulsar-beam/go/src/github.com/kafkaesque-io/pulsar-beam/src/unit-test/example_private_key",
77
"PbDbInterval": "60s",
88
"DbConnectionStr": "mongodb://172.17.0.1:27017"
99

‎go.mod

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
module github.com/pulsar-beam
1+
module github.com/kafkaesque-io/pulsar-beam
22

33
go 1.13
44

‎scripts/ci.sh

+1-1
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
# absolute directory
1010
DIR="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null 2>&1 && pwd )"
1111

12-
BASE_PKG_DIR="github.com/pulsar-beam/src/"
12+
BASE_PKG_DIR="github.com/kafkaesque-io/pulsar-beam/src/"
1313
ALL_PKGS=""
1414

1515
cd $DIR/../src

‎src/broker/webhook.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -14,10 +14,10 @@ import (
1414

1515
"github.com/apache/pulsar-client-go/pulsar"
1616
"github.com/hashicorp/go-retryablehttp"
17-
"github.com/pulsar-beam/src/db"
18-
"github.com/pulsar-beam/src/model"
19-
"github.com/pulsar-beam/src/pulsardriver"
20-
"github.com/pulsar-beam/src/util"
17+
"github.com/kafkaesque-io/pulsar-beam/src/db"
18+
"github.com/kafkaesque-io/pulsar-beam/src/model"
19+
"github.com/kafkaesque-io/pulsar-beam/src/pulsardriver"
20+
"github.com/kafkaesque-io/pulsar-beam/src/util"
2121
)
2222

2323
// SubCloseSignal is a signal object to pass for channel

‎src/db/in-memory.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"log"
66
"time"
77

8-
"github.com/pulsar-beam/src/model"
8+
"github.com/kafkaesque-io/pulsar-beam/src/model"
99
)
1010

1111
/**

‎src/db/interface.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import (
44
"errors"
55
"log"
66

7-
"github.com/pulsar-beam/src/model"
7+
"github.com/kafkaesque-io/pulsar-beam/src/model"
88
)
99

1010
// dbConn is a singlton of Db instance

‎src/db/mongo.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@ import (
66
"log"
77
"time"
88

9-
"github.com/pulsar-beam/src/model"
10-
"github.com/pulsar-beam/src/util"
9+
"github.com/kafkaesque-io/pulsar-beam/src/model"
10+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1111
"go.mongodb.org/mongo-driver/bson"
1212
"go.mongodb.org/mongo-driver/mongo"
1313
"go.mongodb.org/mongo-driver/mongo/options"

‎src/db/pulsardb.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,8 @@ import (
88
"time"
99

1010
"github.com/apache/pulsar-client-go/pulsar"
11-
"github.com/pulsar-beam/src/model"
12-
"github.com/pulsar-beam/src/util"
11+
"github.com/kafkaesque-io/pulsar-beam/src/model"
12+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1313
)
1414

1515
/**

‎src/e2e/e2etest.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,8 @@ import (
1212
"time"
1313

1414
"github.com/apache/pulsar-client-go/pulsar"
15-
"github.com/pulsar-beam/src/model"
16-
"github.com/pulsar-beam/src/util"
15+
"github.com/kafkaesque-io/pulsar-beam/src/model"
16+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1717
)
1818

1919
// This is an end to end test program. It does these steps in order

‎src/main.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@ import (
66
"net/http"
77
"os"
88

9-
"github.com/pulsar-beam/src/broker"
10-
"github.com/pulsar-beam/src/route"
11-
"github.com/pulsar-beam/src/util"
9+
"github.com/kafkaesque-io/pulsar-beam/src/broker"
10+
"github.com/kafkaesque-io/pulsar-beam/src/route"
11+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1212
"github.com/rs/cors"
1313
)
1414

‎src/middleware/middleware.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import (
66
"net/http"
77
"strings"
88

9-
"github.com/pulsar-beam/src/util"
9+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1010
)
1111

1212
// AuthFunc is a function type to allow pluggable authentication middleware

‎src/model/topic.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
"time"
1212

1313
"github.com/apache/pulsar-client-go/pulsar"
14-
"github.com/pulsar-beam/src/icrypto"
14+
"github.com/kafkaesque-io/pulsar-beam/src/icrypto"
1515
)
1616

1717
// Status can be used for webhook status

‎src/pulsardriver/pulsar-client.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ import (
77
"time"
88

99
"github.com/apache/pulsar-client-go/pulsar"
10-
"github.com/pulsar-beam/src/util"
10+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1111
)
1212

1313
// ClientCache caches a list Pulsar clients

‎src/pulsardriver/pulsar-consumer.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,8 @@ import (
77
"time"
88

99
"github.com/apache/pulsar-client-go/pulsar"
10-
"github.com/pulsar-beam/src/model"
11-
"github.com/pulsar-beam/src/util"
10+
"github.com/kafkaesque-io/pulsar-beam/src/model"
11+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1212
)
1313

1414
// ConsumerCache caches a list Pulsar prudcers

‎src/pulsardriver/pulsar-producer.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88
"time"
99

1010
"github.com/apache/pulsar-client-go/pulsar"
11-
"github.com/pulsar-beam/src/util"
11+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1212
)
1313

1414
// ProducerCache caches a list Pulsar prudcers

‎src/route/handlers.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -10,10 +10,10 @@ import (
1010
"strings"
1111

1212
"github.com/gorilla/mux"
13-
"github.com/pulsar-beam/src/db"
14-
"github.com/pulsar-beam/src/model"
15-
"github.com/pulsar-beam/src/pulsardriver"
16-
"github.com/pulsar-beam/src/util"
13+
"github.com/kafkaesque-io/pulsar-beam/src/db"
14+
"github.com/kafkaesque-io/pulsar-beam/src/model"
15+
"github.com/kafkaesque-io/pulsar-beam/src/pulsardriver"
16+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1717
)
1818

1919
var singleDb db.Db

‎src/route/router.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@ import (
66

77
"github.com/gorilla/mux"
88

9-
"github.com/pulsar-beam/src/middleware"
10-
"github.com/pulsar-beam/src/util"
9+
"github.com/kafkaesque-io/pulsar-beam/src/middleware"
10+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1111
)
1212

1313
// NewRouter - create new router for HTTP routing

‎src/route/routes.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55

66
"github.com/gorilla/mux"
77
"github.com/prometheus/client_golang/prometheus/promhttp"
8-
"github.com/pulsar-beam/src/middleware"
8+
"github.com/kafkaesque-io/pulsar-beam/src/middleware"
99
)
1010

1111
// Route - HTTP Route

‎src/unit-test/crypto_test.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import (
55
"testing"
66
"time"
77

8-
. "github.com/pulsar-beam/src/icrypto"
8+
. "github.com/kafkaesque-io/pulsar-beam/src/icrypto"
99
)
1010

1111
func TestAES(t *testing.T) {

‎src/unit-test/db_test.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -6,10 +6,10 @@ import (
66
"strings"
77
"testing"
88

9-
"github.com/pulsar-beam/src/broker"
10-
. "github.com/pulsar-beam/src/db"
11-
"github.com/pulsar-beam/src/model"
12-
"github.com/pulsar-beam/src/util"
9+
"github.com/kafkaesque-io/pulsar-beam/src/broker"
10+
. "github.com/kafkaesque-io/pulsar-beam/src/db"
11+
"github.com/kafkaesque-io/pulsar-beam/src/model"
12+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1313
)
1414

1515
func TestUnsupportedDbDriver(t *testing.T) {

‎src/unit-test/handlers_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,9 @@ import (
88
"os"
99
"testing"
1010

11-
"github.com/pulsar-beam/src/model"
12-
. "github.com/pulsar-beam/src/route"
13-
"github.com/pulsar-beam/src/util"
11+
"github.com/kafkaesque-io/pulsar-beam/src/model"
12+
. "github.com/kafkaesque-io/pulsar-beam/src/route"
13+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1414
)
1515

1616
func TestStatusAPI(t *testing.T) {

‎src/unit-test/middleware_test.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@ import (
66
"testing"
77
"time"
88

9-
"github.com/pulsar-beam/src/icrypto"
10-
. "github.com/pulsar-beam/src/middleware"
11-
"github.com/pulsar-beam/src/route"
9+
"github.com/kafkaesque-io/pulsar-beam/src/icrypto"
10+
. "github.com/kafkaesque-io/pulsar-beam/src/middleware"
11+
"github.com/kafkaesque-io/pulsar-beam/src/route"
1212
)
1313

1414
func mockHandler(w http.ResponseWriter, r *http.Request) {

‎src/unit-test/pulsar_test.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -5,8 +5,8 @@ import (
55
"strings"
66
"testing"
77

8-
"github.com/pulsar-beam/src/pulsardriver"
9-
"github.com/pulsar-beam/src/util"
8+
"github.com/kafkaesque-io/pulsar-beam/src/pulsardriver"
9+
"github.com/kafkaesque-io/pulsar-beam/src/util"
1010
)
1111

1212
func TestClientCreation(t *testing.T) {

‎src/unit-test/util_test.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -8,10 +8,10 @@ import (
88
"strconv"
99
"testing"
1010

11-
"github.com/pulsar-beam/src/broker"
12-
"github.com/pulsar-beam/src/model"
13-
"github.com/pulsar-beam/src/route"
14-
. "github.com/pulsar-beam/src/util"
11+
"github.com/kafkaesque-io/pulsar-beam/src/broker"
12+
"github.com/kafkaesque-io/pulsar-beam/src/model"
13+
"github.com/kafkaesque-io/pulsar-beam/src/route"
14+
. "github.com/kafkaesque-io/pulsar-beam/src/util"
1515
)
1616

1717
func TestUUID(t *testing.T) {

‎src/util/config.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
"unicode"
1212

1313
"github.com/ghodss/yaml"
14-
"github.com/pulsar-beam/src/icrypto"
14+
"github.com/kafkaesque-io/pulsar-beam/src/icrypto"
1515
)
1616

1717
// DefaultConfigFile - default config file

0 commit comments

Comments
 (0)