destination

package

v4.99.0 Latest Latest Go to latest Published: Oct 19, 2026 License: MPL-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudquery/plugin-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

func CQTypesOneToRecord(mem memory.Allocator, c schemav2.CQTypes, arrowSchema *arrow.Schema) arrow.RecordBatch
func CQTypesToRecord(mem memory.Allocator, c []schemav2.CQTypes, arrowSchema *arrow.Schema) arrow.RecordBatch
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

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.RecordBatch

func CQTypesToRecord ¶

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

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

func (*Server) Write ¶

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

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.

Source Files ¶

View all Source files

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