Documentation
¶
Index ¶
- Constants
- type Server
- func (s *Server) AssessTables(ctx context.Context, req *pb.AssessTables_Request) (*pb.AssessTables_Response, error)
- 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
- func (s *Server) WriteStream(stream pb.Plugin_WriteStreamServer) error
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
MaxMsgSize int
}
func (*Server) AssessTables ¶ added in v4.97.0
func (s *Server) AssessTables(ctx context.Context, req *pb.AssessTables_Request) (*pb.AssessTables_Response, error)
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 ¶ added in v4.30.0
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 ¶ added in v4.43.0
func (s *Server) TestConnection(ctx context.Context, req *pb.TestConnection_Request) (*pb.TestConnection_Response, error)
func (*Server) Transform ¶ added in v4.50.0
func (s *Server) Transform(stream pb.Plugin_TransformServer) error
func (*Server) TransformSchema ¶ added in v4.56.0
func (s *Server) TransformSchema(ctx context.Context, req *pb.TransformSchema_Request) (*pb.TransformSchema_Response, error)
func (*Server) WriteStream ¶ added in v4.99.0
func (s *Server) WriteStream(stream pb.Plugin_WriteStreamServer) error
WriteStream is Write that also accepts flushes. It answers each flush once the plugin's Write has tried to commit every message sent before it, with an error if some of them may not have been committed. A failed flush does not end the stream.
Source Files
Click to show internal directories.
Click to hide internal directories.