plugin

type ProtocolPlugin ¶

type ProtocolPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	// Concrete implementation, written in Go. This is only used for plugins
	// that are written in Go.
	Impl shared.Protocol
}

This is the implementation of plugin.Plugin so we can serve/consume this. We also implement GRPCPlugin so that this plugin can be served over gRPC.

func (p *ProtocolPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (p *ProtocolPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error