Skip to content

Commit

Permalink
Version Bump (#23)
Browse files Browse the repository at this point in the history
* fix flapper

Signed-off-by: Colin Sullivan <[email protected]>

* version bump

Signed-off-by: Colin Sullivan <[email protected]>
  • Loading branch information
ColinSullivan1 authored Apr 14, 2020
1 parent ef6e20d commit 6cd1c0b
Show file tree
Hide file tree
Showing 3 changed files with 16 additions and 10 deletions.
2 changes: 1 addition & 1 deletion docker/linux/amd64/makefile
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
IMAGE := synadia/nats-surveyor
TAG := 0.0.1-alpha3
TAG := 0.1.0

build:
$(info Make: Building "$(TAG)" tagged images.)
Expand Down
2 changes: 1 addition & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ import (
"github.com/nats-io/nats-surveyor/surveyor"
)

var version = "0.0.1"
var version = "0.1.0"

func main() {
var printVersion bool
Expand Down
22 changes: 14 additions & 8 deletions surveyor/observation_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -107,16 +107,22 @@ func TestServiceObservation_Handle(t *testing.T) {
t.Fatalf("did not receive observations")
}

// publish an invalid observation
err = sc.Clients[0].Publish("testing.topic", []byte{})
if err != nil {
t.Fatalf("publish error: %s", err)
// publish some invalid observations
for i := 0; i < 10; i++ {
err = sc.Clients[0].Publish("testing.topic", []byte{})
if err != nil {
t.Fatalf("publish error: %s", err)
}
}

// wait for the invalid observation to arrive and then test for it
_, err = sub.NextMsg(time.Second)
if err != nil {
t.Fatalf("test subscriber didn't receive invalid message")
sc.Clients[0].Flush()

for i := 0; i < 10; i++ {
// wait for the invalid observations to arrive
_, err = sub.NextMsg(time.Second)
if err != nil {
t.Fatalf("test subscriber didn't receive invalid message")
}
}

time.Sleep(250 * time.Microsecond)
Expand Down

0 comments on commit 6cd1c0b

Please sign in to comment.