server

package

v0.9.0 Latest Latest Go to latest Published: Jul 22, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type GRPCPlugin struct {
	plugin.NetRPCUnsupportedPlugin
	Impl pb.PluginServer
}

GRPCPlugin is the plugin implementation for go-plugin

func (p *GRPCPlugin) Client(_ *plugin.MuxBroker, _ *rpc.Client) (any, error)

Client is required by the go-plugin interface

func (p *GRPCPlugin) GRPCClient(_ context.Context, _ *plugin.GRPCBroker, c *grpc.ClientConn) (any, error)

GRPCClient is required by the go-plugin interface

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

GRPCServer is required by the go-plugin interface

func (p *GRPCPlugin) Server(_ *plugin.MuxBroker) (any, error)

Server is required by the go-plugin interface

type PluginServer struct {
	pb.UnimplementedPluginServer
	// contains filtered or unexported fields
}

PluginServer is the server implementation that plugins will use

func NewPluginServer(impl pb.PluginServer) *PluginServer

NewPluginServer creates a new plugin server

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

Close implements the plugin.Plugin interface

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

GetMetadata implements the plugin.Plugin interface

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

Initialize implements the plugin.Plugin interface

func (p *PluginServer) Serve()

Serve starts the plugin server