plugin

package

v1.4.0 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 39 Imported by: 0

Details

This section is empty.

View Source

var (
	Name    = "yc"
	Kind    = "source"
	Team    = "yandex-cloud"
	Version = "development"
)

func NewClient(ctx context.Context, logger zerolog.Logger, specBytes []byte, options plugin.NewClientOptions) (plugin.Client, error)

func Plugin() *plugin.Plugin

func PluginAutoGeneratedTables() schema.Tables

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, _ plugin.TableOptions) (schema.Tables, error)