1 files changed, 0 insertions, 77 deletions
diff --git a/plugins/temporal/protocol/protocol.go b/plugins/temporal/protocol/protocol.go
deleted file mode 100644
index 53076fdf..00000000
--- a/plugins/temporal/protocol/protocol.go
+++ /dev/null
@@ -1,77 +0,0 @@
-package protocol
-
-import (
-	"github.com/spiral/roadrunner/v2/pkg/payload"
-	"github.com/spiral/roadrunner/v2/plugins/logger"
-	commonpb "go.temporal.io/api/common/v1"
-	"go.temporal.io/api/failure/v1"
-)
-
-const (
-	// DebugNone disables all debug messages.
-	DebugNone = iota
-
-	// DebugNormal renders all messages into console.
-	DebugNormal
-
-	// DebugHumanized enables color highlights for messages.
-	DebugHumanized
-)
-
-// Context provides worker information about currently. Context can be empty for server level commands.
-type Context struct {
-	// TaskQueue associates message batch with the specific task queue in underlying worker.
-	TaskQueue string `json:"taskQueue,omitempty"`
-
-	// TickTime associated current or historical time with message batch.
-	TickTime string `json:"tickTime,omitempty"`
-
-	// Replay indicates that current message batch is historical.
-	Replay bool `json:"replay,omitempty"`
-}
-
-// Message used to exchange the send commands and receive responses from underlying workers.
-type Message struct {
-	// ID contains ID of the command, response or error.
-	ID uint64 `json:"id"`
-
-	// Command of the message in unmarshalled form. Pointer.
-	Command interface{} `json:"command,omitempty"`
-
-	// Failure associated with command id.
-	Failure *failure.Failure `json:"failure,omitempty"`
-
-	// Payloads contains message specific payloads in binary format.
-	Payloads *commonpb.Payloads `json:"payloads,omitempty"`
-}
-
-// Codec manages payload encoding and decoding while communication with underlying worker.
-type Codec interface {
-	// WithLogger creates new codes instance with attached logger.
-	WithLogger(logger.Logger) Codec
-
-	// GetName returns codec name.
-	GetName() string
-
-	// Execute sends message to worker and waits for the response.
-	Execute(e Endpoint, ctx Context, msg ...Message) ([]Message, error)
-}
-
-// Endpoint provides the ability to send and receive messages.
-type Endpoint interface {
-	// ExecWithContext allow to set ExecTTL
-	Exec(p payload.Payload) (payload.Payload, error)
-}
-
-// DebugLevel configures debug level.
-type DebugLevel int
-
-// IsEmpty only check if task queue set.
-func (ctx Context) IsEmpty() bool {
-	return ctx.TaskQueue == ""
-}
-
-// IsCommand returns true if message carries request.
-func (msg Message) IsCommand() bool {
-	return msg.Command != nil
-}