grpcplugin

package

v1.0.0-alpha1 Latest Latest Go to latest Published: Sep 12, 2024 License: MIT Imports: 7 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	// contains filtered or unexported fields
}

func NewGrpcClient(
	impl pluginv1.PluginServiceClient,
) *Client

func (c *Client) Import(fileData []byte) (*messages.ImportFileResponse, error)

func (c *Client) ImportLocalFile(filePath string) (*messages.ImportFileResponse, error)

func (c *Client) PluginInfo() (
	*messages.PluginInfoResponse,
	error,
)

type GrpcPlugin struct {
	plugin.Plugin
	// contains filtered or unexported fields
}

func NewGrpcPlugin(
	impl interfaces.LimePipesPlugin,
) *GrpcPlugin

func (g *GrpcPlugin) GRPCClient(
	_ context.Context,
	_ *plugin.GRPCBroker,
	conn *grpc.ClientConn,
) (any, error)

func (g *GrpcPlugin) GRPCServer(
	_ *plugin.GRPCBroker,
	server *grpc.Server,
) error

type Server struct {
	pluginv1.UnimplementedPluginServiceServer
	// contains filtered or unexported fields
}

func NewGrpcServer(
	impl interfaces.LimePipesPlugin,
) *Server

func (s *Server) ImportFile(
	_ context.Context,
	req *messages.ImportFileRequest,
) (*messages.ImportFileResponse, error)

func (s *Server) PluginInfo(
	context.Context,
	*messages.PluginInfoRequest,
) (*messages.PluginInfoResponse, error)