destination

package
v4.19.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2023 License: MPL-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CQTypesOneToRecord

func CQTypesOneToRecord(mem memory.Allocator, c schemav2.CQTypes, arrowSchema *arrow.Schema) arrow.Record

func CQTypesToRecord

func CQTypesToRecord(mem memory.Allocator, c []schemav2.CQTypes, arrowSchema *arrow.Schema) arrow.Record

func ColumnV2ToV3

func ColumnV2ToV3(column schemav2.Column) schema.Column

func ColumnsV2ToV3

func ColumnsV2ToV3(columns []schemav2.Column) []schema.Column

func SetDestinationManagedCqColumns

func SetDestinationManagedCqColumns(tables []*schema.Table)

Overwrites or adds the CQ columns that are managed by the destination plugins (_cq_sync_time, _cq_source_name).

func TableV2ToV3

func TableV2ToV3(table *schemav2.Table) *schema.Table

func TablesV2ToV3

func TablesV2ToV3(tables schemav2.Tables) schema.Tables

func TypeV2ToV3

func TypeV2ToV3(dataType schemav2.ValueType) arrow.DataType

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 (*Server) DeleteStale

func (s *Server) DeleteStale(ctx context.Context, req *pb.DeleteStale_Request) (*pb.DeleteStale_Response, error)

func (*Server) Migrate

func (s *Server) Migrate(ctx context.Context, req *pb.Migrate_Request) (*pb.Migrate_Response, error)

func (*Server) Write

func (*Server) Write2

func (s *Server) Write2(msg pb.Destination_Write2Server) 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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL