Remove dependancy on go-micro/v3/events package

.github/workflows/integration-k8s.yml

@@ -53,7 +53,8 @@ jobs:
         mkdir /tmp/micro
         cp -R . /tmp/micro
         cd /tmp/micro
-        go mod edit -replace github.com/micro/micro/plugin/nats/v3=./plugin/nats
+        go mod edit -replace github.com/micro/micro/plugin/nats/broker/v3=./plugin/nats/broker
+        go mod edit -replace github.com/micro/micro/plugin/nats/stream/v3=./plugin/nats/stream
         go mod edit -replace github.com/micro/micro/profile/platform/v3=./profile/platform
         go mod edit -replace google.golang.org/grpc=google.golang.org/grpc@v1.26.0
         go install

.github/workflows/platform.yml

@@ -21,7 +21,8 @@ jobs:
     - name: Replace platform profile
       id: replace-profile
       run: |
-        go mod edit -replace github.com/micro/micro/plugin/nats/v3=./plugin/nats
+        go mod edit -replace github.com/micro/micro/plugin/nats/broker/v3=./plugin/nats/broker
+        go mod edit -replace github.com/micro/micro/plugin/nats/stream/v3=./plugin/nats/stream
         go mod edit -replace github.com/micro/micro/profile/platform/v3=./profile/platform
         go mod edit -replace google.golang.org/grpc=google.golang.org/grpc@v1.26.0
 

cmd/defaults.go

@@ -7,6 +7,8 @@ import (
 	brokerSrv "github.com/micro/micro/v3/service/broker/client"
 	"github.com/micro/micro/v3/service/client"
 	grpcCli "github.com/micro/micro/v3/service/client/grpc"
+	"github.com/micro/micro/v3/service/events"
+	eventsSrv "github.com/micro/micro/v3/service/events/client"
 	"github.com/micro/micro/v3/service/network"
 	mucpNet "github.com/micro/micro/v3/service/network/mucp"
 	"github.com/micro/micro/v3/service/server"
@@ -23,4 +25,6 @@ func setupDefaults() {
 	// setup rpc implementations after the client is configured
 	auth.DefaultAuth = authSrv.NewAuth()
 	broker.DefaultBroker = brokerSrv.NewBroker()
+	events.DefaultStream = eventsSrv.NewStream()
+	events.DefaultStore = eventsSrv.NewStore()
 }

go.mod

@@ -23,7 +23,6 @@ require (
 	github.com/google/uuid v1.1.2
 	github.com/gorilla/handlers v1.4.2
 	github.com/gorilla/mux v1.7.3
-	github.com/gosimple/slug v1.9.0
 	github.com/hashicorp/go-version v1.2.1
 	github.com/juju/fslock v0.0.0-20160525022230-4d5c94c67b4b
 	github.com/micro/go-micro/v3 v3.0.0-beta.3.0.20201013135405-1a962e46fd3a

go.sum

@@ -191,8 +191,6 @@ github.com/gorilla/handlers v1.4.2/go.mod h1:Qkdc/uu4tH4g6mTK6auzZ766c4CA0Ng8+o/
 github.com/gorilla/mux v1.6.2/go.mod h1:1lud6UwP+6orDFRuTfBEV8e9/aOM/c4fVVCaMa2zaAs=
 github.com/gorilla/mux v1.7.3 h1:gnP5JzjVOuiZD07fKKToCAOjS0yOpj/qPETTXCCS6hw=
 github.com/gorilla/mux v1.7.3/go.mod h1:1lud6UwP+6orDFRuTfBEV8e9/aOM/c4fVVCaMa2zaAs=
-github.com/gosimple/slug v1.9.0 h1:r5vDcYrFz9BmfIAMC829un9hq7hKM4cHUrsv36LbEqs=
-github.com/gosimple/slug v1.9.0/go.mod h1:AMZ+sOVe65uByN3kgEyf9WEBKBCSS+dJjMX9x4vDJbg=
 github.com/grpc-ecosystem/grpc-gateway v1.8.5/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
 github.com/h2non/parth v0.0.0-20190131123155-b4df798d6542/go.mod h1:Ow0tF8D4Kplbc8s8sSb3V2oUCygFHVp8gC3Dn6U4MNI=
 github.com/hashicorp/errwrap v0.0.0-20141028054710-7554cd9344ce/go.mod h1:YH+1FKiLXxHSkmPseP+kNlulaMuP3n2brvKWEqk/Jc4=
@@ -328,8 +326,6 @@ github.com/prometheus/procfs v0.0.2/go.mod h1:TjEm7ze935MbeOT/UhFTIMYKhuLP4wbCsT
 github.com/prometheus/procfs v0.0.3/go.mod h1:4A/X28fw3Fc593LaREMrKMqOKvUAntwMDaekg4FpcdQ=
 github.com/prometheus/procfs v0.0.5/go.mod h1:4A/X28fw3Fc593LaREMrKMqOKvUAntwMDaekg4FpcdQ=
 github.com/rainycape/memcache v0.0.0-20150622160815-1031fa0ce2f2/go.mod h1:7tZKcyumwBO6qip7RNQ5r77yrssm9bfCowcLEBcU5IA=
-github.com/rainycape/unidecode v0.0.0-20150907023854-cb7f23ec59be h1:ta7tUOvsPHVHGom5hKW5VXNc2xZIkfCKP8iaqOyYtUQ=
-github.com/rainycape/unidecode v0.0.0-20150907023854-cb7f23ec59be/go.mod h1:MIDFMn7db1kT65GmV94GzpX9Qdi7N/pQlwb+AN8wh+Q=
 github.com/rcrowley/go-metrics v0.0.0-20181016184325-3113b8401b8a/go.mod h1:bCqnVzQkZxMG4s8nGwiZ5l3QUCyqpo9Y+/ZMZ9VjZe4=
 github.com/rhysd/go-github-selfupdate v1.2.2 h1:G+mNzkc1wEtpmM6sFS/Ghkeq+ad4Yp6EZEHyp//wGEo=
 github.com/rhysd/go-github-selfupdate v1.2.2/go.mod h1:khesvSyKcXDUxeySCedFh621iawCks0dS/QnHPcpCws=

plugin/nats/go.mod → plugin/nats/broker/go.mod

@@ -1,4 +1,4 @@
-module github.com/micro/micro/plugin/nats/v3
+module github.com/micro/micro/plugin/nats/broker/v3
 
 go 1.13
 
@@ -11,4 +11,4 @@ require (
 	github.com/oxtoacart/bpool v0.0.0-20190530202638-03653db5a59c
 )
 
-replace github.com/micro/micro/v3 => ../..
+replace github.com/micro/micro/v3 => ../../..

plugin/nats/stream/go.mod

@@ -0,0 +1,13 @@
+module github.com/micro/micro/plugin/nats/stream/v3
+
+go 1.13
+
+require (
+	github.com/google/uuid v1.1.2
+	github.com/micro/micro/v3 v3.0.0-beta.6
+	github.com/nats-io/nats.go v1.10.0
+	github.com/nats-io/stan.go v0.7.0
+	github.com/pkg/errors v0.9.1
+)
+
+replace github.com/micro/micro/v3 => ../../..