client

package

v0.0.0-...-ccb566b Latest Latest Go to latest Published: Oct 24, 2023 License: MPL-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func Configure(ctx context.Context, logger zerolog.Logger, spec []byte, opts plugin.NewClientOptions) (plugin.Client, error)

func GetValue(arr arrow.Array, i int) (any, error)

func Identifier(name string) string

func SQLType(t arrow.DataType) string

func SchemaType(dataType string, columnType string) arrow.DataType

func TransformRecord(record arrow.Record) ([][]any, error)

used in the tests to insert the arrow.Record

type Client struct {
	plugin.UnimplementedDestination
	// contains filtered or unexported fields
}

func (c Client) Close(_ context.Context) error

func (*Client) ID() string

func (c Client) Sync(ctx context.Context, options plugin.SyncOptions, res chan<- message.SyncMessage) error

func (c Client) Tables(ctx context.Context, opts plugin.TableOptions) (schema.Tables, error)

type Spec struct {
	ConnectionString string `json:"connection_string,omitempty"`
}

func (*Spec) SetDefaults()

func (s *Spec) Validate() error