summaryrefslogtreecommitdiff
path: root/pkg/transport
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-01-25 14:50:21 +0300
committerValery Piashchynski <[email protected]>2021-01-25 14:50:21 +0300
commitbb9e34db0f96295c5c2104262f43a3ab0edbc060 (patch)
treea9b0b99a36b796fdeaac130c9330de10aa4d5c0e /pkg/transport
parent709f7223fca5e60793ad9b3192f92a554854d6ee (diff)
Add new Supervisor test in the http plugin
Uniform supervisor config keys to use same notation as pool (10s, 10h not just 10)
Diffstat (limited to 'pkg/transport')
-rw-r--r--pkg/transport/pipe/pipe_factory_spawn_test.go6
-rwxr-xr-xpkg/transport/pipe/pipe_factory_test.go6
2 files changed, 6 insertions, 6 deletions
diff --git a/pkg/transport/pipe/pipe_factory_spawn_test.go b/pkg/transport/pipe/pipe_factory_spawn_test.go
index 2e5bbcd5..d4949c82 100644
--- a/pkg/transport/pipe/pipe_factory_spawn_test.go
+++ b/pkg/transport/pipe/pipe_factory_spawn_test.go
@@ -440,17 +440,17 @@ func Test_NumExecs2(t *testing.T) {
if err != nil {
t.Errorf("fail to execute payload: error %v", err)
}
- assert.Equal(t, int64(1), w.State().NumExecs())
+ assert.Equal(t, uint64(1), w.State().NumExecs())
_, err = sw.Exec(payload.Payload{Body: []byte("hello")})
if err != nil {
t.Errorf("fail to execute payload: error %v", err)
}
- assert.Equal(t, int64(2), w.State().NumExecs())
+ assert.Equal(t, uint64(2), w.State().NumExecs())
_, err = sw.Exec(payload.Payload{Body: []byte("hello")})
if err != nil {
t.Errorf("fail to execute payload: error %v", err)
}
- assert.Equal(t, int64(3), w.State().NumExecs())
+ assert.Equal(t, uint64(3), w.State().NumExecs())
}
diff --git a/pkg/transport/pipe/pipe_factory_test.go b/pkg/transport/pipe/pipe_factory_test.go
index fa37ac0f..38166b85 100755
--- a/pkg/transport/pipe/pipe_factory_test.go
+++ b/pkg/transport/pipe/pipe_factory_test.go
@@ -462,17 +462,17 @@ func Test_NumExecs(t *testing.T) {
if err != nil {
t.Errorf("fail to execute payload: error %v", err)
}
- assert.Equal(t, int64(1), w.State().NumExecs())
+ assert.Equal(t, uint64(1), w.State().NumExecs())
_, err = sw.Exec(payload.Payload{Body: []byte("hello")})
if err != nil {
t.Errorf("fail to execute payload: error %v", err)
}
- assert.Equal(t, int64(2), w.State().NumExecs())
+ assert.Equal(t, uint64(2), w.State().NumExecs())
_, err = sw.Exec(payload.Payload{Body: []byte("hello")})
if err != nil {
t.Errorf("fail to execute payload: error %v", err)
}
- assert.Equal(t, int64(3), w.State().NumExecs())
+ assert.Equal(t, uint64(3), w.State().NumExecs())
}