Documentation ¶
Index ¶
- func CQTypesOneToRecord(mem memory.Allocator, c schemav2.CQTypes, arrowSchema *arrow.Schema) arrow.Record
- func CQTypesToRecord(mem memory.Allocator, c []schemav2.CQTypes, arrowSchema *arrow.Schema) arrow.Record
- func ColumnV2ToV3(column schemav2.Column) schema.Column
- func ColumnsV2ToV3(columns []schemav2.Column) []schema.Column
- func SetDestinationManagedCqColumns(tables []*schema.Table)
- func TableV2ToV3(table *schemav2.Table) *schema.Table
- func TablesV2ToV3(tables schemav2.Tables) schema.Tables
- func TypeV2ToV3(dataType schemav2.ValueType) arrow.DataType
- type Server
- func (s *Server) Close(ctx context.Context, _ *pb.Close_Request) (*pb.Close_Response, error)
- func (s *Server) Configure(ctx context.Context, req *pbBase.Configure_Request) (*pbBase.Configure_Response, error)
- func (s *Server) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)
- func (s *Server) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)
- func (s *Server) GetName(context.Context, *pbBase.GetName_Request) (*pbBase.GetName_Response, error)
- func (*Server) GetProtocolVersion(context.Context, *pbBase.GetProtocolVersion_Request) (*pbBase.GetProtocolVersion_Response, error)
- func (s *Server) GetVersion(context.Context, *pbBase.GetVersion_Request) (*pbBase.GetVersion_Response, error)
- func (s *Server) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)
- func (*Server) Write(pb.Destination_WriteServer) error
- func (s *Server) Write2(msg pb.Destination_Write2Server) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CQTypesOneToRecord ¶
func CQTypesToRecord ¶
func SetDestinationManagedCqColumns ¶
Overwrites or adds the CQ columns that are managed by the destination plugins (_cq_sync_time, _cq_source_name).
Types ¶
type Server ¶
type Server struct { pb.UnimplementedDestinationServer Plugin *destination.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 *pbBase.Configure_Request) (*pbBase.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 (s *Server) GetMetrics(context.Context, *pb.GetDestinationMetrics_Request) (*pb.GetDestinationMetrics_Response, error)
func (*Server) GetName ¶
func (s *Server) GetName(context.Context, *pbBase.GetName_Request) (*pbBase.GetName_Response, error)
func (*Server) GetProtocolVersion ¶
func (*Server) GetProtocolVersion(context.Context, *pbBase.GetProtocolVersion_Request) (*pbBase.GetProtocolVersion_Response, error)
func (*Server) GetVersion ¶
func (s *Server) GetVersion(context.Context, *pbBase.GetVersion_Request) (*pbBase.GetVersion_Response, error)
func (*Server) Migrate ¶
func (s *Server) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)
Click to show internal directories.
Click to hide internal directories.