plugin

package

v1.4.0 Latest Latest Go to latest Published: May 5, 2021 License: BSD-3-Clause Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var Handshake = plugin.HandshakeConfig{
	ProtocolVersion:  1,
	MagicCookieKey:   "NODE_PROCESS_PLUGIN",
	MagicCookieValue: "dynamic",
}

View Source

var PluginMap = map[string]plugin.Plugin{
	"nodeProcess": &AppPlugin{},
}

PluginMap is the map of plugins we can dispense.

This section is empty.

type AppPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	// contains filtered or unexported fields
}

AppPlugin is can be served/consumed with the hashicorp plugin library. Plugin implements plugin.GRPCPlugin

func New(app *process.App) *AppPlugin

func (p *AppPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

GRPCClient returns a new GRPC client

func (p *AppPlugin) GRPCServer(_ *plugin.GRPCBroker, s *grpc.Server) error

GRPCServer registers a new GRPC server.

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

func NewClient(node appproto.NodeClient) *Client

NewServer returns a vm instance connected to a remote vm instance

func (c *Client) Start() (int, error)

Blocks until the node is done shutting down. Returns the node's exit code.

func (c *Client) Stop() error

Blocks until the node is done shutting down.

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

Server wraps a node so it can be served with the hashicorp plugin harness

func NewServer(app *process.App) *Server

func (s *Server) Start(_ context.Context, req *appproto.StartRequest) (*appproto.StartResponse, error)

Blocks until the node returns

func (s *Server) Stop(_ context.Context, req *appproto.StopRequest) (*appproto.StopResponse, error)

Blocks until the node is done shutting down

Path	Synopsis
proto