Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var TaskHandshakeConfig = plugin.HandshakeConfig{
ProtocolVersion: 1,
MagicCookieKey: "WALNUT_TASK",
MagicCookieValue: "MTXPTRXXJY",
}
Functions ¶
This section is empty.
Types ¶
type RunParameters ¶
type Task ¶
type Task interface {
Run(RunParameters) TaskResult
}
type TaskPlugin ¶
type TaskPlugin struct {
Impl Task
}
func (TaskPlugin) Client ¶
func (TaskPlugin) Client(b *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
func (*TaskPlugin) Server ¶
func (p *TaskPlugin) Server(*plugin.MuxBroker) (interface{}, error)
type TaskResult ¶
type TaskRpc ¶
type TaskRpc struct {
// contains filtered or unexported fields
}
Here is an implementation that talks over RPC
func (*TaskRpc) Run ¶
func (t *TaskRpc) Run(params RunParameters) TaskResult
type TaskRpcServer ¶
type TaskRpcServer struct {
Impl Task
}
func (*TaskRpcServer) Run ¶
func (s *TaskRpcServer) Run(params RunParameters, result *TaskResult) error
Click to show internal directories.
Click to hide internal directories.