server

May 11, 2025

Changes in this version

+ type GRPCPlugin struct

+ Impl pb.PluginServer

+ func (p *GRPCPlugin) Client(broker *plugin.MuxBroker, rpcClient *rpc.Client) (interface{}, error)

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

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

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

+ type PluginServer struct

+ func NewPluginServer(impl pb.PluginServer) *PluginServer

+ func (p *PluginServer) Close(ctx context.Context, req *pb.CloseRequest) (*pb.CloseResponse, error)

+ func (p *PluginServer) GetMetadata(ctx context.Context, req *pb.GetMetadataRequest) (*pb.GetMetadataResponse, error)

+ func (p *PluginServer) Initialize(ctx context.Context, req *pb.InitializeRequest) (*pb.InitializeResponse, error)

+ func (p *PluginServer) Serve()