summaryrefslogtreecommitdiff
path: root/tests/plugins/informer/test_plugin.go
diff options
context:
space:
mode:
Diffstat (limited to 'tests/plugins/informer/test_plugin.go')
-rw-r--r--tests/plugins/informer/test_plugin.go71
1 files changed, 0 insertions, 71 deletions
diff --git a/tests/plugins/informer/test_plugin.go b/tests/plugins/informer/test_plugin.go
deleted file mode 100644
index 21897f40..00000000
--- a/tests/plugins/informer/test_plugin.go
+++ /dev/null
@@ -1,71 +0,0 @@
-package informer
-
-import (
- "context"
- "time"
-
- "github.com/spiral/roadrunner/v2/pkg/pool"
- "github.com/spiral/roadrunner/v2/pkg/state/process"
- "github.com/spiral/roadrunner/v2/plugins/config"
- "github.com/spiral/roadrunner/v2/plugins/server"
-)
-
-var testPoolConfig = &pool.Config{
- NumWorkers: 10,
- MaxJobs: 100,
- AllocateTimeout: time.Second * 10,
- DestroyTimeout: time.Second * 10,
- Supervisor: &pool.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 "informer.plugin1"
-}
-
-func (p1 *Plugin1) Available() {}
-
-func (p1 *Plugin1) Workers() []*process.State {
- p, err := p1.server.NewWorkerPool(context.Background(), testPoolConfig, nil)
- if err != nil {
- panic(err)
- }
-
- ps := make([]*process.State, 0, len(p.Workers()))
- workers := p.Workers()
- for i := 0; i < len(workers); i++ {
- state, err := process.WorkerProcessState(workers[i])
- if err != nil {
- return nil
- }
- ps = append(ps, state)
- }
-
- return ps
-}