func (cmd ExecuteActivity) ActivityParams(env bindings.WorkflowEnvironment, payloads *commonpb.Payloads) bindings.ExecuteActivityParams {
	params := bindings.ExecuteActivityParams{
		ExecuteActivityOptions: cmd.Options,
		ActivityType:           bindings.ActivityType{Name: cmd.Name},
		Input:                  payloads,
	}
	if params.TaskQueueName == "" {
		params.TaskQueueName = env.WorkflowInfo().TaskQueueName
	}
	return params
}
ActivityParams maps activity command to activity params.
package protocol
import (
	"time"
	"github.com/spiral/errors"
	commonpb "go.temporal.io/api/common/v1"
	"go.temporal.io/sdk/activity"
	bindings "go.temporal.io/sdk/internalbindings"
	"go.temporal.io/sdk/workflow"
)
const (
	getWorkerInfoCommand = "GetWorkerInfo"
	invokeActivityCommand  = "InvokeActivity"
	startWorkflowCommand   = "StartWorkflow"
	invokeSignalCommand    = "InvokeSignal"
	invokeQueryCommand     = "InvokeQuery"
	destroyWorkflowCommand = "DestroyWorkflow"
	cancelWorkflowCommand  = "CancelWorkflow"
	getStackTraceCommand   = "StackTrace"
	executeActivityCommand           = "ExecuteActivity"
	executeChildWorkflowCommand      = "ExecuteChildWorkflow"
	getChildWorkflowExecutionCommand = "GetChildWorkflowExecution"
	newTimerCommand         = "NewTimer"
	sideEffectCommand       = "SideEffect"
	getVersionCommand       = "GetVersion"
	completeWorkflowCommand = "CompleteWorkflow"
	continueAsNewCommand    = "ContinueAsNew"
	signalExternalWorkflowCommand = "SignalExternalWorkflow"
	cancelExternalWorkflowCommand = "CancelExternalWorkflow"
	cancelCommand = "Cancel"
	panicCommand  = "Panic"
)
type GetWorkerInfo struct{}
type InvokeActivity struct {
	Name string `json:"name"`
	Info activity.Info `json:"info"`
	HeartbeatDetails int `json:"heartbeatDetails,omitempty"`
}
type StartWorkflow struct {
	Info *workflow.Info `json:"info"`
	LastCompletion int `json:"lastCompletion,omitempty"`
}
type InvokeSignal struct {
	RunID string `json:"runId"`
	Name string `json:"name"`
}
type InvokeQuery struct {
	RunID string `json:"runId"`
	Name string `json:"name"`
}
type CancelWorkflow struct {
	RunID string `json:"runId"`
}
type DestroyWorkflow struct {
	RunID string `json:"runId"`
}
type GetStackTrace struct {
	RunID string `json:"runId"`
}
type ExecuteActivity struct {
	Name string `json:"name"`
	Options bindings.ExecuteActivityOptions `json:"options,omitempty"`
}
type ExecuteChildWorkflow struct {
	Name string `json:"name"`
	Options bindings.WorkflowOptions `json:"options,omitempty"`
}
type GetChildWorkflowExecution struct {
	ID uint64 `json:"id"`
}
type NewTimer struct {
	Milliseconds int `json:"ms"`
}
type SideEffect struct{}
type GetVersion struct {
	ChangeID     string `json:"changeID"`
	MinSupported int    `json:"minSupported"`
	MaxSupported int    `json:"maxSupported"`
}
type CompleteWorkflow struct{}
type ContinueAsNew struct {
	Name string `json:"name"`
	Options struct {
		TaskQueueName            string
		WorkflowExecutionTimeout time.Duration
		WorkflowRunTimeout       time.Duration
		WorkflowTaskTimeout      time.Duration
	} `json:"options"`
}
type SignalExternalWorkflow struct {
	Namespace         string `json:"namespace"`
	WorkflowID        string `json:"workflowID"`
	RunID             string `json:"runID"`
	Signal            string `json:"signal"`
	ChildWorkflowOnly bool   `json:"childWorkflowOnly"`
}
type CancelExternalWorkflow struct {
	Namespace  string `json:"namespace"`
	WorkflowID string `json:"workflowID"`
	RunID      string `json:"runID"`
}
type Cancel struct {
	CommandIDs []uint64 `json:"ids"`
}
type Panic struct {
	Message string `json:"message"`
}