shared

Nov 24, 2021

Changes in this version

+ const PluginName

+ var Handshake = plugin.HandshakeConfig

+ var PluginMap = map[string]plugin.Plugin

+ type GRPCClient struct

+ func (c *GRPCClient) Get(req *pb.GetRequest) (*pb.GetResponse, error)

+ func (c *GRPCClient) Shutdown(req *pb.ShutdownRequest) (*pb.ShutdownResponse, error)

+ type GRPCServer struct

+ Impl PluginManager

+ func (m *GRPCServer) Get(_ context.Context, req *pb.GetRequest) (*pb.GetResponse, error)

+ func (m *GRPCServer) Shutdown(_ context.Context, req *pb.ShutdownRequest) (*pb.ShutdownResponse, error)

+ type PluginManager interface

+ Get func(req *pb.GetRequest) (*pb.GetResponse, error)

+ Shutdown func(req *pb.ShutdownRequest) (*pb.ShutdownResponse, error)

+ type PluginManagerPlugin struct

+ Impl PluginManager

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

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