summaryrefslogtreecommitdiff
path: root/plugins/informer/tests/test_plugin.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/informer/tests/test_plugin.go')
-rw-r--r--plugins/informer/tests/test_plugin.go59
1 files changed, 0 insertions, 59 deletions
diff --git a/plugins/informer/tests/test_plugin.go b/plugins/informer/tests/test_plugin.go
deleted file mode 100644
index 31643952..00000000
--- a/plugins/informer/tests/test_plugin.go
+++ /dev/null
@@ -1,59 +0,0 @@
-package tests
-
-import (
- "context"
- "time"
-
- "github.com/spiral/roadrunner/v2/interfaces/config"
- "github.com/spiral/roadrunner/v2/interfaces/server"
- "github.com/spiral/roadrunner/v2/interfaces/worker"
- poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
-)
-
-var testPoolConfig = poolImpl.Config{
- NumWorkers: 10,
- MaxJobs: 100,
- AllocateTimeout: time.Second * 10,
- DestroyTimeout: time.Second * 10,
- Supervisor: &poolImpl.SupervisorConfig{
- WatchTick: 60,
- TTL: 1000,
- IdleTTL: 10,
- ExecTTL: 10,
- 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) Workers() []worker.BaseProcess {
- pool, err := p1.server.NewWorkerPool(context.Background(), testPoolConfig, nil)
- if err != nil {
- panic(err)
- }
-
- return pool.Workers()
-}