plugin

package

v4.96.2 Latest Latest Go to latest Published: Aug 25, 2026 License: MPL-2.0 Imports: 17 Imported by: 0

Details

View Source

const MaxMsgSize = 100 * 1024 * 1024 // 100 MiB

This section is empty.

This section is empty.

type Server struct {
	pb.UnimplementedPluginServer
	Plugin    *plugin.Plugin
	Logger    zerolog.Logger
	Directory string
}

func (s *Server) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)

func (s *Server) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)

func (s *Server) GetSpecSchema(context.Context, *pb.GetSpecSchema_Request) (*pb.GetSpecSchema_Response, error)

func (s *Server) GetTables(ctx context.Context, req *pb.GetTables_Request) (*pb.GetTables_Response, error)

func (s *Server) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)

func (s *Server) Init(ctx context.Context, req *pb.Init_Request) (*pb.Init_Response, error)

func (s *Server) Read(req *pb.Read_Request, stream pb.Plugin_ReadServer) error

func (s *Server) Sync(req *pb.Sync_Request, stream pb.Plugin_SyncServer) error

func (s *Server) TestConnection(ctx context.Context, req *pb.TestConnection_Request) (*pb.TestConnection_Response, error)

func (s *Server) Transform(stream pb.Plugin_TransformServer) error

func (s *Server) TransformSchema(ctx context.Context, req *pb.TransformSchema_Request) (*pb.TransformSchema_Response, error)

func (s *Server) Write(stream pb.Plugin_WriteServer) error