plugin

package
v4.54.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 30, 2024 License: MPL-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

This section is empty.

Types

type Server

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

func (*Server) Close

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

func (*Server) GetName

func (*Server) GetSpecSchema added in v4.30.0

func (*Server) GetTables

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

func (*Server) GetVersion

func (*Server) Init

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

func (*Server) Read

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

func (*Server) Sync

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

func (*Server) TestConnection added in v4.43.0

func (*Server) Transform added in v4.50.0

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

func (*Server) Write

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL