plugin

package

v1.0.0 Latest Latest Go to latest Published: Oct 11, 2025 License: MPL-2.0 Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

View Source

var (
	Name    = "upwind"
	Kind    = "source"
	Team    = "tektite-io"
	Version = "v1.0.1"
)

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

func Plugin() *plugin.Plugin

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

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

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

func (c *Client) Tables(_ context.Context, options plugin.TableOptions) (schema.Tables, error)