destination

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

Functions

func NewFromBytes

func NewFromBytes(b []byte) (*arrow.Schema, error)

func NewSchemasFromBytes

func NewSchemasFromBytes(b [][]byte) (schema.Schemas, error)

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)

func (*Server) Write

func (s *Server) Write(msg pb.Destination_WriteServer) error

Note the order of operations in this method is important! Trying to insert into the `resources` channel before starting the reader goroutine will cause a deadlock.