Documentation
¶
Index ¶
- func NewFromBytes(b []byte) (*arrow.Schema, error)
- func NewSchemasFromBytes(b [][]byte) (schema.Schemas, error)
- type Server
- func (s *Server) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)
- func (s *Server) Configure(ctx context.Context, req *pb.Configure_Request) (*pb.Configure_Response, error)
- func (s *Server) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)
- func (*Server) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)
- func (s *Server) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
- func (s *Server) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)
- func (s *Server) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)
- func (s *Server) Write(msg pb.Destination_WriteServer) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Server ¶
type Server struct {
pb.UnimplementedDestinationServer
Plugin *plugin.Plugin
Logger zerolog.Logger
// contains filtered or unexported fields
}
func (*Server) Close ¶
func (s *Server) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)
func (*Server) Configure ¶
func (s *Server) Configure(ctx context.Context, req *pb.Configure_Request) (*pb.Configure_Response, error)
func (*Server) DeleteStale ¶
func (s *Server) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)
func (*Server) GetMetrics ¶
func (*Server) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)
func (*Server) GetName ¶
func (s *Server) GetName(context.Context, *pb.GetName_Request) (*pb.GetName_Response, error)
func (*Server) GetVersion ¶
func (s *Server) GetVersion(context.Context, *pb.GetVersion_Request) (*pb.GetVersion_Response, error)
func (*Server) Migrate ¶
func (s *Server) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)
Source Files
Click to show internal directories.
Click to hide internal directories.