plugin

Documentation

Index

• Constants
• type Server
  • 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

Constants

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

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 (s *Server) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)

func (*Server) GetSpecSchema

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

func (*Server) GetTables

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

func (*Server) GetVersion

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

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

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

func (*Server) Transform

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

func (*Server) TransformSchema

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

func (*Server) Write

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