grpcplugin

package

v1.0.0-beta1 Latest Latest Go to latest Published: Oct 9, 2024 License: MIT Imports: 8 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) Export(
	tunes []*tune.Tune,
) ([]byte, error)

func (c *Client) ExportToFile(
	tunes []*tune.Tune,
	filepath string,
) error

func (c *Client) Parse(
	data []byte,
) ([]*messages.ParsedTune, error)

func (c *Client) ParseFromFile(
	filePath string,
) ([]*messages.ParsedTune, 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) Export(
	_ context.Context,
	req *messages.ExportRequest,
) (*messages.ExportResponse, error)

func (s *Server) ExportToFile(
	_ context.Context,
	req *messages.ExportToFileRequest,
) (*messages.ExportToFileResponse, error)

func (s *Server) Parse(
	_ context.Context,
	req *messages.ParseRequest,
) (*messages.ParseResponse, error)

func (s *Server) ParseFromFile(
	_ context.Context,
	req *messages.ParseFromFileRequest,
) (*messages.ParseFromFileResponse, error)

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