runner

package
v0.0.0-...-f7dd217 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 9, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func HandshakeConfig

func HandshakeConfig() plugin.HandshakeConfig

func Serve

func Serve(impl Runner)

Types

type Plugin

type Plugin struct {
	Impl Runner
}

func (*Plugin) Client

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

func (*Plugin) Server

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

type RPCClient

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

func (*RPCClient) Run

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

type RPCServer

type RPCServer struct {
	Impl Runner
}

func (*RPCServer) Run

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

type Runner

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL