plugin

Documentation

Index

• Variables
• type ProtocolPlugin
  • 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

Variables

var Logger *zap.Logger

Types

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 (*ProtocolPlugin) GRPCClient

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

func (*ProtocolPlugin) GRPCServer

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