client

Documentation

Index

• func New(_ context.Context, logger zerolog.Logger, s []byte, ...) (plugin.Client, error)
• type Client
  • func (*Client) Close(ctx context.Context) error
  • func (c *Client) Transform(ctx context.Context, recvRecords <-chan arrow.Record, ...) error
  • func (c *Client) TransformSchema(ctx context.Context, schema *arrow.Schema) (*arrow.Schema, error)

Functions

func New

func New(_ context.Context, logger zerolog.Logger, s []byte, opts plugin.NewClientOptions) (plugin.Client, error)

Types

type Client

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

func (*Client) Close

func (*Client) Close(ctx context.Context) error

func (*Client) Transform

func (c *Client) Transform(ctx context.Context, recvRecords <-chan arrow.Record, sendRecords chan<- arrow.Record) error

func (*Client) TransformSchema

func (c *Client) TransformSchema(ctx context.Context, schema *arrow.Schema) (*arrow.Schema, error)