rpcreceiver

Documentation

Index

• func Run(from string, listenPort int, resultsCh chan types.ContainerReport)
• func SendResult(result types.ContainerReport, harvesterHostname string) (bool, error)
• type Ack
• type RemoteMethods
  • func (r *RemoteMethods) SubmitCapabilities(data *types.ContainerReport, ack *Ack) error

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 Ack

type Ack bool

Ack contains the response from the RPC Receiver server

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