The highest tagged major version is v4.

destination

package

v3.10.6 Latest Latest Go to latest Published: Jun 13, 2023 License: MPL-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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.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

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

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