fixes #76 (#77)

Author: Gsantomaggio

.gitignore

@@ -22,5 +22,6 @@ vet
 .vagrant/
 local/
 tls-gen/
+dist/
 
 perfTest/perfTest

.goreleaser.yml

@@ -0,0 +1,40 @@
+# This is an example .goreleaser.yml file with some sane defaults.
+# Make sure to check the documentation at https://goreleaser.com
+before:
+  hooks:
+    - go mod tidy
+    - go generate ./...
+builds:
+  - id: perf-test
+    binary: stream-perf-test
+    main: ./perfTest
+    env:
+      - CGO_ENABLED=0
+    goos:
+      - linux
+      - windows
+      - darwin
+    goarch:
+      - amd64
+      - arm64
+    goarm:
+      - 7
+archives:
+  - name_template: "{{ .Binary }}_{{ .Os }}_{{ .Arch }}{{ .Arm }}"
+    format: tar.gz
+    format_overrides:
+      - goos: windows
+        format: zip
+checksum:
+  name_template: 'checksums.txt'
+snapshot:
+  name_template: "{{ incpatch .Version }}-next"
+changelog:
+  sort: asc
+  filters:
+    exclude:
+      - "README.md"
+      - ".gitignore"
+      - "^examples:"
+      - Merge pull request
+      - Merge branch

Dockerfile

@@ -7,7 +7,7 @@ COPY Makefile Makefile
 COPY perfTest perfTest
 
 RUN mkdir /stream_perf_test
-RUN VERSION=$(cat VERSION) && go build -ldflags "-X main.Version=$VERSION" -o /stream_perf_test/perfTest perfTest/perftest.go
+RUN VERSION=$(cat VERSION) && go build -ldflags "-X main.Version=$VERSION" -o /stream_perf_test/stream-perf-test perfTest/perftest.go
 
 FROM ubuntu:20.04
 
@@ -26,4 +26,4 @@ RUN 	rm -rf /var/lib/apt/lists/*; \
     	locale-gen en_US.UTF-8
 
 
-ENTRYPOINT ["perfTest"]
+ENTRYPOINT ["stream-perf-test"]

Makefile

@@ -45,7 +45,7 @@ perf-test-help: perf-test-build
 	go run perfTest/perftest.go help
 
 perf-test-build: vet fmt check
-	go build -ldflags=$(LDFLAGS) -o bin/perfTest perfTest/perftest.go
+	go build -ldflags=$(LDFLAGS) -o bin/stream-perf-test perfTest/perftest.go
 
 perf-test-docker-build: perf-test-build
 	docker build -t pivotalrabbitmq/go-stream-perf-test:$(VERSION) .

README.md

@@ -43,7 +43,7 @@ Experimental client for [RabbitMQ Stream Queues](https://github.com/rabbitmq/rab
 ### Installing
 
 ```shell
-go get -u github.com/rabbitmq/rabbitmq-stream-go-client@v0.12-alpha
+go get -u github.com/rabbitmq/rabbitmq-stream-go-client@v0.1.0-beta
 ```
 
 imports:
@@ -327,15 +327,37 @@ func consumerClose(channelClose stream.ChannelClose) {
 ```
 In this way it is possible to handle fail-over
 
-### Perfomance test tool
+### Performance test tool
 
-With the client there is also a performace tool:
+Performance test tool it is useful to execute tests. 
+See also the [Java Performance](https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#the-performance-tool) tool
+
+
+To install you can download the version from github:
+
+Mac:
+```
+https://github.com/rabbitmq/rabbitmq-stream-go-client/releases/latest/download/stream-perf-test_darwin_amd64.tar.gz
+```
+
+Linux:
+```
+https://github.com/rabbitmq/rabbitmq-stream-go-client/releases/latest/download/stream-perf-test_linux_amd64.tar.gz
+```
+
+Windows
+```
+https://github.com/rabbitmq/rabbitmq-stream-go-client/releases/latest/download/stream-perf-test_windows_amd64.zip
+```
+
+execute `stream-perf-test --help` to see the parameters. By default it executes a test with one producer, one consumer.
+
+here an example:
 ```shell
- bin/perfTest -h
+stream-perf-test --publishers 3 --consumers 2 --streams my_stream --max-length-bytes 2GB --uris rabbitmq-stream://guest:guest@localhost:5552/  --fixed-body 400 --time 10
 ```
-It is usefull to execute some test. See also the [Java Performance](https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#the-performance-tool) tool
 
-### Perfomance test tool Docker
+### Performance test tool Docker
 A docker image is available: `pivotalrabbitmq/go-stream-perf-test`, to test it:
 
 Run the server is host mode:
@@ -349,7 +371,7 @@ enable the plugin:
 ```
 then run the docker image:
 ```shell
-docker run -it --network host  pivotalrabbitmq/go-stream-perf-test silent
+docker run -it --network host  pivotalrabbitmq/go-stream-perf-test
 ```
 
 To see all the parameters:

VERSION

@@ -1 +1 @@
-0.13-alpha
+0.1.0-beta

perfTest/.gitignore

@@ -0,0 +1,2 @@
+
+dist/

perfTest/cmd/commands.go

@@ -74,6 +74,12 @@ func setupCli(baseCmd *cobra.Command) {
 
 //Execute is the entrypoint of the commands
 func Execute() {
+	cmd, _, err := rootCmd.Find(os.Args[1:])
+	if err == nil && cmd.Use == rootCmd.Use {
+		args := append([]string{"silent"}, os.Args[1:]...)
+		rootCmd.SetArgs(args)
+	}
+
 	if err := rootCmd.Execute(); err != nil {
 		_, _ = fmt.Fprintln(os.Stderr, err)
 		os.Exit(1)

perfTest/cmd/silent.go

@@ -21,7 +21,8 @@ var wg sync.WaitGroup
 func newSilent() *cobra.Command {
 	var silentCmd = &cobra.Command{
 		Use:   "silent",
-		Short: "NewProducer a silent simulation",
+		Short: "Start the performance test (default command)",
+
 		RunE: func(cmd *cobra.Command, args []string) error {
 			wg.Add(1)
 			err := startSimulation()
@@ -56,7 +57,7 @@ func checkRunDuration() {
 				case _ = <-ticker.C:
 					v := time.Now().Sub(start).Seconds()
 					if v >= float64(runDuration) {
-						logInfo("Stopping after %s seconds", runDuration)
+						logInfo("Stopping after %d seconds", runDuration)
 						os.Exit(0)
 					}
 				}
@@ -79,8 +80,8 @@ func printStats() {
 					CMessagesPerSecond := float64(atomic.LoadInt32(&consumerMessageCount)) / float64(v) * 1000
 					ConfirmedMessagesPerSecond := float64(atomic.LoadInt32(&confirmedMessageCount)) / float64(v) * 1000
 
-					logInfo("Published %8.2f msg/s   |   Confirmed %8.2f msg/s   |   Consumed %8.2f msg/s   |  Cons. closed %3v  |   Pub errors %3v  |   %3v  |  %3v  |  msg sent: %3v  |",
-						PMessagesPerSecond, ConfirmedMessagesPerSecond, CMessagesPerSecond, consumersCloseCount, publishErrors, decodeRate(), decodeBody(), atomic.LoadInt64(&messagesSent))
+					logInfo("Published %8.1f msg/s   |   Confirmed %8.1f msg/s   |   Consumed %8.1f msg/s  |  Pub errors %3v  |   %3v  |  %3v  |  msg sent: %3v  |",
+						PMessagesPerSecond, ConfirmedMessagesPerSecond, CMessagesPerSecond, publishErrors, decodeRate(), decodeBody(), atomic.LoadInt64(&messagesSent))
 				}
 			}
 

pkg/stream/constants.go

@@ -90,7 +90,7 @@ const (
 	defaultBatchSize            = 100
 	defaultBatchPublishingDelay = 100
 	//
-	ClientVersion = "0.13-alpha"
+	ClientVersion = "0.1.0-beta"
 
 	StreamTcpPort = "5552"
 )