Move plugins to a separate repository

Signed-off-by: Valery Piashchynski <piashchynski.valery@gmail.com>

.github/workflows/linux.yml

@@ -7,12 +7,12 @@ on:
       - beta
       - stable
     tags-ignore:
-      - '**'
+      - "**"
     paths-ignore:
-      - '**.md'
+      - "**.md"
   pull_request:
     paths-ignore:
-      - '**.md'
+      - "**.md"
 
 jobs:
   golang:
@@ -22,9 +22,9 @@ jobs:
     strategy:
       fail-fast: true
       matrix:
-        php: [ "7.4", "8.0" ]
-        go: [ "1.17" ]
-        os: [ 'ubuntu-latest' ]
+        php: ["7.4", "8.0", "8.1"]
+        go: ["1.17.1"]
+        os: ["ubuntu-latest"]
     steps:
       - name: Set up Go ${{ matrix.go }}
         uses: actions/setup-go@v2 # action page: <https://github.com/actions/setup-go>
@@ -71,4 +71,3 @@ jobs:
         with:
           file: ./coverage-ci/summary.txt
           fail_ci_if_error: false
-

.vscode/settings.json

@@ -5,12 +5,14 @@
         "amqpjobs",
         "boltdb",
         "codecov",
+        "Errored",
         "golangci",
         "gomemcache",
         "goridge",
         "hget",
         "hset",
         "INMEMORY",
+        "keyvals",
         "memcachedkv",
         "memorykv",
         "mexpire",

Makefile

@@ -15,28 +15,6 @@ test_coverage:
 	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/bst.out -covermode=atomic ./pkg/bst
 	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/pq.out -covermode=atomic ./pkg/priority_queue
 	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/worker_stack.out -covermode=atomic ./pkg/worker_watcher
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/ws_origin.out -covermode=atomic ./plugins/websockets
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/http_config.out -covermode=atomic ./plugins/http/config
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/server_cmd.out -covermode=atomic ./plugins/server
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/struct_jobs.out -covermode=atomic ./plugins/jobs/job
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/pipeline_jobs.out -covermode=atomic ./plugins/jobs/pipeline
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/jobs_core.out -covermode=atomic ./tests/plugins/jobs
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/kv_plugin.out -covermode=atomic ./tests/plugins/kv
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/broadcast_plugin.out -covermode=atomic ./tests/plugins/broadcast
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/websockets.out -covermode=atomic ./tests/plugins/websockets
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/http.out -covermode=atomic ./tests/plugins/http
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/informer.out -covermode=atomic ./tests/plugins/informer
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/reload.out -covermode=atomic ./tests/plugins/reload
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/server.out -covermode=atomic ./tests/plugins/server
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/service.out -covermode=atomic ./tests/plugins/service
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/status.out -covermode=atomic ./tests/plugins/status
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/config.out -covermode=atomic ./tests/plugins/config
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/gzip.out -covermode=atomic ./tests/plugins/gzip
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/headers.out -covermode=atomic ./tests/plugins/headers
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/logger.out -covermode=atomic ./tests/plugins/logger
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/metrics.out -covermode=atomic ./tests/plugins/metrics
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/resetter.out -covermode=atomic ./tests/plugins/resetter
-	go test -v -race -cover -tags=debug -coverpkg=./... -coverprofile=./coverage-ci/rpc.out -covermode=atomic ./tests/plugins/rpc
 	echo 'mode: atomic' > ./coverage-ci/summary.txt
 	tail -q -n +2 ./coverage-ci/*.out >> ./coverage-ci/summary.txt
 	docker-compose -f tests/env/docker-compose.yaml down
@@ -50,26 +28,4 @@ test: ## Run application tests
 	go test -v -race -tags=debug ./pkg/worker_watcher
 	go test -v -race -tags=debug ./pkg/bst
 	go test -v -race -tags=debug ./pkg/priority_queue
-	go test -v -race -tags=debug ./plugins/jobs/pipeline
-	go test -v -race -tags=debug ./plugins/http/config
-	go test -v -race -tags=debug ./plugins/server
-	go test -v -race -tags=debug ./plugins/jobs/job
-	go test -v -race -tags=debug ./tests/plugins/jobs
-	go test -v -race -tags=debug ./tests/plugins/kv
-	go test -v -race -tags=debug ./tests/plugins/broadcast
-	go test -v -race -tags=debug ./tests/plugins/websockets
-	go test -v -race -tags=debug ./plugins/websockets
-	go test -v -race -tags=debug ./tests/plugins/http
-	go test -v -race -tags=debug ./tests/plugins/informer
-	go test -v -race -tags=debug ./tests/plugins/reload
-	go test -v -race -tags=debug ./tests/plugins/server
-	go test -v -race -tags=debug ./tests/plugins/service
-	go test -v -race -tags=debug ./tests/plugins/status
-	go test -v -race -tags=debug ./tests/plugins/config
-	go test -v -race -tags=debug ./tests/plugins/gzip
-	go test -v -race -tags=debug ./tests/plugins/headers
-	go test -v -race -tags=debug ./tests/plugins/logger
-	go test -v -race -tags=debug ./tests/plugins/metrics
-	go test -v -race -tags=debug ./tests/plugins/resetter
-	go test -v -race -tags=debug ./tests/plugins/rpc
 	docker-compose -f tests/env/docker-compose.yaml down

codecov.yml

@@ -19,25 +19,18 @@ ignore:
   - "tests"
   - "systemd"
   - "utils/to_ptr.go"
-  - "plugins/metrics/config_test.go"
-  - "plugins/websockets/storage/storage_test.go"
-  - "plugins/websockets/config.go"
-  - "plugins/amqp/amqpjobs/config.go"
-  - "plugins/beanstalk/config.go"
-  - "plugins/redis/config.go"
-  - "plugins/redis/kv/config.go"
-  - "pkg/doc"
-  - "pkg/bst/bst_test.go"
-  - "pkg/pool/static_pool_test.go"
-  - "pkg/pool/supervisor_test.go"
-  - "pkg/transport/pipe/pipe_factory_spawn_test.go"
-  - "pkg/transport/pipe/pipe_factory_test.go"
-  - "pkg/transport/socket/socket_factory_spawn_test.go"
-  - "pkg/transport/socket/socket_factory_test.go"
-  - "pkg/transport/interface.go"
-  - "pkg/worker/state_test.go"
-  - "pkg/worker/sync_worker_test.go"
-  - "pkg/worker/worker_test.go"
-  - "pkg/events/pool_events.go"
-  - "pkg/events/worker_events.go"
-  - "pkg/events/jobs_events.go"
+  - "doc"
+  - "bst/bst_test.go"
+  - "pool/static_pool_test.go"
+  - "pool/supervisor_test.go"
+  - "transport/pipe/pipe_factory_spawn_test.go"
+  - "transport/pipe/pipe_factory_test.go"
+  - "transport/socket/socket_factory_spawn_test.go"
+  - "transport/socket/socket_factory_test.go"
+  - "transport/interface.go"
+  - "worker/state_test.go"
+  - "worker/sync_worker_test.go"
+  - "worker/worker_test.go"
+  - "events/pool_events.go"
+  - "events/worker_events.go"
+  - "events/jobs_events.go"

pkg/events/pool_events.go → events/pool_events.go

@@ -7,12 +7,12 @@ const (
 	// EventWorkerDestruct thrown after worker destruction.
 	EventWorkerDestruct
 
-	// EventPoolError caused on pool wide errors.
-	EventPoolError
-
 	// EventSupervisorError triggered when supervisor can not complete work.
 	EventSupervisorError
 
+	// EventWorkerProcessExit triggered on process wait exit
+	EventWorkerProcessExit
+
 	// EventNoFreeWorkers triggered when there are no free workers in the stack and timeout for worker allocate elapsed
 	EventNoFreeWorkers
 
@@ -36,12 +36,12 @@ type P int64
 
 func (ev P) String() string {
 	switch ev {
+	case EventWorkerProcessExit:
+		return "EventWorkerProcessExit"
 	case EventWorkerConstruct:
 		return "EventWorkerConstruct"
 	case EventWorkerDestruct:
 		return "EventWorkerDestruct"
-	case EventPoolError:
-		return "EventPoolError"
 	case EventSupervisorError:
 		return "EventSupervisorError"
 	case EventNoFreeWorkers:
@@ -67,4 +67,5 @@ type PoolEvent struct {
 
 	// Payload depends on event type, typically it's worker or error.
 	Payload interface{}
+	Error   error
 }