Documentation ¶
Index ¶
- Variables
- func IsEOFAndExitedSuccessfullyErr(err error) bool
- func NewExecutorSessions() *executorSessions
- type Client
- func (c *Client) Execute(args *ExecutorExecuteArgs, reply *ExecutorExecuteReply) error
- func (c *Client) GetFeedback(args *GetFeedbackArgs, reply *GetFeedbackReply) error
- func (c *Client) RunWithFeedback(args *ExecutorExecuteArgs, pollForFeedbackInterval time.Duration, ...) error
- func (c *Client) Start(args *ExecutorExecuteArgs, reply *ExecutorStartReply) error
- type Comms
- type Executor
- type ExecutorExecuteArgs
- type ExecutorExecuteReply
- type ExecutorStartReply
- type GetFeedbackArgs
- type GetFeedbackReply
Constants ¶
This section is empty.
Variables ¶
View Source
var (
EOF_AND_EXITED_SUCCESSFULLY = errors.New("EOF and Exited successfully")
)
View Source
var (
Version = "0.0.5"
)
Functions ¶
func NewExecutorSessions ¶
func NewExecutorSessions() *executorSessions
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewConnectedClient ¶
func (*Client) Execute ¶
func (c *Client) Execute(args *ExecutorExecuteArgs, reply *ExecutorExecuteReply) error
func (*Client) GetFeedback ¶
func (c *Client) GetFeedback(args *GetFeedbackArgs, reply *GetFeedbackReply) error
func (*Client) RunWithFeedback ¶
func (*Client) Start ¶
func (c *Client) Start(args *ExecutorExecuteArgs, reply *ExecutorStartReply) error
type Comms ¶
type Comms interface { Execute(executeArgs *ExecutorExecuteArgs, reply *ExecutorExecuteReply) error Start(executeArgs *ExecutorExecuteArgs, reply *ExecutorStartReply) error GetFeedback(args *GetFeedbackArgs, reply *GetFeedbackReply) error }
Comms is the shared interface between Client and Executor/server
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
Executor is the RPC server/executor
func (*Executor) Execute ¶
func (e *Executor) Execute(executeArgs *ExecutorExecuteArgs, reply *ExecutorExecuteReply) error
func (*Executor) GetFeedback ¶
func (e *Executor) GetFeedback(args *GetFeedbackArgs, reply *GetFeedbackReply) error
func (*Executor) Start ¶
func (e *Executor) Start(executeArgs *ExecutorExecuteArgs, reply *ExecutorStartReply) error
type ExecutorExecuteArgs ¶
type ExecutorExecuteReply ¶
type ExecutorStartReply ¶
type GetFeedbackArgs ¶
type GetFeedbackReply ¶
Click to show internal directories.
Click to hide internal directories.