summaryrefslogtreecommitdiff
path: root/tests/plugins/resetter/test_plugin.go
diff options
context:
space:
mode:
Diffstat (limited to 'tests/plugins/resetter/test_plugin.go')
-rw-r--r--tests/plugins/resetter/test_plugin.go66
1 files changed, 0 insertions, 66 deletions
diff --git a/tests/plugins/resetter/test_plugin.go b/tests/plugins/resetter/test_plugin.go
deleted file mode 100644
index 5c26cbd0..00000000
--- a/tests/plugins/resetter/test_plugin.go
+++ /dev/null
@@ -1,66 +0,0 @@
-package resetter
-
-import (
- "context"
- "time"
-
- poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
- "github.com/spiral/roadrunner/v2/plugins/config"
- "github.com/spiral/roadrunner/v2/plugins/server"
-)
-
-var testPoolConfig = &poolImpl.Config{
- NumWorkers: 10,
- MaxJobs: 100,
- AllocateTimeout: time.Second * 10,
- DestroyTimeout: time.Second * 10,
- Supervisor: &poolImpl.SupervisorConfig{
- WatchTick: 60 * time.Second,
- TTL: 1000 * time.Second,
- IdleTTL: 10 * time.Second,
- ExecTTL: 10 * time.Second,
- MaxWorkerMemory: 1000,
- },
-}
-
-// Gauge //////////////
-type Plugin1 struct {
- config config.Configurer
- server server.Server
-}
-
-func (p1 *Plugin1) Init(cfg config.Configurer, server server.Server) error {
- p1.config = cfg
- p1.server = server
- return nil
-}
-
-func (p1 *Plugin1) Serve() chan error {
- errCh := make(chan error, 1)
- return errCh
-}
-
-func (p1 *Plugin1) Stop() error {
- return nil
-}
-
-func (p1 *Plugin1) Name() string {
- return "resetter.plugin1"
-}
-
-func (p1 *Plugin1) Reset() error {
- pool, err := p1.server.NewWorkerPool(context.Background(), testPoolConfig, nil)
- if err != nil {
- panic(err)
- }
- pool.Destroy(context.Background())
-
- pool, err = p1.server.NewWorkerPool(context.Background(), testPoolConfig, nil)
- if err != nil {
- panic(err)
- }
-
- _ = pool
-
- return nil
-}