summaryrefslogtreecommitdiff
path: root/interfaces
diff options
context:
space:
mode:
authorValery Piashchynski <[email protected]>2020-12-18 22:57:33 +0300
committerValery Piashchynski <[email protected]>2020-12-18 22:57:33 +0300
commitad39466afb39fac49977cfb97f20f682f54bf35e (patch)
tree59b630ad0ef9b52eb13e0df5c8e41d92ce277950 /interfaces
parentee0cb478c74c393a35155c2bf51e1ef260e0e5e2 (diff)
Move roadrunner payload out of internal to pkgv2.0.0-alpha25
Diffstat (limited to 'interfaces')
-rw-r--r--interfaces/pool/pool.go6
-rw-r--r--interfaces/worker/worker.go5
2 files changed, 6 insertions, 5 deletions
diff --git a/interfaces/pool/pool.go b/interfaces/pool/pool.go
index a1015fd6..72da9597 100644
--- a/interfaces/pool/pool.go
+++ b/interfaces/pool/pool.go
@@ -7,7 +7,7 @@ import (
"github.com/spiral/roadrunner/v2/interfaces/events"
"github.com/spiral/roadrunner/v2/interfaces/worker"
- "github.com/spiral/roadrunner/v2/internal"
+ "github.com/spiral/roadrunner/v2/pkg/payload"
)
// Pool managed set of inner worker processes.
@@ -19,9 +19,9 @@ type Pool interface {
GetConfig() interface{}
// Exec
- Exec(rqs internal.Payload) (internal.Payload, error)
+ Exec(rqs payload.Payload) (payload.Payload, error)
- ExecWithContext(ctx context.Context, rqs internal.Payload) (internal.Payload, error)
+ ExecWithContext(ctx context.Context, rqs payload.Payload) (payload.Payload, error)
// Workers returns worker list associated with the pool.
Workers() (workers []worker.BaseProcess)
diff --git a/interfaces/worker/worker.go b/interfaces/worker/worker.go
index edbc68d9..773dd044 100644
--- a/interfaces/worker/worker.go
+++ b/interfaces/worker/worker.go
@@ -8,6 +8,7 @@ import (
"github.com/spiral/goridge/v3"
"github.com/spiral/roadrunner/v2/interfaces/events"
"github.com/spiral/roadrunner/v2/internal"
+ "github.com/spiral/roadrunner/v2/pkg/payload"
)
// Allocator is responsible for worker allocation in the pool
@@ -56,7 +57,7 @@ type SyncWorker interface {
// BaseProcess provides basic functionality for the SyncWorker
BaseProcess
// Exec used to execute payload on the SyncWorker, there is no TIMEOUTS
- Exec(rqs internal.Payload) (internal.Payload, error)
+ Exec(rqs payload.Payload) (payload.Payload, error)
// ExecWithContext used to handle Exec with TTL
- ExecWithContext(ctx context.Context, p internal.Payload) (internal.Payload, error)
+ ExecWithContext(ctx context.Context, p payload.Payload) (payload.Payload, error)
}