runner

package

v0.0.0-...-f7dd217 Latest Latest Go to latest Published: Jan 9, 2020 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func HandshakeConfig() plugin.HandshakeConfig

func Serve(impl Runner)

type Plugin struct {
	Impl Runner
}

func (p *Plugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (p *Plugin) Server(broker *plugin.MuxBroker) (interface{}, error)

type RPCClient struct {
	// contains filtered or unexported fields
}

func (c *RPCClient) Run(index, timeout uint32, exMap map[string]string) ([]*pb.Result, error)

type RPCServer struct {
	Impl Runner
}

func (s *RPCServer) Run(args map[string]interface{}, resp *string) error

type Runner interface {
	Run(index, timeout uint32, exMap map[string]string) ([]*pb.Result, error)
}