summaryrefslogtreecommitdiff
path: root/tests/plugins/jobs/jobs_general_test.go
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2021-09-02 20:09:01 +0300
committerGitHub <[email protected]>2021-09-02 20:09:01 +0300
commit6749db4a2d39fa70b426bcf50edf66a176c07f57 (patch)
treef6f92c9f0016f6bcac6a9aa45ccc961eebf90018 /tests/plugins/jobs/jobs_general_test.go
parent0437d1f58514f694ea86e8176e621c009cd510f9 (diff)
parent4524f8c5af045ed5048250b63b7859eaeb4f24a1 (diff)
#778: feat(refactor): jobs code adjustingv2.4.0
#778: feat(refactor): jobs code adjusting
Diffstat (limited to 'tests/plugins/jobs/jobs_general_test.go')
-rw-r--r--tests/plugins/jobs/jobs_general_test.go10
1 files changed, 5 insertions, 5 deletions
diff --git a/tests/plugins/jobs/jobs_general_test.go b/tests/plugins/jobs/jobs_general_test.go
index 951d6227..5c521c2b 100644
--- a/tests/plugins/jobs/jobs_general_test.go
+++ b/tests/plugins/jobs/jobs_general_test.go
@@ -14,9 +14,9 @@ import (
endure "github.com/spiral/endure/pkg/container"
"github.com/spiral/roadrunner/v2/plugins/amqp"
"github.com/spiral/roadrunner/v2/plugins/config"
- "github.com/spiral/roadrunner/v2/plugins/ephemeral"
"github.com/spiral/roadrunner/v2/plugins/informer"
"github.com/spiral/roadrunner/v2/plugins/jobs"
+ "github.com/spiral/roadrunner/v2/plugins/memory"
"github.com/spiral/roadrunner/v2/plugins/metrics"
"github.com/spiral/roadrunner/v2/plugins/resetter"
rpcPlugin "github.com/spiral/roadrunner/v2/plugins/rpc"
@@ -68,7 +68,7 @@ func TestJobsInit(t *testing.T) {
&jobs.Plugin{},
&resetter.Plugin{},
&informer.Plugin{},
- &ephemeral.Plugin{},
+ &memory.Plugin{},
&amqp.Plugin{},
)
assert.NoError(t, err)
@@ -154,7 +154,7 @@ func TestJOBSMetrics(t *testing.T) {
&server.Plugin{},
&jobs.Plugin{},
&metrics.Plugin{},
- &ephemeral.Plugin{},
+ &memory.Plugin{},
mockLogger,
)
assert.NoError(t, err)
@@ -204,8 +204,8 @@ func TestJOBSMetrics(t *testing.T) {
time.Sleep(time.Second * 2)
- t.Run("DeclareEphemeralPipeline", declareEphemeralPipe)
- t.Run("ConsumeEphemeralPipeline", consumeEphemeralPipe)
+ t.Run("DeclareEphemeralPipeline", declareMemoryPipe)
+ t.Run("ConsumeEphemeralPipeline", consumeMemoryPipe)
t.Run("PushEphemeralPipeline", pushToPipe("test-3"))
time.Sleep(time.Second)
t.Run("PushEphemeralPipeline", pushToPipeDelayed("test-3", 5))