Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Run ¶
func Run(from string, listenPort int, resultsCh chan types.ContainerReport)
Run creates an RPC Receiver server and registers the remoteMethods which are used by attached harvesting containers to submit results back to the scheduler.
func SendResult ¶
func SendResult(result types.ContainerReport, harvesterHostname string) (bool, error)
SendResult submits the ContainerReport populated with the output from each AttachedCapability run on the attached container. This sends to the `scheduler` host which will have been aliased at container creation to the node where the the scheduler is running.
Types ¶
type RemoteMethods ¶
type RemoteMethods struct {
// contains filtered or unexported fields
}
RemoteMethods is a dummy struct used to hang RPC remote methods off.
func (*RemoteMethods) SubmitCapabilities ¶
func (r *RemoteMethods) SubmitCapabilities(data *types.ContainerReport, ack *Ack) error
SubmitCapabilities used to submit data to the server
Source Files
Click to show internal directories.
Click to hide internal directories.