Skip to content
This repository has been archived by the owner on Apr 12, 2024. It is now read-only.

Commit

Permalink
Added a new simple-stream-service example
Browse files Browse the repository at this point in the history
This sends out a random word on 'simple-stream' every 1 second.

Signed-off-by: Dave Shanley <dshanley@vmware.com>
  • Loading branch information
daveshanley committed Aug 25, 2021
1 parent fff9cf0 commit 32f432a
Show file tree
Hide file tree
Showing 5 changed files with 132 additions and 36 deletions.
4 changes: 4 additions & 0 deletions plank/cmd/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,10 @@ func main() {
return err
}

if err := platformServer.RegisterService(services.NewSimpleStreamService(), services.SimpleStreamServiceChannel); err != nil {
return err
}

// start server
syschan := make(chan os.Signal, 1)
platformServer.StartServer(syschan)
Expand Down
12 changes: 1 addition & 11 deletions plank/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -3,12 +3,6 @@ module github.com/vmware/transport-go/plank
go 1.16

require (
github.com/armon/consul-api v0.0.0-20180202201655-eb2c6b5be1b6 // indirect
github.com/coreos/etcd v3.3.10+incompatible // indirect
github.com/coreos/go-etcd v2.0.0+incompatible // indirect
github.com/cpuguy83/go-md2man v1.0.10 // indirect
github.com/cpuguy83/go-md2man/v2 v2.0.1 // indirect
github.com/disintegration/imaging v1.6.2 // indirect
github.com/eliukblau/pixterm v1.3.1
github.com/fatih/color v1.12.0
github.com/go-git/go-git/v5 v5.4.2
Expand All @@ -21,23 +15,19 @@ require (
github.com/magefile/mage v1.11.0 // indirect
github.com/mattn/go-isatty v0.0.13 // indirect
github.com/prometheus/client_golang v1.6.0
github.com/russross/blackfriday/v2 v2.1.0 // indirect
github.com/shurcooL/httpfs v0.0.0-20190707220628-8d4bc4ba7749 // indirect
github.com/robfig/cron/v3 v3.0.1 // indirect
github.com/sirupsen/logrus v1.8.0
github.com/spf13/cobra v1.2.1
github.com/spf13/pflag v1.0.5
github.com/spf13/viper v1.8.1
github.com/streadway/amqp v1.0.0
github.com/stretchr/objx v0.2.0 // indirect
github.com/stretchr/testify v1.7.0
github.com/ugorji/go/codec v0.0.0-20181204163529-d75b2dcb6bc8 // indirect
github.com/vmware/transport-go v1.2.0
github.com/xordataexchange/crypt v0.0.3-0.20170626215501-b2862e3d0a77 // indirect
golang.org/x/crypto v0.0.0-20210817164053-32db794688a5
golang.org/x/net v0.0.0-20210805182204-aaa1db679c0d
golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c // indirect
golang.org/x/term v0.0.0-20210615171337-6886f2dfbf5b // indirect
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect
)

replace github.com/vmware/transport-go => ../
Loading

0 comments on commit 32f432a

Please sign in to comment.